crrection nom fonction

This commit is contained in:
trochas
2024-12-04 10:18:41 +01:00
parent 0839f20c84
commit 055140a82e
2 changed files with 7 additions and 7 deletions

View File

@@ -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(r"COPY INTO airlines FROM 'C:\\Users\\Public\\2015_Flight_Delay_and_cancellations\\airlines.csv' USING DELIMITERS ',', E'\n', '\"';") cursor.execute(r"COPY INTO airlines FROM 'C:\\Users\\Public\\2015_Flight_Delay_and_cancellations\\airlines.csv' USING DELIMITERS ',', E'\n', '\"';")
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(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)

12
main.py
View File

@@ -22,12 +22,12 @@ 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)
def execMoneDB(conn,cursor,str): def execMonetDB(conn,cursor,str):
requete_monetdb(conn,cursor, str) requete_monetdb(conn,cursor, str)
@@ -47,6 +47,6 @@ if __name__ == '__main__':
#MonetDB #MonetDB
conn, cursor =connect_monetdb() conn, cursor =connect_monetdb()
initMoneDB(conn,cursor) initMonetDB(conn,cursor)
#execMoneDB(conn,cursor,requeteSelect1MonetDB) #execMonetDB(conn,cursor,requeteSelect1MonetDB)
disconnect_monetdb(conn, cursor) disconnect_monetdb(conn, cursor)