This commit is contained in:
Rochas
2024-12-22 19:17:00 +01:00
parent cfc4af1014
commit 9f796a7741
16 changed files with 85 additions and 1199 deletions

100
main.py
View File

@@ -13,6 +13,8 @@ from datetime import datetime
requeteSelect1MonetDB = """SELECT * FROM flights WHERE "AIRLINE" = 'AA';"""
requeteSelect2MonetDB = """SELECT * FROM flights;"""
requeteSELECT3MonetDB = """SELECT * FROM flights WHERE "YEAR" = 2015 AND "MONTH" = 12 AND "DAY" = 32 AND "DAY_OF_WEEK" = 4 AND "AIRLINE" = 'B6' AND "FLIGHT_NUMBER" = 839;"""
requeteSelect05MonetDB = """SELECT * FROM flights WHERE "DAY" > 5;"""
requeteSelect10MonetDB = """SELECT * FROM flights WHERE "DAY" > 10;"""
requeteSelect15MonetDB = """SELECT * FROM flights WHERE "DAY" > 15;"""
@@ -60,6 +62,8 @@ requeteDropFlight2MonetDB = """DROP TABLE flights2;"""
requeteSelect1PostgreSQL = """SELECT * FROM public.flights WHERE "AIRLINE" = 'AA'"""
requeteSelect2PostgreSQL = """SELECT * FROM public.flights"""
requeteSELECT3PostgreSQL = """SELECT * FROM flights WHERE "YEAR" = 2015 AND "MONTH" = 12 AND "DAY" = 32 AND "DAY_OF_WEEK" = 4 AND "AIRLINE" = 'B6' AND "FLIGHT_NUMBER" = 839"""
requeteSelect05PostgreSQL = """SELECT * FROM public.flights WHERE "DAY" > 5"""
requeteSelect10PostgreSQL = """SELECT * FROM public.flights WHERE "DAY" > 10"""
requeteSelect15PostgreSQL = """SELECT * FROM public.flights WHERE "DAY" > 15"""
@@ -129,29 +133,31 @@ def execMonetDB(str):
return requete_monetdb(str)
def readMonetDB():
execForMonetDB(5,[requeteSelect1MonetDB])
execForMonetDB(5,[requeteSelect2MonetDB])
#execForMonetDB(5,[requeteSelect1MonetDB])
#execForMonetDB(5,[requeteSelect2MonetDB])
execForMonetDB(5,[requeteSelect05MonetDB])
execForMonetDB(5,[requeteSelect10MonetDB])
execForMonetDB(5,[requeteSelect15MonetDB])
execForMonetDB(5,[requeteSelect20MonetDB])
execForMonetDB(5,[requeteSelect25MonetDB])
execForMonetDB(5,[requeteSelect30MonetDB])
execForMonetDB(5,[requeteSELECT3MonetDB]) #ONE RESULT
execForMonetDB(5,[requeteSelect05_2MonetDB])
execForMonetDB(5,[requeteSelect10_2MonetDB])
execForMonetDB(5,[requeteSelect15_2MonetDB])
execForMonetDB(5,[requeteSelect20_2MonetDB])
execForMonetDB(5,[requeteSelect25_2MonetDB])
execForMonetDB(5,[requeteSelect30_2MonetDB])
execForMonetDB(10,[requeteSelect05_3MonetDB])
execForMonetDB(10,[requeteSelect10_3MonetDB])
execForMonetDB(10,[requeteSelect15_3MonetDB])
execForMonetDB(10,[requeteSelect20_3MonetDB])
execForMonetDB(10,[requeteSelect25_3MonetDB])
execForMonetDB(10,[requeteSelect30_3MonetDB])
#execForMonetDB(5,[requeteSelect05MonetDB])
#execForMonetDB(5,[requeteSelect10MonetDB])
#execForMonetDB(5,[requeteSelect15MonetDB])
#execForMonetDB(5,[requeteSelect20MonetDB])
#execForMonetDB(5,[requeteSelect25MonetDB])
#execForMonetDB(5,[requeteSelect30MonetDB])
#
#execForMonetDB(5,[requeteSelect05_2MonetDB])
#execForMonetDB(5,[requeteSelect10_2MonetDB])
#execForMonetDB(5,[requeteSelect15_2MonetDB])
#execForMonetDB(5,[requeteSelect20_2MonetDB])
#execForMonetDB(5,[requeteSelect25_2MonetDB])
#execForMonetDB(5,[requeteSelect30_2MonetDB])
#
#execForMonetDB(10,[requeteSelect05_3MonetDB])
#execForMonetDB(10,[requeteSelect10_3MonetDB])
#execForMonetDB(10,[requeteSelect15_3MonetDB])
#execForMonetDB(10,[requeteSelect20_3MonetDB])
#execForMonetDB(10,[requeteSelect25_3MonetDB])
#execForMonetDB(10,[requeteSelect30_3MonetDB])
def readAndWriteMonetDB():
execForMonetDB(4,[requeteCreateTable5MonetDB,requeteDelete5MonetDB,requeteInsertMonetDB,requeteDropFlight2MonetDB])
@@ -194,9 +200,9 @@ def runMonetDB():
readMonetDB()
readAndWriteMonetDB()
#readAndWriteMonetDB()
writeMonetDB()
#writeMonetDB()
@@ -248,29 +254,31 @@ def execPostgreSQL(str):
return requete_postgres(str)
def readPostgreSQL():
execForPostgreSQL(2,[requeteSelect1PostgreSQL])
execForPostgreSQL(2,[requeteSelect2PostgreSQL])
#execForPostgreSQL(2,[requeteSelect1PostgreSQL])
#execForPostgreSQL(2,[requeteSelect2PostgreSQL])
execForPostgreSQL(2,[requeteSelect05PostgreSQL])
execForPostgreSQL(2,[requeteSelect10PostgreSQL])
execForPostgreSQL(2,[requeteSelect15PostgreSQL])
execForPostgreSQL(2,[requeteSelect20PostgreSQL])
execForPostgreSQL(2,[requeteSelect25PostgreSQL])
execForPostgreSQL(3,[requeteSelect30PostgreSQL])
execForPostgreSQL(5,[requeteSELECT3PostgreSQL]) #ONE RESULT
execForPostgreSQL(2,[requeteSelect05_2PostgreSQL])
execForPostgreSQL(2,[requeteSelect10_2PostgreSQL])
execForPostgreSQL(2,[requeteSelect15_2PostgreSQL])
execForPostgreSQL(2,[requeteSelect20_2PostgreSQL])
execForPostgreSQL(2,[requeteSelect25_2PostgreSQL])
execForPostgreSQL(2,[requeteSelect30_2PostgreSQL])
execForPostgreSQL(5,[requeteSelect05_3PostgreSQL])
execForPostgreSQL(5,[requeteSelect10_3PostgreSQL])
execForPostgreSQL(5,[requeteSelect15_3PostgreSQL])
execForPostgreSQL(5,[requeteSelect20_3PostgreSQL])
execForPostgreSQL(5,[requeteSelect25_3PostgreSQL])
execForPostgreSQL(5,[requeteSelect30_3PostgreSQL])
#execForPostgreSQL(2,[requeteSelect05PostgreSQL])
#execForPostgreSQL(2,[requeteSelect10PostgreSQL])
#execForPostgreSQL(2,[requeteSelect15PostgreSQL])
#execForPostgreSQL(2,[requeteSelect20PostgreSQL])
#execForPostgreSQL(2,[requeteSelect25PostgreSQL])
#execForPostgreSQL(3,[requeteSelect30PostgreSQL])
#
#execForPostgreSQL(2,[requeteSelect05_2PostgreSQL])
#execForPostgreSQL(2,[requeteSelect10_2PostgreSQL])
#execForPostgreSQL(2,[requeteSelect15_2PostgreSQL])
#execForPostgreSQL(2,[requeteSelect20_2PostgreSQL])
#execForPostgreSQL(2,[requeteSelect25_2PostgreSQL])
#execForPostgreSQL(2,[requeteSelect30_2PostgreSQL])
#
#execForPostgreSQL(5,[requeteSelect05_3PostgreSQL])
#execForPostgreSQL(5,[requeteSelect10_3PostgreSQL])
#execForPostgreSQL(5,[requeteSelect15_3PostgreSQL])
#execForPostgreSQL(5,[requeteSelect20_3PostgreSQL])
#execForPostgreSQL(5,[requeteSelect25_3PostgreSQL])
#execForPostgreSQL(5,[requeteSelect30_3PostgreSQL])
def readAndWritePostgreSQL():
execForPostgreSQL(4,[requeteCreateTable5PostgreSQL,requeteDelete5PostgreSQL,requeteInsertPostgreSQL,requeteDropFlight2PostgreSQL])
@@ -312,9 +320,9 @@ def runPostgreSQL():
readPostgreSQL()
readAndWritePostgreSQL()
#readAndWritePostgreSQL()
writePostgreSQL()
#writePostgreSQL()
# execute n fois les n requêtes