62 lines
2.2 KiB
Python
62 lines
2.2 KiB
Python
from MonetDB import *
|
|
from PostgreSQL import *
|
|
import time
|
|
|
|
#Monet DB
|
|
requeteSelect1MonetDB = """SELECT * FROM flights WHERE "AIRLINE" = 'AA';"""
|
|
requeteSelect2MonetDB = """SELECT * FROM flights;"""
|
|
requeteSelect3MonetDB = """SELECT * FROM flight WHERE “DAY” > 10;"""
|
|
requeteSelect4MonetDB = """SELECT * FROM flight WHERE “DAY” > 30;"""
|
|
|
|
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;"""
|
|
|
|
#Postgre SQL
|
|
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"""
|
|
|
|
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"""
|
|
|
|
def initMonetDB(conn,cursor):
|
|
reset_data_monetdb(conn,cursor)
|
|
create_table_monetdb(conn,cursor)
|
|
load_data_monetdb(conn,cursor)
|
|
|
|
def execMonetDB(conn,cursor,str):
|
|
requete_monetdb(conn,cursor, str)
|
|
|
|
def display_table(data, headers):
|
|
max_len = max(len(header) for header in headers)
|
|
print(" | ".join(header.ljust(max_len) for header in headers))
|
|
sep = "-" * max_len
|
|
print("-|-".join(sep for _ in headers))
|
|
for row in data:
|
|
print(" | ".join(header.ljust(max_len) for header in row))
|
|
|
|
def runMonetDB():
|
|
conn, cursor =connect_monetdb()
|
|
start = time.time()
|
|
initMonetDB(conn,cursor)
|
|
print(time.time() - start)
|
|
#execMoneDB(conn,cursor,requeteSelect1MonetDB)
|
|
disconnect_monetdb(conn, cursor)
|
|
|
|
def runPostgreSQL():
|
|
reset_database_postgres()
|
|
start_time = time.time()
|
|
create_tables_postgres()
|
|
create_data_postgres()
|
|
print(time.time() - start_time)
|
|
#requete_postgres(str)
|
|
|
|
if __name__ == '__main__':
|
|
#PostgreSQL
|
|
runMonetDB()
|
|
#runPostgreSQL()
|
|
#MonetDB
|