1 files changed, 256 insertions, 0 deletions

diff --git a/frontend/install/classes/class.ImportDB.php b/frontend/install/classes/class.ImportDB.php
new file mode 100644
index 0000000..5ba632f
--- /dev/null
+++ b/frontend/install/classes/class.ImportDB.php
@@ -0,0 +1,256 @@
+<?php

+/**

+* 

+* 	Class, ki skrbi za posodabljanje in uvažanje 1ka baze

+*

+*/

+

+class ImportDB{

+	

+	var $clean_db_file = '../../sql/1ka_clean_27-7-2020.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();

+			}

+		}

+	}

+}

+

+?>
\ No newline at end of file