ca marche
This commit is contained in:
@@ -71,7 +71,7 @@ def create_table_monetdb(connection,cursor):
|
|||||||
cursor.execute(createFlights)
|
cursor.execute(createFlights)
|
||||||
connection.commit()
|
connection.commit()
|
||||||
|
|
||||||
def create_data_monetdb(connection,cursor):
|
def load_data_monetdb(connection,cursor):
|
||||||
cursor.execute(peuplementAirlines)
|
cursor.execute(peuplementAirlines)
|
||||||
cursor.execute(peuplementAirports)
|
cursor.execute(peuplementAirports)
|
||||||
cursor.execute(peuplementFlights)
|
cursor.execute(peuplementFlights)
|
||||||
|
|||||||
10
main.py
10
main.py
@@ -22,14 +22,14 @@ requeteCreateTablePostgreSQL = """CREATE TABLE flights10 AS SELECT * FROM FLIGHT
|
|||||||
requeteDeletePostgreSQL = """DELETE FROM flights WHERE "DAY" > 10"""
|
requeteDeletePostgreSQL = """DELETE FROM flights WHERE "DAY" > 10"""
|
||||||
requeteInsertPostgreSQL = """INSERT INTO flights SELECT * FROM flights10"""
|
requeteInsertPostgreSQL = """INSERT INTO flights SELECT * FROM flights10"""
|
||||||
|
|
||||||
def initMoneDB(conn,cursor):
|
def initMonetDB(conn,cursor):
|
||||||
reset_data_monetdb(conn,cursor)
|
reset_data_monetdb(conn,cursor)
|
||||||
create_table_monetdb(conn,cursor)
|
create_table_monetdb(conn,cursor)
|
||||||
create_data_monetdb(conn,cursor)
|
load_data_monetdb(conn,cursor)
|
||||||
|
load_data_monetdb(conn,cursor)
|
||||||
|
|
||||||
def execMoneDB(conn,cursor,str):
|
def execMonetDB(conn,cursor,str):
|
||||||
requete_monetdb(conn,cursor, str)
|
requete_monetdb(conn,cursor, str)
|
||||||
|
|
||||||
|
|
||||||
def display_table(data, headers):
|
def display_table(data, headers):
|
||||||
max_len = max(len(header) for header in headers)
|
max_len = max(len(header) for header in headers)
|
||||||
@@ -51,7 +51,7 @@ if __name__ == '__main__':
|
|||||||
#MonetDB
|
#MonetDB
|
||||||
conn, cursor =connect_monetdb()
|
conn, cursor =connect_monetdb()
|
||||||
start = time.time()
|
start = time.time()
|
||||||
initMoneDB(conn,cursor)
|
initMonetDB(conn,cursor)
|
||||||
print(time.time() - start)
|
print(time.time() - start)
|
||||||
#execMoneDB(conn,cursor,requeteSelect1MonetDB)
|
#execMoneDB(conn,cursor,requeteSelect1MonetDB)
|
||||||
disconnect_monetdb(conn, cursor)
|
disconnect_monetdb(conn, cursor)
|
||||||
Reference in New Issue
Block a user