vuminh224/m1_bdd_comparaison_perf
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ca marche

Browse Source
This commit is contained in:
Minh VU
2024-12-04 09:26:20 +01:00
parent 3375b9f920
commit e1357b8550
2 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
MonetDB.py
View File

@@ -72,9 +72,9 @@ def create_table_monetdb(connection,cursor):
connection.commit() connection.commit()
def create_data_monetdb(connection,cursor): def create_data_monetdb(connection,cursor):
cursor.execute(r"COPY INTO airlines FROM 'C:\\Users\\Public\\2015_Flight_Delay_and_cancellations\\airlines.csv' USING DELIMITERS ',', E'\n', '\"';") cursor.execute(peuplementAirlines)
cursor.execute(r"COPY INTO airports FROM 'C:\\Users\\Public\\2015_Flight_Delay_and_cancellations\\airports.csv' USING DELIMITERS ',', E'\n', '\"' NULL AS '';")
cursor.execute(peuplementAirports) cursor.execute(peuplementAirports)
cursor.execute(peuplementFlights)
connection.commit() connection.commit()
def requete_monetdb(connection,cursor,str): def requete_monetdb(connection,cursor,str):

14
main.py
View File

@@ -1,6 +1,6 @@
from MonetDB import * from MonetDB import *
#from PostgreSQL import * from PostgreSQL import *
import re import time
#Monet DB #Monet DB
requeteSelect1MonetDB = """SELECT * FROM flights WHERE "AIRLINE" = 'AA';""" requeteSelect1MonetDB = """SELECT * FROM flights WHERE "AIRLINE" = 'AA';"""
@@ -26,7 +26,6 @@ def initMoneDB(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) create_data_monetdb(conn,cursor)
create_data_monetdb(conn,cursor)
def execMoneDB(conn,cursor,str): def execMoneDB(conn,cursor,str):
requete_monetdb(conn,cursor, str) requete_monetdb(conn,cursor, str)
@@ -42,12 +41,17 @@ def display_table(data, headers):
if __name__ == '__main__': if __name__ == '__main__':
#PostgreSQL #PostgreSQL
#create_tables_postgres() reset_database_postgres()
#create_data_postgres() start_time = time.time()
create_tables_postgres()
create_data_postgres()
print(time.time() - start_time)
#requete_postgres(str) #requete_postgres(str)
#MonetDB #MonetDB
conn, cursor =connect_monetdb() conn, cursor =connect_monetdb()
start = time.time()
initMoneDB(conn,cursor) initMoneDB(conn,cursor)
print(time.time() - start)
#execMoneDB(conn,cursor,requeteSelect1MonetDB) #execMoneDB(conn,cursor,requeteSelect1MonetDB)
disconnect_monetdb(conn, cursor) disconnect_monetdb(conn, cursor)