ajout de fonction dans le main
This commit is contained in:
Binary file not shown.
Binary file not shown.
24
main.py
24
main.py
@@ -1,5 +1,5 @@
|
||||
from MonetDB import *
|
||||
from PostgreSQL import *
|
||||
#from PostgreSQL import *
|
||||
import re
|
||||
|
||||
#Monet DB
|
||||
@@ -16,12 +16,21 @@ requeteInsertMonetDB = """INSERT INTO flights SELECT * FROM flights10;"""
|
||||
requeteSelect1PostgreSQL = """SELECT * FROM public.flights WHERE airline = 'AA'"""
|
||||
requeteSelect2PostgreSQL = """SELECT * FROM public.flights"""
|
||||
requeteSelect3PostgreSQL = """SELECT * FROM public.flight WHERE “DAY” > 10"""
|
||||
requeteSelect2PostgreSQL = """SELECT * FROM public.flight WHERE “DAY” > 30"""
|
||||
requeteSelect4PostgreSQL = """SELECT * FROM public.flight WHERE “DAY” > 30"""
|
||||
|
||||
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"""
|
||||
|
||||
def initMoneDB(conn,cursor):
|
||||
reset_data_monetdb(conn,cursor)
|
||||
create_table_monetdb(conn,cursor)
|
||||
create_data_monetdb(conn,cursor)
|
||||
create_data_monetdb(conn,cursor)
|
||||
|
||||
def execMoneDB(conn,cursor,str):
|
||||
requete_monetdb(conn,cursor, str)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
#PostgreSQL
|
||||
@@ -31,7 +40,10 @@ if __name__ == '__main__':
|
||||
|
||||
#MonetDB
|
||||
conn, cursor =connect_monetdb()
|
||||
create_table_monetdb(conn,cursor)
|
||||
#create_data_monetdb(conn,cursor)
|
||||
#requete_monetdb(conn,cursor, str)
|
||||
#disconnect_monetdb(conn, cursor)
|
||||
initMoneDB(conn,cursor)
|
||||
execMoneDB(conn,cursor,requeteSelect1MonetDB)
|
||||
disconnect_monetdb(conn, cursor)
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user