diff --git a/MonetDB.py b/MonetDB.py index 62456b8..c835912 100644 --- a/MonetDB.py +++ b/MonetDB.py @@ -1,5 +1,8 @@ import pymonetdb +import time +#Creation_table +createAirline = """CREATE TABLE airlines("IATA_CODE" VARCHAR(2) NOT NULL PRIMARY KEY UNIQUE, "AIRLINE" VARCHAR(99) NOT NULL);""" createAirports = """CREATE TABLE airports("IATA_CODE" VARCHAR(3) NOT NULL PRIMARY KEY UNIQUE, "AIRPORT" VARCHAR(100), "CITY" VARCHAR(40), "STATE" VARCHAR(2), "COUNTRY" VARCHAR(40), "LATITUDE" REAL, "LONGITUDE" REAL);""" createFlights = """CREATE TABLE flights("YEAR" INT, "MONTH" INT, "DAY" INT, "DAY_OF_WEEK" INT, "AIRLINE" VARCHAR(2), "FLIGHT_NUMBER" INT, "TAIL_NUMBER" VARCHAR(6), "ORIGIN_AIRPORT" VARCHAR(5), "DESTINATION_AIRPORT" VARCHAR(5), "SCHEDULED_DEPARTURE" INT, "DEPARTURE_TIME" INT, @@ -7,7 +10,7 @@ createFlights = """CREATE TABLE flights("YEAR" INT, "MONTH" INT, "DAY" INT, "DAY "WHEELS_ON" INT, "TAXI_IN" INT, "SCHEDULED_ARRIVAL" INT, "ARRIVAL_TIME" INT, "ARRIVAL_DELAY" INT, "DIVERTED" INT, "CANCELLED" INT, "CANCELLATION_REASON" VARCHAR(1), "AIR_SYSTEM_DELAY" INT, "SECURITY_DELAY" INT, "AIRLINE_DELAY" INT, "LATE_AIRCRAFT_DELAY" INT, "WEATHER_DELAY" INT);""" - +#Inserer_data peuplementAirlines = """COPY INTO airlines FROM 'C:\\Users\\Public\\2015_Flight_Delay_and_cancellations\\airlines.csv' USING DELIMITERS ',', E'\n', '\"';""" peuplementAirports = """COPY INTO airports FROM 'C:\\Users\\Public\\2015_Flight_Delay_and_cancellations\\airports.csv' USING DELIMITERS ',', E'\n', '"' NULL AS '';""" peuplementFlights = """COPY INTO flights FROM 'C:\\Users\\Public\\2015_Flight_Delay_and_cancellations\\flights.csv' USING DELIMITERS ',', E'\n', '"' NULL AS '';""" @@ -20,16 +23,18 @@ def connect_monetdb(): return connection, cursor def create_table_monetdb(cursor): - cursor.execute(createAirports) + cursor.execute(createAirline) cursor.execute(createAirports) cursor.execute(createFlights) - def create_data_monetdb(cursor): cursor.execute(peuplementAirlines) cursor.execute(peuplementFlights) cursor.execute(peuplementAirports) +def requete_monetdb(cursor,str): + cursor.execute(str) + def disconnect_monetdb(connection,cursor): cursor.close() connection.close() diff --git a/PostgreSQL.py b/PostgreSQL.py index 6c2ad15..eba39cf 100644 --- a/PostgreSQL.py +++ b/PostgreSQL.py @@ -92,7 +92,7 @@ def create_data_postgres(): print(error) -def requete_lecture_postgres(str): +def requete_postgres(str): try: with connect_postgres() as conn: with conn.cursor() as cursor: diff --git a/main.py b/main.py index 7e0b4ae..c3bb8c2 100644 --- a/main.py +++ b/main.py @@ -20,5 +20,11 @@ if __name__ == '__main__': #PostgreSQL #create_tables_postgres() #create_data_postgres() - str="""SELECT * FROM public.flights WHERE airline = 'AA'""" - requete_lecture_postgres(str) \ No newline at end of file + requete_postgres(str) + + #MonetDB + conn, cursor =connect_monetdb() + create_table_monetdb(cursor) + create_data_monetdb(cursor) + requete_monetdb(cursor, str) + disconnect_monetdb(conn, cursor)