This commit is contained in:
Minh VU
2024-12-03 14:09:34 +01:00
2 changed files with 31 additions and 10 deletions

View File

@@ -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 '';"""

28
main.py
View File

@@ -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()