From bfe9189378853f48a0757852af73ffa1b95557b1 Mon Sep 17 00:00:00 2001 From: Minh VU Date: Tue, 3 Dec 2024 14:34:09 +0100 Subject: [PATCH] ok ok --- MonetDB.py | 8 +++++++- main.py | 25 ++++++------------------- 2 files changed, 13 insertions(+), 20 deletions(-) diff --git a/MonetDB.py b/MonetDB.py index 864f46d..62456b8 100644 --- a/MonetDB.py +++ b/MonetDB.py @@ -20,10 +20,16 @@ def connect_monetdb(): return connection, cursor def create_table_monetdb(cursor): - return 0 + cursor.execute(createAirports) + cursor.execute(createAirports) + cursor.execute(createFlights) def create_data_monetdb(cursor): cursor.execute(peuplementAirlines) cursor.execute(peuplementFlights) cursor.execute(peuplementAirports) + +def disconnect_monetdb(connection,cursor): + cursor.close() + connection.close() diff --git a/main.py b/main.py index 005555d..7e0b4ae 100644 --- a/main.py +++ b/main.py @@ -1,36 +1,23 @@ -import time - -from PostgreSQL import create_tables_postgres,create_data_postgres,requete_lecture_postgres - +from MonetDB import * +from PostgreSQL import * +#Monet DB 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' -""" - +#Postgre SQL +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__': + #PostgreSQL #create_tables_postgres() #create_data_postgres() str="""SELECT * FROM public.flights WHERE airline = 'AA'"""