update

update

MonetDB.py

@@ -1,34 +1,44 @@
 import pymonetdb
 
-
-connection = pymonetdb.connect(username="monetdb", password="monetdb", hostname="localhost", database="demo")
-# create a cursor
-cursor = connection.cursor()
-
-
-createAirlines = """CREATE TABLE airlines("IATA_CODE" VARCHAR(2) NOT NULL PRIMARY KEY UNIQUE, "AIRLINE" VARCHAR(99) NOT NULL);"""
-
-createAirports = """CREATE TABLE airports("IATA_CODE" VARCHAR(3) NOT NULL PRIMARY KEY UNIQUE, "AIRPORT" VARCHAR(100), "CITY" VARCHAR(40),
-"STATE" VARCHAR(2), "COUNTRY" VARCHAR(40), "LATITUDE" REAL, "LONGITUDE" REAL);"""
-
+createAirports = """CREATE TABLE airports("IATA_CODE" VARCHAR(3) NOT NULL PRIMARY KEY UNIQUE, "AIRPORT" VARCHAR(100), "CITY" VARCHAR(40), "STATE" VARCHAR(2), "COUNTRY" VARCHAR(40), "LATITUDE" REAL, "LONGITUDE" REAL);"""
 createFlights = """CREATE TABLE flights("YEAR" INT, "MONTH" INT, "DAY" INT, "DAY_OF_WEEK" INT, "AIRLINE" VARCHAR(2), "FLIGHT_NUMBER" INT,
 "TAIL_NUMBER" VARCHAR(6), "ORIGIN_AIRPORT" VARCHAR(5), "DESTINATION_AIRPORT" VARCHAR(5), "SCHEDULED_DEPARTURE" INT, "DEPARTURE_TIME" INT,
 "DEPARTURE_DELAY" INT, "TAXI_OUT" INT, "WHEELS_OFF" INT, "SCHEDULED_TIME" INT, "ELAPSED_TIME" INT, "AIR_TIME" INT, "DISTANCE" INT,
-WHEELS_ON" INT, "TAXI_IN" INT, "SCHEDULED_ARRIVAL" INT, "ARRIVAL_TIME" INT, "ARRIVAL_DELAY" INT, "DIVERTED" INT, "CANCELLED" INT,
+"WHEELS_ON" INT, "TAXI_IN" INT, "SCHEDULED_ARRIVAL" INT, "ARRIVAL_TIME" INT, "ARRIVAL_DELAY" INT, "DIVERTED" INT, "CANCELLED" INT,
 "CANCELLATION_REASON" VARCHAR(1), "AIR_SYSTEM_DELAY" INT, "SECURITY_DELAY" INT, "AIRLINE_DELAY" INT, "LATE_AIRCRAFT_DELAY" INT, "WEATHER_DELAY" INT);"""
 
-peuplementAirlines = """COPY INTO airlines 
-FROM 'C:\\Users\\Public\\2015_Flight_Delay_and_cancellations\\airlines.csv' 
-USING DELIMITERS ',', E'\n', '\"';"""
 
-peuplementAirports = """COPY INTO airports 
-FROM 'C:\\Users\\Public\\2015_Flight_Delay_and_cancellations\\airports.csv' 
-USING DELIMITERS ',', E'\n', '"' NULL AS '';
-"""
+peuplementAirlines = """COPY INTO airlines FROM 'C:\\Users\\Public\\2015_Flight_Delay_and_cancellations\\airlines.csv' USING DELIMITERS ',', E'\n', '\"';"""
+peuplementAirports = """COPY INTO airports FROM 'C:\\Users\\Public\\2015_Flight_Delay_and_cancellations\\airports.csv' USING DELIMITERS ',', E'\n', '"' NULL AS '';"""
+peuplementFlights = """COPY INTO flights FROM 'C:\\Users\\Public\\2015_Flight_Delay_and_cancellations\\flights.csv' USING DELIMITERS ',', E'\n', '"' NULL AS '';"""
+
+
+def connect_monetdb():
+    connection = pymonetdb.connect(username="monetdb", password="monetdb", hostname="localhost", database="demo")
+    # create a cursor
+    cursor = connection.cursor()
+    return connection, cursor
+
+def create_table_monetdb(cursor):
+    return 0
+
+
+def create_data_monetdb(cursor):
+    cursor.execute(peuplementAirlines)
+    cursor.execute(peuplementFlights)
+    cursor.execute(peuplementAirports)
+
+
+
+
+
+
+
+
+
+
+
 
-peuplementFlights = """COPY INTO flights 
-FROM 'C:\\Users\\Public\\2015_Flight_Delay_and_cancellations\\flights.csv' 
-USING DELIMITERS ',', E'\n', '"' NULL AS '';"""
 
 requeteSelect1 = """SELECT * FROM flights WHERE "AIRLINE" = 'AA';"""
 
@@ -40,4 +50,5 @@ WHERE airline = 'AA'
 
 requeteDelete = """DELETE FROM flights WHERE "DAY" > 10"""
 
-requeteInsert = """INSERT INTO flights SELECT * FROM flights10"""
+requeteInsert = """INSERT INTO flights SELECT * FROM flights10"""
+

PostgreSQL.py

@@ -9,7 +9,7 @@ def connect_postgres():
         password="1"
     )
 
-def create_tables():
+def create_tables_postgres():
     sql_command_create_table= (
         """CREATE TABLE airlines
         (
@@ -75,7 +75,7 @@ def create_tables():
         print(error)
 
 
-def create_data():
+def create_data_postgres():
     sql_command_copy =(
         """COPY airlines FROM 'C://Users//Public//2015_Flight_Delay_and_cancellations//airlines.csv' DELIMITER ',' NULL AS ''""",
         """COPY airports FROM 'C://Users//Public//2015_Flight_Delay_and_cancellations//airports.csv' DELIMITER ',' NULL AS ''""",
@@ -92,7 +92,7 @@ def create_data():
         print(error)
 
 
-def requete_lecture(str):
+def requete_lecture_postgres(str):
     try:
         with connect_postgres() as conn:
             with conn.cursor() as cursor:

main.py

@@ -1,9 +1,9 @@
 import time
 
-from PostgreSQL import create_tables,create_data,requete_lecture
+from PostgreSQL import create_tables_postgres,create_data_postgres,requete_lecture_postgres
 
 if __name__ == '__main__':
-    #create_tables()
-    #create_data()
+    #create_tables_postgres()
+    #create_data_postgres()
     str="""SELECT * FROM public.flights WHERE airline = 'AA'"""
-    requete_lecture(str)
+    requete_lecture_postgres(str)