adicao do arquivo central que contem a classe CommandCenter que contem todas as funcoes necessarias para o funcionamendo da SmartFarm

Author: EduardFonseca

codigos_python/Adicionar.py

@@ -1,6 +1,6 @@
 import pandas as pd
 import sqlalchemy
-import mysql.connector 
+import mysql.connector
 
 engine = sqlalchemy.create_engine('mysql+pymysql://u165471834_admin:admin@92.249.44.52/u165471834_smartfarmdb') 
 

codigos_python/Central.py

@@ -0,0 +1,64 @@
+#Arquivo central para reunir as funcoes necessarias para serem aplicadas na smartfarm
+import mysql.connector
+import pandas as pd
+import sqlalchemy
+from sqlalchemy.orm import sessionmaker
+import time
+
+
+class ComandCenter():
+
+    def __init__(self,host_ip,user,password,database,tablename,tags):
+        """
+        Construtor central da classe responsavel
+        por iniciar as variaveis do codigo
+        e iniciar conexao com a base de dados
+
+        Args:
+            host_ip (str): ip do host da base de dados
+            user (str): usuario para acessar a base de dados
+            password (str): senha para acessar a base de dados
+            database (str): nome da base de dados a ser acessada
+            tablename (str): nome da tabela a ser modificada
+            tags (dict): Dicionario dos sensores e valvulas do sistema
+        """
+        self.__host = host_ip
+        self.__user = user
+        self.__pw = password
+        self.__dbpath = database
+        self._table_name = tablename
+        self._db = mysql.connector.connect (
+            host=self.__host,
+            user= self.__user,
+            password= self.__pw,
+            database= self.__dbpath
+        )
+        self._cursor = self._db.cursor()
+        #TODO:(testar funcionamento do addr)
+        addr = 'mysql+pymysql://'+self.__user + ':' + self.__pw + "@" + self.__host + '/' + self.__dbpath
+        self._engine = sqlalchemy.create_engine(addr)
+
+    def getData(self):
+        """
+        Obtem dados da DB e faz  print no console
+        """
+        df_index = pd.read_sql_query('select * from {self._table_name}',self._engine,index_col='id')
+        print(df_index)
+
+    def addData(self,data):
+        #TODO: Adicionar o Lock.aquire() e Lock.release()
+        str_cols = str_cols = ','.join(data.keys())
+        str_values = []
+        str_values.append([data[tag] for tag in data.keys()])
+        sql = f'INSERT INTO {self._table_name} ({str_cols}) VALUES (%s, %s, %s, %s)'
+        self._cursor.executemany(sql,str_values)
+        print(self._cursor.rowcount, "Dados foram adicionados.")
+
+    def removeData(self):
+        pass
+
+    def getValveState(self):
+        pass
+
+    def controleValvula(self):
+        pass

codigos_python/Remover.py

@@ -23,7 +23,7 @@
     com = sql+J+ "'"
     mycursor.execute(com)
     teste_db.commit()
-    
+
 print("Linhas removidas.")
 
 a = "ALTER TABLE dados AUTO_INCREMENT = "

codigos_python/query_dados.py

@@ -1,7 +1,27 @@
-import pandas as pd
-import sqlalchemy
+# import pandas as pd
+# import sqlalchemy
 
-engine = sqlalchemy.create_engine('mysql+pymysql://u165471834_admin:admin@92.249.44.52/u165471834_smartfarmdb') 
-df_index = pd.read_sql_query('select * from dados',engine,index_col='id')
-print(df_index)
+# engine = sqlalchemy.create_engine('mysql+pymysql://u165471834_admin:admin@92.249.44.52/u165471834_smartfarmdb') 
+# df_index = pd.read_sql_query('select * from dados',engine,index_col='id')
+# print(df_index)
 
+
+"""
+Testes para os codigos
+"""
+dict={
+    'Sensor1': 1,
+    'Sensor2': 2,
+    'Senseor3': 3,
+    'Valvula': 4
+}
+
+val = [
+  ('1', '2', '3', '1')
+]
+print(dict)
+str_cols = ','.join(dict.keys())
+str_values=[]
+str_values.append([dict[tag] for tag in dict.keys()])
+print(len(str_values))
+print(len(val))