fanwuyang/SENG202
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Implemented the parser for basic Flight files(The one given to us in the important documents folder on learn)

Browse Source
This commit is contained in:
Liam Beckett
2016-09-14 10:22:01 +12:00
parent b6624f20a8
commit 13697ac673
1 changed files with 52 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/seng202/group9/Controller/Dataset.java
+53 -33
View File
@@ -637,13 +637,13 @@ public class Dataset {
* @throws DataException * @throws DataException
*/ */
/*
public String importFlight(String filePath) throws DataException { public String importFlight(String filePath) throws DataException {
FlightPathParser parser = new FlightPathParser(filePath); FlightPathParser parser = new FlightPathParser(filePath);
//remember this still has to append the duplicate message to it. //remember this still has to append the duplicate message to it.
//routes are identified in the diction by routeAirline + routeSourceAirport + routeArrvAirport + routeCodeShare + routeStops + routeEquip; //routes are identified in the diction by routeAirline + routeSourceAirport + routeArrvAirport + routeCodeShare + routeStops + routeEquip;
String message = parser.parse(); String message = parser.parse();
ArrayList<FlightPoint> flightsToImport = parser.getResult(); ArrayList<FlightPoint> flightPointsToImport = parser.getResult();
//check for dup //check for dup
int numOfDuplicates = 0; int numOfDuplicates = 0;
int nextID = -1; int nextID = -1;
@@ -654,49 +654,69 @@ public class Dataset {
Class.forName("org.sqlite.JDBC"); Class.forName("org.sqlite.JDBC");
c = DriverManager.getConnection("jdbc:sqlite:res/userdb.db"); c = DriverManager.getConnection("jdbc:sqlite:res/userdb.db");
stmt = c.createStatement(); stmt = c.createStatement();
String queryName = this.name.replace("'", "''").replace("\"", "\"\""); String queryName = this.name.replace("'", "''");
String IDQuery = "SELECT * FROM `sqlite_sequence` WHERE `name` = '"+queryName+"_Routes' LIMIT 1;"; String IDQuery = "SELECT * FROM `sqlite_sequence` WHERE `name` = '"+queryName+"_Flight_Points' LIMIT 1;";
ResultSet IDResult = stmt.executeQuery(IDQuery); ResultSet IDResult = stmt.executeQuery(IDQuery);
while(IDResult.next()){ while(IDResult.next()){
nextID = Integer.parseInt(IDResult.getString("seq")) + 1;//for some reason sqlite3 stores incremental values as a string... nextID = Integer.parseInt(IDResult.getString("seq")) + 1;//for some reason sqlite3 stores incremental values as a string...
} }
stmt.close(); stmt.close();
stmt = c.createStatement(); stmt = c.createStatement();
String insertFlightQuery = "INSERT INTO `" + this.name + "_Routes` (`Airline`, `Source_Airport`, `Destination_Airport`," + //ADDED
" `Codeshare`, `Stops`, `Equipment`) VALUES "; String firstPt = flightPointsToImport.get(0).getName();
int numOfRoutes = 0; String lastPt = flightPointsToImport.get(flightPointsToImport.size() - 1).getName();
for (int i = 0; i < flightsToImport.size(); i ++){ FlightPath flightPathToAdd = new FlightPath(firstPt, lastPt);
String routeIdentifier = flightsToImport.get(i).getType() + flightsToImport.get(i).getID() +
flightsToImport.get(i).getAltitude() + flightsToImport.get(i).getLatitude() + String insertFlightPathQuery = "INSERT INTO `" + this.name + "_Flight_Path` (`Source_Airport`, `Destination_Airport`)" +
flightsToImport.get(i).getLongitude(); "VALUES ( \"" + firstPt + "\",\"" + lastPt + "\") ";
//if (routeDictionary.containsKey(routeIdentifier)){ stmt.execute(insertFlightPathQuery);
// numOfDuplicates ++; stmt.close();
//}else{ stmt = c.createStatement();
//route variables int flightPathId = 0;
String flightType = flightsToImport.get(i).getType().replace("\"", "\"\""); String getLastestIndex = "SELECT * FROM `sqlite_sequence` WHERE `name` = \"" + this.name.replace("\"", "\"\"") +
String flightID = flightsToImport.get(i).getID().replace("\"", "\"\""); "_Flight_Path\" LIMIT 1;";
double flightAltitude = flightsToImport.get(i).getAltitude(); ResultSet lastestIdResult = stmt.executeQuery(getLastestIndex);
double flightLatitude = flightsToImport.get(i).getLatitude(); while(lastestIdResult.next()){
double flightLongitude = flightsToImport.get(i).getLongitude(); flightPathId = Integer.parseInt(lastestIdResult.getString("seq"));//for some reason sqlite3 stores incremental values as a string...
//insert import into database
if (numOfRoutes > 0){
insertFlightQuery += ",";
} }
insertFlightQuery += "(\""+flightType+"\", \"" + flightID + "\", \"" + flightAltitude + "\", " + stmt.close();
"\"" + flightLatitude + "\", " + flightLongitude + "\")"; lastestIdResult.close();
flightsToImport.get(i).setID(nextID); stmt = c.createStatement();
flightPathToAdd.setID(flightPathId);
//ADDED
String insertFlightPointQuery = "INSERT INTO `" + this.name + "_Flight_Points` (`Index_ID`, `Name`, `Type`," +
" `Altitude`, `Longitude`, `Latitude`) VALUES ";
int numOfFlights = 0;
for (int i = 0; i < flightPointsToImport.size(); i ++){
String flightPointIdentifier = flightPointsToImport.get(i).getType() + flightPointsToImport.get(i).getName() +
flightPointsToImport.get(i).getAltitude() + flightPointsToImport.get(i).getLatitude() +
flightPointsToImport.get(i).getLongitude();
String flightType = flightPointsToImport.get(i).getType().replace("\"", "\"\"");
String flightName = flightPointsToImport.get(i).getName().replace("\"", "\"\"");
double flightAltitude = flightPointsToImport.get(i).getAltitude();
double flightLatitude = flightPointsToImport.get(i).getLatitude();
double flightLongitude = flightPointsToImport.get(i).getLongitude();
//insert import into database
if (numOfFlights > 0){
insertFlightPointQuery += ",";
}
insertFlightPointQuery += "(" + flightPathId +", \""+ flightName +"\", \"" + flightType + "\", "+ flightAltitude + ", " +
"" + flightLatitude + ", " + flightLongitude + ")";
flightPointsToImport.get(i).setID(nextID);
//add data to dataset array. //add data to dataset array.
//this is placed after incase the database messes up //this is placed after incase the database messes up
flights.add(flightsToImport.get(i)); flightPathToAdd.addFlightPoint(flightPointsToImport.get(i));
routeDictionary.put(routeIdentifier, flightsToImport.get(i)); //routeDictionary.put(routeIdentifier, flightsToImport.get(i));
nextID++; nextID++;
numOfRoutes++; numOfFlights++;
//} //}
} }
if (numOfRoutes > 0){ if (numOfFlights > 0){
stmt.execute(insertRouteQuery); stmt.execute(insertFlightPointQuery);
stmt.close(); stmt.close();
} }
flightPaths.add(flightPathToAdd);
} catch ( Exception e ) { } catch ( Exception e ) {
System.err.println( e.getClass().getName() + ": " + e.getMessage() ); System.err.println( e.getClass().getName() + ": " + e.getMessage() );
System.exit(0); System.exit(0);
@@ -705,10 +725,10 @@ public class Dataset {
createDataLinks(); createDataLinks();
return message; return message;
} }
/*
*/
/** /**
* This function updates the connections between airports citys countries etc. * This function updates the connections between airports citys countries etc.
*/ */