|
@@ 106-142 (lines=37) @@
|
| 103 |
|
} |
| 104 |
|
return ''; |
| 105 |
|
} |
| 106 |
|
public static function retrieve_route_oneworld($database_file) { |
| 107 |
|
global $globalDebug, $globalTransaction; |
| 108 |
|
//$query = 'TRUNCATE TABLE routes'; |
| 109 |
|
if ($globalDebug) echo " - Delete previous routes from DB -"; |
| 110 |
|
$query = "DELETE FROM routes WHERE Source = '' OR Source = :source"; |
| 111 |
|
$Connection = new Connection(); |
| 112 |
|
try { |
| 113 |
|
//$Connection = new Connection(); |
| 114 |
|
$sth = $Connection->db->prepare($query); |
| 115 |
|
$sth->execute(array(':source' => 'oneworld')); |
| 116 |
|
} catch(PDOException $e) { |
| 117 |
|
return "error : ".$e->getMessage(); |
| 118 |
|
} |
| 119 |
|
|
| 120 |
|
if ($globalDebug) echo " - Add routes to DB -"; |
| 121 |
|
|
| 122 |
|
if ($fh = fopen($database_file,"r")) { |
| 123 |
|
$query_dest = 'INSERT INTO routes (CallSign,Operator_ICAO,FromAirport_ICAO,FromAirport_Time,ToAirport_ICAO,ToAirport_Time,RouteStop,Source) VALUES (:CallSign, :Operator_ICAO, :FromAirport_ICAO,:FromAirport_Time, :ToAirport_ICAO, :ToAirport_Time,:routestop, :source)'; |
| 124 |
|
$Connection = new Connection(); |
| 125 |
|
$sth_dest = $Connection->db->prepare($query_dest); |
| 126 |
|
if ($globalTransaction) $Connection->db->beginTransaction(); |
| 127 |
|
while (!feof($fh)) { |
| 128 |
|
$line = fgetcsv($fh,9999,','); |
| 129 |
|
if ($line[0] != '') { |
| 130 |
|
try { |
| 131 |
|
$query_dest_values = array(':CallSign' => str_replace('*','',$line[7]),':Operator_ICAO' => '',':FromAirport_ICAO' => $line[0],':FromAirport_Time' => $line[5],':ToAirport_ICAO' => $line[1],':ToAirport_Time' => $line[6],':routestop' => '',':source' => 'oneworld'); |
| 132 |
|
$sth_dest->execute($query_dest_values); |
| 133 |
|
} catch(PDOException $e) { |
| 134 |
|
if ($globalTransaction) $Connection->db->rollBack(); |
| 135 |
|
return "error : ".$e->getMessage(); |
| 136 |
|
} |
| 137 |
|
} |
| 138 |
|
} |
| 139 |
|
if ($globalTransaction) $Connection->db->commit(); |
| 140 |
|
} |
| 141 |
|
return ''; |
| 142 |
|
} |
| 143 |
|
|
| 144 |
|
public static function retrieve_route_skyteam($database_file) { |
| 145 |
|
global $globalDebug, $globalTransaction; |
|
@@ 144-180 (lines=37) @@
|
| 141 |
|
return ''; |
| 142 |
|
} |
| 143 |
|
|
| 144 |
|
public static function retrieve_route_skyteam($database_file) { |
| 145 |
|
global $globalDebug, $globalTransaction; |
| 146 |
|
//$query = 'TRUNCATE TABLE routes'; |
| 147 |
|
if ($globalDebug) echo " - Delete previous routes from DB -"; |
| 148 |
|
$query = "DELETE FROM routes WHERE Source = '' OR Source = :source"; |
| 149 |
|
$Connection = new Connection(); |
| 150 |
|
try { |
| 151 |
|
//$Connection = new Connection(); |
| 152 |
|
$sth = $Connection->db->prepare($query); |
| 153 |
|
$sth->execute(array(':source' => 'skyteam')); |
| 154 |
|
} catch(PDOException $e) { |
| 155 |
|
return "error : ".$e->getMessage(); |
| 156 |
|
} |
| 157 |
|
|
| 158 |
|
if ($globalDebug) echo " - Add routes to DB -"; |
| 159 |
|
|
| 160 |
|
if ($fh = fopen($database_file,"r")) { |
| 161 |
|
$query_dest = 'INSERT INTO routes (CallSign,Operator_ICAO,FromAirport_ICAO,FromAirport_Time,ToAirport_ICAO,ToAirport_Time,RouteStop,Source) VALUES (:CallSign, :Operator_ICAO, :FromAirport_ICAO,:FromAirport_Time, :ToAirport_ICAO, :ToAirport_Time,:routestop, :source)'; |
| 162 |
|
$Connection = new Connection(); |
| 163 |
|
$sth_dest = $Connection->db->prepare($query_dest); |
| 164 |
|
try { |
| 165 |
|
if ($globalTransaction) $Connection->db->beginTransaction(); |
| 166 |
|
while (!feof($fh)) { |
| 167 |
|
$line = fgetcsv($fh,9999,','); |
| 168 |
|
if ($line[0] != '') { |
| 169 |
|
$query_dest_values = array(':CallSign' => str_replace('*','',$line[6]),':Operator_ICAO' => '',':FromAirport_ICAO' => $line[0],':FromAirport_Time' => $line[4],':ToAirport_ICAO' => $line[1],':ToAirport_Time' => $line[5],':routestop' => '',':source' => 'skyteam'); |
| 170 |
|
$sth_dest->execute($query_dest_values); |
| 171 |
|
} |
| 172 |
|
} |
| 173 |
|
if ($globalTransaction) $Connection->db->commit(); |
| 174 |
|
} catch(PDOException $e) { |
| 175 |
|
if ($globalTransaction) $Connection->db->rollBack(); |
| 176 |
|
return "error : ".$e->getMessage(); |
| 177 |
|
} |
| 178 |
|
} |
| 179 |
|
return ''; |
| 180 |
|
} |
| 181 |
|
public static function retrieve_modes_sqlite_to_dest($database_file) { |
| 182 |
|
global $globalTransaction; |
| 183 |
|
//$query = 'TRUNCATE TABLE aircraft_modes'; |
Ysurac /
FlightAirMap
