@@ -258,7 +258,9 @@ discard block |
||
258 | 258 | // Update table countries |
259 | 259 | if ($Connection->tableExists('airspace')) { |
260 | 260 | $error .= update_db::update_countries(); |
261 | - if ($error != '') return $error; |
|
261 | + if ($error != '') { |
|
262 | + return $error; |
|
263 | + } |
|
262 | 264 | } |
263 | 265 | // Update schema_version to 7 |
264 | 266 | $query = "UPDATE `config` SET `value` = '7' WHERE `name` = 'schema_version'"; |
@@ -314,7 +316,9 @@ discard block |
||
314 | 316 | $error = ''; |
315 | 317 | // Update table aircraft |
316 | 318 | $error .= create_db::import_file('../db/source_location.sql'); |
317 | - if ($error != '') return $error; |
|
319 | + if ($error != '') { |
|
320 | + return $error; |
|
321 | + } |
|
318 | 322 | // Update schema_version to 6 |
319 | 323 | $query = "UPDATE `config` SET `value` = '8' WHERE `name` = 'schema_version'"; |
320 | 324 | try { |
@@ -331,7 +335,9 @@ discard block |
||
331 | 335 | $error = ''; |
332 | 336 | // Update table aircraft |
333 | 337 | $error .= create_db::import_file('../db/notam.sql'); |
334 | - if ($error != '') return $error; |
|
338 | + if ($error != '') { |
|
339 | + return $error; |
|
340 | + } |
|
335 | 341 | $query = "DELETE FROM config WHERE name = 'last_update_db'; |
336 | 342 | INSERT INTO config (name,value) VALUES ('last_update_db',NOW()); |
337 | 343 | DELETE FROM config WHERE name = 'last_update_notam_db'; |
@@ -365,7 +371,9 @@ discard block |
||
365 | 371 | $error = ''; |
366 | 372 | // Update table atc |
367 | 373 | $error .= create_db::import_file('../db/atc.sql'); |
368 | - if ($error != '') return $error; |
|
374 | + if ($error != '') { |
|
375 | + return $error; |
|
376 | + } |
|
369 | 377 | |
370 | 378 | $query = "UPDATE `config` SET `value` = '10' WHERE `name` = 'schema_version'"; |
371 | 379 | try { |
@@ -389,13 +397,21 @@ discard block |
||
389 | 397 | $error = ''; |
390 | 398 | // Add tables |
391 | 399 | $error .= create_db::import_file('../db/aircraft_owner.sql'); |
392 | - if ($error != '') return $error; |
|
400 | + if ($error != '') { |
|
401 | + return $error; |
|
402 | + } |
|
393 | 403 | $error .= create_db::import_file('../db/metar.sql'); |
394 | - if ($error != '') return $error; |
|
404 | + if ($error != '') { |
|
405 | + return $error; |
|
406 | + } |
|
395 | 407 | $error .= create_db::import_file('../db/taf.sql'); |
396 | - if ($error != '') return $error; |
|
408 | + if ($error != '') { |
|
409 | + return $error; |
|
410 | + } |
|
397 | 411 | $error .= create_db::import_file('../db/airport.sql'); |
398 | - if ($error != '') return $error; |
|
412 | + if ($error != '') { |
|
413 | + return $error; |
|
414 | + } |
|
399 | 415 | |
400 | 416 | $query = "UPDATE `config` SET `value` = '11' WHERE `name` = 'schema_version'"; |
401 | 417 | try { |
@@ -469,19 +485,33 @@ discard block |
||
469 | 485 | $error = ''; |
470 | 486 | // Add tables |
471 | 487 | $error .= create_db::import_file('../db/stats.sql'); |
472 | - if ($error != '') return $error; |
|
488 | + if ($error != '') { |
|
489 | + return $error; |
|
490 | + } |
|
473 | 491 | $error .= create_db::import_file('../db/stats_aircraft.sql'); |
474 | - if ($error != '') return $error; |
|
492 | + if ($error != '') { |
|
493 | + return $error; |
|
494 | + } |
|
475 | 495 | $error .= create_db::import_file('../db/stats_airline.sql'); |
476 | - if ($error != '') return $error; |
|
496 | + if ($error != '') { |
|
497 | + return $error; |
|
498 | + } |
|
477 | 499 | $error .= create_db::import_file('../db/stats_airport.sql'); |
478 | - if ($error != '') return $error; |
|
500 | + if ($error != '') { |
|
501 | + return $error; |
|
502 | + } |
|
479 | 503 | $error .= create_db::import_file('../db/stats_owner.sql'); |
480 | - if ($error != '') return $error; |
|
504 | + if ($error != '') { |
|
505 | + return $error; |
|
506 | + } |
|
481 | 507 | $error .= create_db::import_file('../db/stats_pilot.sql'); |
482 | - if ($error != '') return $error; |
|
508 | + if ($error != '') { |
|
509 | + return $error; |
|
510 | + } |
|
483 | 511 | $error .= create_db::import_file('../db/spotter_archive_output.sql'); |
484 | - if ($error != '') return $error; |
|
512 | + if ($error != '') { |
|
513 | + return $error; |
|
514 | + } |
|
485 | 515 | |
486 | 516 | $query = "UPDATE `config` SET `value` = '13' WHERE `name` = 'schema_version'"; |
487 | 517 | try { |
@@ -521,7 +551,9 @@ discard block |
||
521 | 551 | // Add tables |
522 | 552 | if (!$Connection->tableExists('stats_flight')) { |
523 | 553 | $error .= create_db::import_file('../db/stats_flight.sql'); |
524 | - if ($error != '') return $error; |
|
554 | + if ($error != '') { |
|
555 | + return $error; |
|
556 | + } |
|
525 | 557 | } |
526 | 558 | $query = "UPDATE `config` SET `value` = '15' WHERE `name` = 'schema_version'"; |
527 | 559 | try { |
@@ -545,7 +577,9 @@ discard block |
||
545 | 577 | } catch(PDOException $e) { |
546 | 578 | return "error (update stats) : ".$e->getMessage()."\n"; |
547 | 579 | } |
548 | - if ($error != '') return $error; |
|
580 | + if ($error != '') { |
|
581 | + return $error; |
|
582 | + } |
|
549 | 583 | $query = "UPDATE `config` SET `value` = '16' WHERE `name` = 'schema_version'"; |
550 | 584 | try { |
551 | 585 | $sth = $Connection->db->prepare($query); |
@@ -566,7 +600,9 @@ discard block |
||
566 | 600 | if (!$Connection->tableExists('stats_callsign')) { |
567 | 601 | $error .= create_db::import_file('../db/stats_callsign.sql'); |
568 | 602 | } |
569 | - if ($error != '') return $error; |
|
603 | + if ($error != '') { |
|
604 | + return $error; |
|
605 | + } |
|
570 | 606 | $query = "UPDATE `config` SET `value` = '17' WHERE `name` = 'schema_version'"; |
571 | 607 | try { |
572 | 608 | $sth = $Connection->db->prepare($query); |
@@ -584,7 +620,9 @@ discard block |
||
584 | 620 | if (!$Connection->tableExists('stats_country')) { |
585 | 621 | $error .= create_db::import_file('../db/stats_country.sql'); |
586 | 622 | } |
587 | - if ($error != '') return $error; |
|
623 | + if ($error != '') { |
|
624 | + return $error; |
|
625 | + } |
|
588 | 626 | $query = "UPDATE `config` SET `value` = '18' WHERE `name` = 'schema_version'"; |
589 | 627 | try { |
590 | 628 | $sth = $Connection->db->prepare($query); |
@@ -607,7 +645,9 @@ discard block |
||
607 | 645 | return "error (update stats) : ".$e->getMessage()."\n"; |
608 | 646 | } |
609 | 647 | } |
610 | - if ($error != '') return $error; |
|
648 | + if ($error != '') { |
|
649 | + return $error; |
|
650 | + } |
|
611 | 651 | $query = "UPDATE `config` SET `value` = '19' WHERE `name` = 'schema_version'"; |
612 | 652 | try { |
613 | 653 | $sth = $Connection->db->prepare($query); |
@@ -623,7 +663,9 @@ discard block |
||
623 | 663 | $error = ''; |
624 | 664 | // Update airport table |
625 | 665 | $error .= create_db::import_file('../db/airport.sql'); |
626 | - if ($error != '') return 'Import airport.sql : '.$error; |
|
666 | + if ($error != '') { |
|
667 | + return 'Import airport.sql : '.$error; |
|
668 | + } |
|
627 | 669 | // Remove primary key on Spotter_Archive |
628 | 670 | $query = "alter table spotter_archive drop spotter_archive_id"; |
629 | 671 | try { |
@@ -699,7 +741,9 @@ discard block |
||
699 | 741 | return "error (add source_name column) : ".$e->getMessage()."\n"; |
700 | 742 | } |
701 | 743 | } |
702 | - if ($error != '') return $error; |
|
744 | + if ($error != '') { |
|
745 | + return $error; |
|
746 | + } |
|
703 | 747 | $query = "UPDATE `config` SET `value` = '20' WHERE `name` = 'schema_version'"; |
704 | 748 | try { |
705 | 749 | $sth = $Connection->db->prepare($query); |
@@ -717,7 +761,9 @@ discard block |
||
717 | 761 | // Update airline table |
718 | 762 | if (!$globalIVAO && !$globalVATSIM && !$globalphpVMS) { |
719 | 763 | $error .= create_db::import_file('../db/airlines.sql'); |
720 | - if ($error != '') return 'Import airlines.sql : '.$error; |
|
764 | + if ($error != '') { |
|
765 | + return 'Import airlines.sql : '.$error; |
|
766 | + } |
|
721 | 767 | } |
722 | 768 | if (!$Connection->checkColumnName('aircraft_modes','type_flight')) { |
723 | 769 | // Add column over_country |
@@ -729,7 +775,9 @@ discard block |
||
729 | 775 | return "error (add over_country) : ".$e->getMessage()."\n"; |
730 | 776 | } |
731 | 777 | } |
732 | - if ($error != '') return $error; |
|
778 | + if ($error != '') { |
|
779 | + return $error; |
|
780 | + } |
|
733 | 781 | /* |
734 | 782 | if (!$globalIVAO && !$globalVATSIM && !$globalphpVMS) { |
735 | 783 | // Force update ModeS (this will put type_flight data |
@@ -759,7 +807,9 @@ discard block |
||
759 | 807 | } catch(PDOException $e) { |
760 | 808 | return "error (rename type to stats_type on stats*) : ".$e->getMessage()."\n"; |
761 | 809 | } |
762 | - if ($error != '') return $error; |
|
810 | + if ($error != '') { |
|
811 | + return $error; |
|
812 | + } |
|
763 | 813 | } |
764 | 814 | $query = "UPDATE `config` SET `value` = '22' WHERE `name` = 'schema_version'"; |
765 | 815 | try { |
@@ -782,7 +832,9 @@ discard block |
||
782 | 832 | } else { |
783 | 833 | $error .= create_db::import_file('../db/pgsql/stats_source.sql'); |
784 | 834 | } |
785 | - if ($error != '') return $error; |
|
835 | + if ($error != '') { |
|
836 | + return $error; |
|
837 | + } |
|
786 | 838 | } |
787 | 839 | $query = "UPDATE config SET value = '23' WHERE name = 'schema_version'"; |
788 | 840 | try { |
@@ -804,12 +856,16 @@ discard block |
||
804 | 856 | if ($globalDBdriver == 'mysql') { |
805 | 857 | if (!$Connection->tableExists('tle')) { |
806 | 858 | $error .= create_db::import_file('../db/tle.sql'); |
807 | - if ($error != '') return $error; |
|
859 | + if ($error != '') { |
|
860 | + return $error; |
|
861 | + } |
|
808 | 862 | } |
809 | 863 | } else { |
810 | 864 | if (!$Connection->tableExists('tle')) { |
811 | 865 | $error .= create_db::import_file('../db/pgsql/tle.sql'); |
812 | - if ($error != '') return $error; |
|
866 | + if ($error != '') { |
|
867 | + return $error; |
|
868 | + } |
|
813 | 869 | } |
814 | 870 | $query = "create index flightaware_id_idx ON spotter_archive USING btree(flightaware_id)"; |
815 | 871 | try { |
@@ -849,7 +905,9 @@ discard block |
||
849 | 905 | } else { |
850 | 906 | $error .= create_db::import_file('../db/pgsql/airlines.sql'); |
851 | 907 | } |
852 | - if ($error != '') return 'Import airlines.sql : '.$error; |
|
908 | + if ($error != '') { |
|
909 | + return 'Import airlines.sql : '.$error; |
|
910 | + } |
|
853 | 911 | if (!$Connection->checkColumnName('airlines','forsource')) { |
854 | 912 | // Add forsource to airlines |
855 | 913 | $query = "ALTER TABLE airlines ADD forsource VARCHAR(255) NULL DEFAULT NULL"; |
@@ -861,7 +919,9 @@ discard block |
||
861 | 919 | } |
862 | 920 | } else { |
863 | 921 | $errort = $Connection->checkColumnName('airlines','forsource'); |
864 | - if ($errort !== true && $errort !== false) return 'Error check column airlines : '.$errort; |
|
922 | + if ($errort !== true && $errort !== false) { |
|
923 | + return 'Error check column airlines : '.$errort; |
|
924 | + } |
|
865 | 925 | } |
866 | 926 | if (!$Connection->checkColumnName('stats_aircraft','stats_airline')) { |
867 | 927 | // Add forsource to airlines |
@@ -908,7 +968,9 @@ discard block |
||
908 | 968 | } |
909 | 969 | } else { |
910 | 970 | $errort = $Connection->checkColumnName('stats_airport','stats_airline'); |
911 | - if ($errort !== true && $errort !== false) return 'Error check column stats_airport : '.$errort; |
|
971 | + if ($errort !== true && $errort !== false) { |
|
972 | + return 'Error check column stats_airport : '.$errort; |
|
973 | + } |
|
912 | 974 | } |
913 | 975 | if (!$Connection->checkColumnName('stats_country','stats_airline')) { |
914 | 976 | // Add forsource to airlines |
@@ -1119,8 +1181,11 @@ discard block |
||
1119 | 1181 | if ($Connection->tableExists('aircraft')) { |
1120 | 1182 | if (!$Connection->tableExists('config')) { |
1121 | 1183 | $version = '1'; |
1122 | - if ($update) return self::update_from_1(); |
|
1123 | - else return $version; |
|
1184 | + if ($update) { |
|
1185 | + return self::update_from_1(); |
|
1186 | + } else { |
|
1187 | + return $version; |
|
1188 | + } |
|
1124 | 1189 | } else { |
1125 | 1190 | $Connection = new Connection(); |
1126 | 1191 | $query = "SELECT value FROM config WHERE name = 'schema_version' LIMIT 1"; |
@@ -1134,106 +1199,183 @@ discard block |
||
1134 | 1199 | if ($update) { |
1135 | 1200 | if ($result['value'] == '2') { |
1136 | 1201 | $error = self::update_from_2(); |
1137 | - if ($error != '') return $error; |
|
1138 | - else return self::check_version(true); |
|
1202 | + if ($error != '') { |
|
1203 | + return $error; |
|
1204 | + } else { |
|
1205 | + return self::check_version(true); |
|
1206 | + } |
|
1139 | 1207 | } elseif ($result['value'] == '3') { |
1140 | 1208 | $error = self::update_from_3(); |
1141 | - if ($error != '') return $error; |
|
1142 | - else return self::check_version(true); |
|
1209 | + if ($error != '') { |
|
1210 | + return $error; |
|
1211 | + } else { |
|
1212 | + return self::check_version(true); |
|
1213 | + } |
|
1143 | 1214 | } elseif ($result['value'] == '4') { |
1144 | 1215 | $error = self::update_from_4(); |
1145 | - if ($error != '') return $error; |
|
1146 | - else return self::check_version(true); |
|
1216 | + if ($error != '') { |
|
1217 | + return $error; |
|
1218 | + } else { |
|
1219 | + return self::check_version(true); |
|
1220 | + } |
|
1147 | 1221 | } elseif ($result['value'] == '5') { |
1148 | 1222 | $error = self::update_from_5(); |
1149 | - if ($error != '') return $error; |
|
1150 | - else return self::check_version(true); |
|
1223 | + if ($error != '') { |
|
1224 | + return $error; |
|
1225 | + } else { |
|
1226 | + return self::check_version(true); |
|
1227 | + } |
|
1151 | 1228 | } elseif ($result['value'] == '6') { |
1152 | 1229 | $error = self::update_from_6(); |
1153 | - if ($error != '') return $error; |
|
1154 | - else return self::check_version(true); |
|
1230 | + if ($error != '') { |
|
1231 | + return $error; |
|
1232 | + } else { |
|
1233 | + return self::check_version(true); |
|
1234 | + } |
|
1155 | 1235 | } elseif ($result['value'] == '7') { |
1156 | 1236 | $error = self::update_from_7(); |
1157 | - if ($error != '') return $error; |
|
1158 | - else return self::check_version(true); |
|
1237 | + if ($error != '') { |
|
1238 | + return $error; |
|
1239 | + } else { |
|
1240 | + return self::check_version(true); |
|
1241 | + } |
|
1159 | 1242 | } elseif ($result['value'] == '8') { |
1160 | 1243 | $error = self::update_from_8(); |
1161 | - if ($error != '') return $error; |
|
1162 | - else return self::check_version(true); |
|
1244 | + if ($error != '') { |
|
1245 | + return $error; |
|
1246 | + } else { |
|
1247 | + return self::check_version(true); |
|
1248 | + } |
|
1163 | 1249 | } elseif ($result['value'] == '9') { |
1164 | 1250 | $error = self::update_from_9(); |
1165 | - if ($error != '') return $error; |
|
1166 | - else return self::check_version(true); |
|
1251 | + if ($error != '') { |
|
1252 | + return $error; |
|
1253 | + } else { |
|
1254 | + return self::check_version(true); |
|
1255 | + } |
|
1167 | 1256 | } elseif ($result['value'] == '10') { |
1168 | 1257 | $error = self::update_from_10(); |
1169 | - if ($error != '') return $error; |
|
1170 | - else return self::check_version(true); |
|
1258 | + if ($error != '') { |
|
1259 | + return $error; |
|
1260 | + } else { |
|
1261 | + return self::check_version(true); |
|
1262 | + } |
|
1171 | 1263 | } elseif ($result['value'] == '11') { |
1172 | 1264 | $error = self::update_from_11(); |
1173 | - if ($error != '') return $error; |
|
1174 | - else return self::check_version(true); |
|
1265 | + if ($error != '') { |
|
1266 | + return $error; |
|
1267 | + } else { |
|
1268 | + return self::check_version(true); |
|
1269 | + } |
|
1175 | 1270 | } elseif ($result['value'] == '12') { |
1176 | 1271 | $error = self::update_from_12(); |
1177 | - if ($error != '') return $error; |
|
1178 | - else return self::check_version(true); |
|
1272 | + if ($error != '') { |
|
1273 | + return $error; |
|
1274 | + } else { |
|
1275 | + return self::check_version(true); |
|
1276 | + } |
|
1179 | 1277 | } elseif ($result['value'] == '13') { |
1180 | 1278 | $error = self::update_from_13(); |
1181 | - if ($error != '') return $error; |
|
1182 | - else return self::check_version(true); |
|
1279 | + if ($error != '') { |
|
1280 | + return $error; |
|
1281 | + } else { |
|
1282 | + return self::check_version(true); |
|
1283 | + } |
|
1183 | 1284 | } elseif ($result['value'] == '14') { |
1184 | 1285 | $error = self::update_from_14(); |
1185 | - if ($error != '') return $error; |
|
1186 | - else return self::check_version(true); |
|
1286 | + if ($error != '') { |
|
1287 | + return $error; |
|
1288 | + } else { |
|
1289 | + return self::check_version(true); |
|
1290 | + } |
|
1187 | 1291 | } elseif ($result['value'] == '15') { |
1188 | 1292 | $error = self::update_from_15(); |
1189 | - if ($error != '') return $error; |
|
1190 | - else return self::check_version(true); |
|
1293 | + if ($error != '') { |
|
1294 | + return $error; |
|
1295 | + } else { |
|
1296 | + return self::check_version(true); |
|
1297 | + } |
|
1191 | 1298 | } elseif ($result['value'] == '16') { |
1192 | 1299 | $error = self::update_from_16(); |
1193 | - if ($error != '') return $error; |
|
1194 | - else return self::check_version(true); |
|
1300 | + if ($error != '') { |
|
1301 | + return $error; |
|
1302 | + } else { |
|
1303 | + return self::check_version(true); |
|
1304 | + } |
|
1195 | 1305 | } elseif ($result['value'] == '17') { |
1196 | 1306 | $error = self::update_from_17(); |
1197 | - if ($error != '') return $error; |
|
1198 | - else return self::check_version(true); |
|
1307 | + if ($error != '') { |
|
1308 | + return $error; |
|
1309 | + } else { |
|
1310 | + return self::check_version(true); |
|
1311 | + } |
|
1199 | 1312 | } elseif ($result['value'] == '18') { |
1200 | 1313 | $error = self::update_from_18(); |
1201 | - if ($error != '') return $error; |
|
1202 | - else return self::check_version(true); |
|
1314 | + if ($error != '') { |
|
1315 | + return $error; |
|
1316 | + } else { |
|
1317 | + return self::check_version(true); |
|
1318 | + } |
|
1203 | 1319 | } elseif ($result['value'] == '19') { |
1204 | 1320 | $error = self::update_from_19(); |
1205 | - if ($error != '') return $error; |
|
1206 | - else return self::check_version(true); |
|
1321 | + if ($error != '') { |
|
1322 | + return $error; |
|
1323 | + } else { |
|
1324 | + return self::check_version(true); |
|
1325 | + } |
|
1207 | 1326 | } elseif ($result['value'] == '20') { |
1208 | 1327 | $error = self::update_from_20(); |
1209 | - if ($error != '') return $error; |
|
1210 | - else return self::check_version(true); |
|
1328 | + if ($error != '') { |
|
1329 | + return $error; |
|
1330 | + } else { |
|
1331 | + return self::check_version(true); |
|
1332 | + } |
|
1211 | 1333 | } elseif ($result['value'] == '21') { |
1212 | 1334 | $error = self::update_from_21(); |
1213 | - if ($error != '') return $error; |
|
1214 | - else return self::check_version(true); |
|
1335 | + if ($error != '') { |
|
1336 | + return $error; |
|
1337 | + } else { |
|
1338 | + return self::check_version(true); |
|
1339 | + } |
|
1215 | 1340 | } elseif ($result['value'] == '22') { |
1216 | 1341 | $error = self::update_from_22(); |
1217 | - if ($error != '') return $error; |
|
1218 | - else return self::check_version(true); |
|
1342 | + if ($error != '') { |
|
1343 | + return $error; |
|
1344 | + } else { |
|
1345 | + return self::check_version(true); |
|
1346 | + } |
|
1219 | 1347 | } elseif ($result['value'] == '23') { |
1220 | 1348 | $error = self::update_from_23(); |
1221 | - if ($error != '') return $error; |
|
1222 | - else return self::check_version(true); |
|
1349 | + if ($error != '') { |
|
1350 | + return $error; |
|
1351 | + } else { |
|
1352 | + return self::check_version(true); |
|
1353 | + } |
|
1223 | 1354 | } elseif ($result['value'] == '24') { |
1224 | 1355 | $error = self::update_from_24(); |
1225 | - if ($error != '') return $error; |
|
1226 | - else return self::check_version(true); |
|
1356 | + if ($error != '') { |
|
1357 | + return $error; |
|
1358 | + } else { |
|
1359 | + return self::check_version(true); |
|
1360 | + } |
|
1227 | 1361 | } elseif ($result['value'] == '25') { |
1228 | 1362 | $error = self::update_from_25(); |
1229 | - if ($error != '') return $error; |
|
1230 | - else return self::check_version(true); |
|
1231 | - } else return ''; |
|
1363 | + if ($error != '') { |
|
1364 | + return $error; |
|
1365 | + } else { |
|
1366 | + return self::check_version(true); |
|
1367 | + } |
|
1368 | + } else { |
|
1369 | + return ''; |
|
1370 | + } |
|
1371 | + } else { |
|
1372 | + return $result['value']; |
|
1232 | 1373 | } |
1233 | - else return $result['value']; |
|
1234 | 1374 | } |
1235 | 1375 | |
1236 | - } else return $version; |
|
1376 | + } else { |
|
1377 | + return $version; |
|
1378 | + } |
|
1237 | 1379 | } |
1238 | 1380 | |
1239 | 1381 | } |