Darius BERTRAND 2 years ago
parent fa62cd4ec8
commit 6939b6f107

@ -19,21 +19,36 @@ import getpass
################# Fin Tips #################
def insert_Status(connection,flow):
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'''

Loading…
Cancel
Save