diff --git a/src/Main.py b/src/Main.py index 8194541..35942b0 100644 --- a/src/Main.py +++ b/src/Main.py @@ -19,21 +19,36 @@ import getpass ################# Fin Tips ################# -def insert_Status(connection,flow): - cur = connection.cursor() +def insert_Status(type, adresse, valeur): + +if __name__ == '__main__': + db_host = input('Nom d\'hôte : ') + if not db_host: + db_host = 'londres' + db_name = input('Nom de la base de données : ') + if not db_name: + db_name = 'dblodufour1' + db_user = input('Utilisateur : ') + if not db_user: + db_user = 'ladufour1' + db_password = getpass('Mot de passe : ') + connection = psy.connect(host=db_host, database=db_name, user=db_user, password=db_password) + cur = connection.cursor() + for row in df.itertuples(): cur.execute("INSERT INTO Status VALUES (%s,%s,%s );", - (row.addresse, - row.type, - row.valeur) + (type, + adresse, + valeur) ) connection.commit() cur.close() + def status_State(connection): cur = connection.cursor() pd.read_sql(''' SELECT adresse, type, valeur FROM Status'''