diff --git a/main.py b/main.py index 5e82fca..8671baa 100644 --- a/main.py +++ b/main.py @@ -13,10 +13,10 @@ requeteDeleteMonetDB = """DELETE FROM flights WHERE "DAY" > 10;""" requeteInsertMonetDB = """INSERT INTO flights SELECT * FROM flights10;""" #Postgre SQL -requeteSelect1PostgreSQL = """SELECT * FROM public.flights WHERE airline = 'AA'""" +requeteSelect1PostgreSQL = """SELECT * FROM public.flights WHERE "AIRLINE" = 'AA'""" requeteSelect2PostgreSQL = """SELECT * FROM public.flights""" -requeteSelect3PostgreSQL = """SELECT * FROM public.flight WHERE "DAY" > 10""" -requeteSelect4PostgreSQL = """SELECT * FROM public.flight WHERE "DAY" > 30""" +requeteSelect3PostgreSQL = """SELECT * FROM public.flights WHERE "DAY" > 10""" +requeteSelect4PostgreSQL = """SELECT * FROM public.flights WHERE "DAY" > 30""" requeteCreateTablePostgreSQL = """CREATE TABLE flights10 AS SELECT * FROM FLIGHTS WHERE "DAY" > 10""" requeteDeletePostgreSQL = """DELETE FROM flights WHERE "DAY" > 10""" @@ -54,14 +54,33 @@ def runMonetDB(): execMonetDB(requeteSelect3MonetDB) execMonetDB(requeteSelect4MonetDB) +def initPostgreSQL(): + reset_database_postgres() + start_time = time.time() + create_tables_postgres() + end_time = time.time() + print("[PostgreSQL] create table: time = ", (end_time - start_time), "s") + + start_time = time.time() + create_data_postgres() + end_time = time.time() + print("[PostgreSQL] load data : time = ", (end_time - start_time), "s") + +def execPostgreSQL(str): + start_time = time.time() + requete_postgres(str) + end_time = time.time() + print("[PostgreSQL] requete :", str, "\n time = ", (end_time - start_time), "s") def runPostgreSQL(): - reset_database_postgres() - create_tables_postgres() - create_data_postgres() - #requete_postgres(str) + execPostgreSQL(requeteSelect1PostgreSQL) + execPostgreSQL(requeteSelect2PostgreSQL) + execPostgreSQL(requeteSelect3PostgreSQL) + execPostgreSQL(requeteSelect4PostgreSQL) if __name__ == '__main__': - initMonetDB() - runMonetDB() - #runPostgreSQL() + #initMonetDB() + #runMonetDB() + #initPostgreSQL() + runPostgreSQL() +