1KA_F2F/frontend/install/classes/class.ImportDB.php

<?php
/**
* 
* 	Class, ki skrbi za posodabljanje in uvažanje 1ka baze
*
*/

class ImportDB{
	
	var $clean_db_file = '../../sql/1ka_clean_26-11-2021.sql';	// Datoteka prazne baze za uvoz
	var $update_db_file = '../../sql/update2.sql';		        // Datoteka prazne baze za uvoz

    var $version = '';									// Trenutna verzija 1ke
	
	
	function __construct () {
				
		// Pogledamo ce je baza ze uvozena
		$sql = sisplet_query("SELECT * FROM misc WHERE what='version'");
		
		// Baza je ze uvozena - pogledamo verzijo
		if($sql !== FALSE && mysqli_num_rows($sql) > 0){
			$row = mysqli_fetch_array($sql);
			$this->version = $row['value'];
		}
	}
    
    
	// Pogledamo ce je baza uvozena
	public function checkDBEmpty(){
		
		return ($this->version == '') ? true : false;
	}
	
	// Pogledamo ce je baza posodobljena na najnovejso verzijo
	public function checkDBUpdated(){
		
		$update = $this->prepareUpdateArray();

		return (count($update['update_lines']) != 0) ? true : false;
    }
    
    // Vrnemo vrstice in verzijo za updatanje
	public function getDBUpdateLines(){
		
        $update = $this->prepareUpdateArray();
        
        $update['current_version'] = $this->version;

		return $update;
	}
        
    
    // Izvajamo uvoz celotne baze
    public function executeImport(){
        global $site_url;
        global $lang;

        // Pripravimo vrstice za uvoz
        $import = $this->prepareImportArray();

        // Uvozimo novo bazo
        $this->importCleanDB($import);
        
        // Ce je bilo vse ok potem izvedemo se posodobitev
        $sql = sisplet_query("SELECT * FROM misc WHERE what='version'");
        if($sql !== FALSE && mysqli_num_rows($sql) > 0){

            $row = mysqli_fetch_array($sql);
            $this->version = $row['value'];
            
            // Pripravimo vrstice za posodobitev
            $update = $this->prepareUpdateArray();

            // Izvedemo posodobitev
            $this->updateDB($update['new_version'], $update['update_lines']);
            
            echo $lang['install_database_import_complete'];
        }
        // Uvoz error
        else{
            echo $lang['install_database_import_error'];
        }
    }

	// Pripravimo vrstice za uvoz
	private function prepareImportArray(){
        global $lang;

		$import_lines = array();
		$query = '';
		
		$handle = fopen($this->clean_db_file, "r");
		if ($handle) {
		    while (($line = fgets($handle)) !== false){
				
				// Trimamo odvecne presledke
				$line = trim($line);
				
				// Shranimo vrstico za update
				if($line != '' && substr($line, 0, 1) != '#' && substr($line, 0, 2) != '--' && substr($line, 0, 2) != '//' && substr($line, 0, 2) != '/*'){
					
					// Ce je vrstica zakljucena s ; dodamo query v array
					if(substr($line, -1) == ';' || substr($line, 0, 22) == 'INSERT INTO `srv_help`'){
						
						$query .= $line;
						
						$import_lines[] = $query;
						$query = '';
					}
					// Ukaz je v vecih vrsticah - samo pripnemo string
					else{
						$query .= $line;
					}
				}
		    }
	
		    fclose($handle);
			
			// Se dodatno dodamo recnum funkcijo
			$import_lines[] = "CREATE FUNCTION MAX_RECNUM (aid INT(11))	RETURNS INT(11)	DETERMINISTIC BEGIN	DECLARE max INT(11); SELECT MAX(recnum) INTO max FROM srv_user WHERE ank_id = aid AND preview='0'; IF max IS NULL THEN SET max = '0'; END IF; RETURN max+1;	END;";
		} 
		else {
			echo $lang['install_database_sql_import_missing'];
		}
			
		return $import_lines;
	}
	
	// Uvoz nove prazne baze po vrsticah
	private function importCleanDB($import_lines){
        global $lang;

		// Izvedemo uvoz po posameznih ukazih
		if(count($import_lines) > 0){		
			foreach ($import_lines as $key => $import_line) {			

				$sql = sisplet_query($import_line);	
						     
				if (!$sql){
					echo $lang['install_database_import_line'].':<br />'.$import_line.'<br />';
					echo $lang['install_database_import_line_error'].': '.mysqli_error($GLOBALS['connect_db']);
					
					echo '<br /><br />';
				}
				/*else{
					echo 'Uvoz vrstice:<br />'.$import_line.'<br />';
					echo 'OK';
					
					echo '<br /><br />';
				}*/
				
				flush();
			}	
		}
	}
    
    
    // Izvajamo update celotne baze
    public function executeUpdate(){
        global $lang;

        // Pipravimo vrstice za posodobitev
        $update = $this->prepareUpdateArray();
        
        // Izvedemo update
        $this->updateDB($update['new_version'], $update['update_lines']);
        
        echo $lang['install_database_update_complete'];
    }

	// Pripravimo vrstice za posodabljanje
	private function prepareUpdateArray(){
        global $lang;
        
		$new_version = '';
		$update_lines = array();
		$update = false;
		$query = '';
		
		$handle = fopen($this->update_db_file, "r");
		if ($handle) {
		    while (($line = fgets($handle)) !== false){
				
				// Trimamo odvecne presledke
				$line = trim($line);
				
				// Shranimo vrstico za update
				if($update && $line != '' && substr($line, 0, 1) != '#'){
					
					// Ce je vrstica zakljucena s ; dodamo query v array
					if(substr($line, -1) == ';'){
						
						$query .= $line;
	
						// Pogledamo ce gre za vrstico verzije in jo shranimo
						if(strpos($query, ' WHERE what="version"') !== false){
							if (preg_match("/^update misc set value='(.*)' where what=/i", $query, $matches)) {
								$new_version = $matches[1];
							}
						}
						
						$update_lines[] = $query;
						$query = '';
					}
					// Ukaz je v vecih vrsticah - samo pripnemo string
					else{
						$query .= $line;
					}
				}
				
				// Ko pridemo do vrstice za trenutno verzijo shranimo vse nadaljne vrstice za update
				if(strpos($line, $this->version) !== false)			
					$update = true;
		    }
	
		    fclose($handle);		
		} 
		else {
			echo $lang['install_database_sql_update_missing'];
		}
			
		return array('new_version'=>$new_version, 'update_lines'=>$update_lines);
	}	

	// Izvedba popravkov od trenutne verzije naprej po vrsticah
	private function updateDB($new_version, $update_lines){
        global $lang;
        
		// Izvedemo posodobitve
		if($new_version != '' && count($update_lines) > 0){
			
			foreach ($update_lines as $key => $update_line) {
				
				$sql = sisplet_query($update_line);
	            
				if (!$sql){
					echo $lang['install_database_update_line'].':<br />'.$update_line.'<br />';
					echo $lang['install_database_update_error'].': '.mysqli_error($GLOBALS['connect_db']);
					
					echo '<br /><br />';
				}
				/*else{
					echo 'Posodabljanje vrstice:<br />'.$update_line.'<br />';
					echo 'OK';
					
					echo '<br /><br />';
				}*/

				flush();
			}
		}
	}
}

?>