ok
ok
This commit is contained in:
@@ -20,10 +20,16 @@ def connect_monetdb():
|
||||
return connection, cursor
|
||||
|
||||
def create_table_monetdb(cursor):
|
||||
return 0
|
||||
cursor.execute(createAirports)
|
||||
cursor.execute(createAirports)
|
||||
cursor.execute(createFlights)
|
||||
|
||||
|
||||
def create_data_monetdb(cursor):
|
||||
cursor.execute(peuplementAirlines)
|
||||
cursor.execute(peuplementFlights)
|
||||
cursor.execute(peuplementAirports)
|
||||
|
||||
def disconnect_monetdb(connection,cursor):
|
||||
cursor.close()
|
||||
connection.close()
|
||||
|
||||
25
main.py
25
main.py
@@ -1,36 +1,23 @@
|
||||
import time
|
||||
|
||||
from PostgreSQL import create_tables_postgres,create_data_postgres,requete_lecture_postgres
|
||||
|
||||
from MonetDB import *
|
||||
from PostgreSQL import *
|
||||
|
||||
#Monet DB
|
||||
requeteSelect1MonetDB = """SELECT * FROM flights WHERE "AIRLINE" = 'AA';"""
|
||||
|
||||
requeteSelect2MonetDB = """SELECT * FROM flights;"""
|
||||
|
||||
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;"""
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
requeteSelect1PostgreSQL = """SELECT * FROM public.flights
|
||||
WHERE airline = 'AA'
|
||||
"""
|
||||
|
||||
#Postgre SQL
|
||||
requeteSelect1PostgreSQL = """SELECT * FROM public.flights WHERE airline = 'AA'"""
|
||||
requeteSelect2PostgreSQL = """SELECT * FROM public.flights"""
|
||||
|
||||
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"""
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
#PostgreSQL
|
||||
#create_tables_postgres()
|
||||
#create_data_postgres()
|
||||
str="""SELECT * FROM public.flights WHERE airline = 'AA'"""
|
||||
|
||||
Reference in New Issue
Block a user