1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
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();
}
}
}
}
?>
|
