diff options
Diffstat (limited to 'sql/class.ImportDB.php')
| -rw-r--r-- | sql/class.ImportDB.php | 295 |
1 files changed, 295 insertions, 0 deletions
diff --git a/sql/class.ImportDB.php b/sql/class.ImportDB.php new file mode 100644 index 0000000..1390e96 --- /dev/null +++ b/sql/class.ImportDB.php @@ -0,0 +1,295 @@ +<?php
+/**
+*
+* Class, ki skrbi za posodabljanje in uvažanje 1ka baze
+*
+*/
+
+class ImportDB{
+
+ var $clean_db_file = '1ka_clean_27-7-2020.sql'; // Datoteka prazne baze za uvoz
+ var $update_db_file = 'update2.sql'; // Datoteka prazne baze za uvoz
+ var $excecute = false; // Ali izvajamo update/import
+ var $version = ''; // Trenutna verzija 1ke
+
+
+ function __construct () {
+
+ // Ali izvajamo update/import
+ $this->excecute = (isset($_GET['excecute']) && $_GET['excecute'] == '1') ? true : false;
+
+ // 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;
+ }
+
+
+ public function display(){
+
+ // Uvazamo celotno novo bazo
+ if($this->version == ''){
+ $this->displayInsert();
+ }
+ // Posodabljamo bazo na zadnjo verzijo
+ else{
+ $this->displayUpdate();
+ }
+ }
+
+ // Prikazemo uvoz baze
+ public function displayInsert(){
+ global $site_url;
+
+ echo '<h1>Uvoz nove 1ka MySql baze</h1>';
+
+ // Izvajamo uvoz celotne baze
+ if($this->excecute){
+
+ // Uvozimo novo bazo
+ $import = $this->prepareImportArray();
+ $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'];
+
+ $update = $this->prepareUpdateArray();
+ $this->updateDB($update['new_version'], $update['update_lines']);
+
+ echo 'Postopek uvoza podatkovne baze je dokončan.';
+
+ echo '<br /><br />';
+
+ // Gumb za nazaj na frontpage
+ echo '<a href="'.$site_url.'">Nazaj na prvo stran</a>';
+ }
+ // Uvoz error
+ else{
+ echo 'Prišlo je do napake pri uvažanju.';
+ }
+ }
+ else{
+ echo 'Izvedel se bo uvoz celotne MySql baze. Postopek lahko traja nekaj minut!<br />';
+
+ echo '<br />';
+
+ // Gumb za posodobitev
+ echo '<a href="'.$site_url.'sql/import_db.php?excecute=1">Uvozi</a>';
+ }
+ }
+
+ // Prikazemo update baze
+ public function displayUpdate(){
+ global $site_url;
+
+ echo '<h1>Posodobitev 1ka MySql baze</h1>';
+
+ $update = $this->prepareUpdateArray();
+
+ // Izvajamo posodobitev baze
+ if($this->excecute){
+ $this->updateDB($update['new_version'], $update['update_lines']);
+ }
+ elseif(count($update['update_lines']) != 0){
+
+ echo 'Trenutna verzija: <b>'.$this->version.'</b>';
+ echo '<br />';
+ echo 'Posodobitev na verzijo: <b>'.$update['new_version'].'</b>';
+ echo '<br /><br />';
+ echo 'Izvedla se bo posodobitev MySql baze!';
+ echo '<br /><br />';
+
+ foreach ($update['update_lines'] as $key => $update_line) {
+ echo $update_line.'<br /><br />';
+ }
+
+ echo '<br />';
+
+ // Gumb za posodobitev
+ echo '<a href="'.$site_url.'sql/import_db.php?excecute=1">Posodobi</a>';
+ }
+ else{
+ echo 'Nameščena je najnovejša različica MySql baze.';
+
+ echo '<br /><br />';
+
+ // Gumb za nazaj na frontpage
+ echo '<a href="'.$site_url.'">Nazaj na prvo stran</a>';
+ }
+ }
+
+
+ // Pripravimo vrstice za uvoz
+ private function prepareImportArray(){
+
+ $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 'Manjka sql datoteka za uvoz!';
+ }
+
+ return $import_lines;
+ }
+
+ // Uvoz nove prazne baze
+ private function importCleanDB($import_lines){
+
+ // 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 'Uvoz vrstice:<br />'.$import_line.'<br />';
+ echo 'Napaka pri uvozu: '.mysqli_error($GLOBALS['connect_db']);
+
+ echo '<br /><br />';
+ }
+ /*else{
+ echo 'Uvoz vrstice:<br />'.$import_line.'<br />';
+ echo 'OK';
+
+ echo '<br /><br />';
+ }*/
+
+ flush();
+ }
+ }
+ }
+
+ // Pripravimo vrstice za posodabljanje
+ private function prepareUpdateArray(){
+
+ $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 'Manjka sql datoteka za posodobitev!';
+ }
+
+ return array('new_version'=>$new_version, 'update_lines'=>$update_lines);
+ }
+
+ // Izvedba popravkov od trenutne verzije naprej
+ private function updateDB($new_version, $update_lines){
+
+ // Izvedemo posodobitve
+ if($new_version != '' && count($update_lines) > 0){
+
+ foreach ($update_lines as $key => $update_line) {
+
+ $sql = sisplet_query($update_line);
+
+ if (!$sql){
+ echo 'Posodabljanje vrstice:<br />'.$update_line.'<br />';
+ echo 'Napaka pri posodabljanju: '.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 |