diff --git a/MonetDB.py b/MonetDB.py index 0a8f680..5e6c3e7 100644 --- a/MonetDB.py +++ b/MonetDB.py @@ -40,15 +40,8 @@ def create_data_monetdb(cursor): -requeteSelect1 = """SELECT * FROM flights WHERE "AIRLINE" = 'AA';""" -requeteSelect2 = """SELECT * FROM flights;""" - -requeteCreateTable = """SELECT * FROM public.flights -WHERE airline = 'AA' -""" - -requeteDelete = """DELETE FROM flights WHERE "DAY" > 10""" - -requeteInsert = """INSERT INTO flights SELECT * FROM flights10""" +peuplementFlights = """COPY INTO flights +FROM 'C:\\Users\\Public\\2015_Flight_Delay_and_cancellations\\flights.csv' +USING DELIMITERS ',', E'\n', '"' NULL AS '';""" diff --git a/main.py b/main.py index eaf11da..005555d 100644 --- a/main.py +++ b/main.py @@ -2,6 +2,34 @@ import time from PostgreSQL import create_tables_postgres,create_data_postgres,requete_lecture_postgres + +requeteSelect1MonetDB = """SELECT * FROM flights WHERE "AIRLINE" = 'AA';""" + +requeteSelect2MonetDB = """SELECT * FROM flights;""" + +requeteCreateTableMonetDB = """CREATE TABLE flights10 AS SELECT * FROM FLIGHTS WHERE "DAY" > 10;""" + +requeteDeleteMonetDB = """DELETE FROM flights WHERE "DAY" > 10;""" + +requeteInsertMonetDB = """INSERT INTO flights SELECT * FROM flights10;""" + + + + + +requeteSelect1PostgreSQL = """SELECT * FROM public.flights +WHERE airline = 'AA' +""" + +requeteSelect2PostgreSQL = """SELECT * FROM public.flights""" + +requeteCreateTablePostgreSQL = """CREATE TABLE flights10 AS SELECT * FROM FLIGHTS WHERE "DAY" > 10""" + +requeteDeletePostgreSQL = """DELETE FROM flights WHERE "DAY" > 10""" + +requeteInsertPostgreSQL = """INSERT INTO flights SELECT * FROM flights10""" + + if __name__ == '__main__': #create_tables_postgres() #create_data_postgres()