From 5209c37ab2a06d4fdb0678e4529c73dac59d5430 Mon Sep 17 00:00:00 2001 From: hichbra <hicham.brahimi@laposte.net> Date: Thu, 14 Feb 2019 18:29:19 +0100 Subject: [PATCH] File to Sql --- PC/FileToSql.py | 55 +++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 55 insertions(+) create mode 100644 PC/FileToSql.py diff --git a/PC/FileToSql.py b/PC/FileToSql.py new file mode 100644 index 0000000..392b6e7 --- /dev/null +++ b/PC/FileToSql.py @@ -0,0 +1,55 @@ +import MySQLdb +import time +import sys +import os +import csv + +db = MySQLdb.connect(host="localhost",#"pil-09.univlehavre.lan", + user="firediag", + passwd="firediag$!", + db="firediag"); + +nomCapteur = "Moule A" +tabId = {} + +#--- Recupere les id des capteurs en base de donnees +for i in range(0,6): + requete = "SELECT DISTINCT id FROM capteur WHERE nom = '"+nomCapteur+""+str(i)+"'" + cursor = db.cursor(); + cursor.execute(requete) + idTab = cursor.fetchall() + tabId["A"+str(i)] = int(idTab[0][0]) + +print(tabId) + +FOLDER = "./Target/" +DIR = os.listdir(FOLDER) +DIR.sort() + +cursor = db.cursor(); + +#--- Parcours les fichiers, ajoute les valeurs en base et supprime le fichier +for f in DIR: + try: + print(FOLDER+f) + with open(FOLDER+f,'r') as csvfile: + #--- Recupere la source du fichier + id = csvfile.readline().strip().split(":")[1] + print(id) + + next(csvfile, None) + + valeurs = csv.reader(csvfile, delimiter=';') + for row in valeurs: + time = str(row[0]).strip() + + for i in range(0,6): + requete = "INSERT INTO `valeur` (`temps`, `valeur`, `idCapteur`) VALUES ('"+str(time).strip()+"', '"+str(row[i+1]).strip()+"', '"+str(tabId["A"+str(i)])+"')" + cursor.execute(requete) + #print(row) + db.commit(); + os.remove(FOLDER+f) + except Exception as e: + db.rollback(); + print("rollback "); + print(e); -- GitLab