From 68d72ef7687f943e2a1a8cf7a01d97fd6b83adba Mon Sep 17 00:00:00 2001 From: Darius Bertrand Date: Mon, 13 Mar 2023 17:27:27 +0000 Subject: [PATCH] debut lien bdd decoder --- src/.Table.sql.swp | Bin 0 -> 12288 bytes src/Main.py | 35 ++++++++++++++++++++++------------- 2 files changed, 22 insertions(+), 13 deletions(-) create mode 100644 src/.Table.sql.swp diff --git a/src/.Table.sql.swp b/src/.Table.sql.swp new file mode 100644 index 0000000000000000000000000000000000000000..d959b90af394f0caadf973439a1694b838ac3307 GIT binary patch literal 12288 zcmeI&K}#D!6bJB^9xMpeP!IN0M!h6rvYWMsqIigAg|{D}LfPr6YIf3{ zbRhZ=fWRvRKGCXIbM1zu#RW0<`R6P4Vkrb5009U<00Izz00bcL-UZB{K<9jk52K6B zj>f`^ar6-b1Rwwb2tWV=5P$##AOHafKmY>oP(a2+UuTF;Irjhm@$dgje)!8d<3yY< zoO#Y2ue;^kaIQI5oPV4P&X8lz$vG$pKmY;|fB*y_009U<00Izz08x3J1lK?(J*kJ{ zj~bR_9BY+jYQ+o(s{GJCm0gu<(a(EIC(+8oob8I}Sn5)({5Uh-_PrIobrxrPx# literal 0 HcmV?d00001 diff --git a/src/Main.py b/src/Main.py index fbea8fd..11a0a16 100644 --- a/src/Main.py +++ b/src/Main.py @@ -9,7 +9,7 @@ from cProfile import label import psycopg2 as psy# pip3 install types-psycopg2 -import pandas as pand # pip3 install pandas +import pandas as pd # pip3 install pandas import getpass ################# Debut Tips ################# @@ -19,22 +19,30 @@ import getpass ################# Fin Tips ################# -def insert_Country(connection, filename: str): +def insert_Status(connection, flow str): cur = connection.cursor() - df = pand.DataFrame(pand.read_csv(filename)).dropna() - id_table=0 - for row in df.itertuples(): - for country in row.country_lastfm.split('; '): - id_table+=1 - cur.execute("INSERT INTO Country VALUES (%s, %s) ON CONFLICT ON CONSTRAINT doublons_country DO NOTHING;", - (id_table, - str(country)) - ) + df = pd.DataFrame(pd.read_csv(filename)).dropna() + + for row in df.itertuples(): + cur.execute("INSERT INTO Status VALUES (%s,%s,%s );", + (row.addresse, + row.type, + row.valeur) + ) connection.commit() cur.close() +def status_State(connection): + cur = connection.cursor() + pd.read_sql(''' SELECT adresse, type, valeur FROM Status''' + res = cur.fetchone() + return res + cur.close() + + + def create_tables(connection, filename): cur = connection.cursor() with open(filename) as f: @@ -52,10 +60,11 @@ if __name__ == '__main__': db_name = 'dblodufour1' db_user = input('Utilisateur : ') if not db_user: - db_user = 'lodufour1' + db_user = 'ladufour1' db_password = getpass('Mot de passe : ') connection = psy.connect(host=db_host, database=db_name, user=db_user, password=db_password) + create_tables(connection, 'Table.sql') - connection.close() \ No newline at end of file + connection.close()