test postgresql
This commit is contained in:
39
main.py
39
main.py
@@ -13,10 +13,10 @@ requeteDeleteMonetDB = """DELETE FROM flights WHERE "DAY" > 10;"""
|
|||||||
requeteInsertMonetDB = """INSERT INTO flights SELECT * FROM flights10;"""
|
requeteInsertMonetDB = """INSERT INTO flights SELECT * FROM flights10;"""
|
||||||
|
|
||||||
#Postgre SQL
|
#Postgre SQL
|
||||||
requeteSelect1PostgreSQL = """SELECT * FROM public.flights WHERE airline = 'AA'"""
|
requeteSelect1PostgreSQL = """SELECT * FROM public.flights WHERE "AIRLINE" = 'AA'"""
|
||||||
requeteSelect2PostgreSQL = """SELECT * FROM public.flights"""
|
requeteSelect2PostgreSQL = """SELECT * FROM public.flights"""
|
||||||
requeteSelect3PostgreSQL = """SELECT * FROM public.flight WHERE "DAY" > 10"""
|
requeteSelect3PostgreSQL = """SELECT * FROM public.flights WHERE "DAY" > 10"""
|
||||||
requeteSelect4PostgreSQL = """SELECT * FROM public.flight WHERE "DAY" > 30"""
|
requeteSelect4PostgreSQL = """SELECT * FROM public.flights WHERE "DAY" > 30"""
|
||||||
|
|
||||||
requeteCreateTablePostgreSQL = """CREATE TABLE flights10 AS SELECT * FROM FLIGHTS WHERE "DAY" > 10"""
|
requeteCreateTablePostgreSQL = """CREATE TABLE flights10 AS SELECT * FROM FLIGHTS WHERE "DAY" > 10"""
|
||||||
requeteDeletePostgreSQL = """DELETE FROM flights WHERE "DAY" > 10"""
|
requeteDeletePostgreSQL = """DELETE FROM flights WHERE "DAY" > 10"""
|
||||||
@@ -54,14 +54,33 @@ def runMonetDB():
|
|||||||
execMonetDB(requeteSelect3MonetDB)
|
execMonetDB(requeteSelect3MonetDB)
|
||||||
execMonetDB(requeteSelect4MonetDB)
|
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():
|
def runPostgreSQL():
|
||||||
reset_database_postgres()
|
execPostgreSQL(requeteSelect1PostgreSQL)
|
||||||
create_tables_postgres()
|
execPostgreSQL(requeteSelect2PostgreSQL)
|
||||||
create_data_postgres()
|
execPostgreSQL(requeteSelect3PostgreSQL)
|
||||||
#requete_postgres(str)
|
execPostgreSQL(requeteSelect4PostgreSQL)
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
initMonetDB()
|
#initMonetDB()
|
||||||
runMonetDB()
|
#runMonetDB()
|
||||||
#runPostgreSQL()
|
#initPostgreSQL()
|
||||||
|
runPostgreSQL()
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user