Advertisement
Guest User

asdasd

a guest
Dec 27th, 2016
98
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 2.27 KB | None | 0 0
  1. # -*- coding: utf-8 -*-
  2.  
  3. import MySQLdb
  4. import serial
  5. import time
  6.  
  7.  
  8. #Datos de conexion
  9. DB_HOST = '192.168.10.3'
  10. DB_USER = 'root'
  11. DB_PASS = 'tech123'
  12. DB_NAME = 'Harnes'
  13.  
  14. #Datos de conexion BD2
  15. DB_HOST2 = '192.168.10.3'
  16. DB_USER2 = 'root'
  17. DB_PASS2 = 'tech123'
  18. DB_NAME2 = 'BD-A'
  19.  
  20.  
  21. #conexion y ejecucion de query
  22. def run_query(query=''):
  23.     datos = [DB_HOST, DB_USER, DB_PASS, DB_NAME]
  24.     conn = MySQLdb.connect(*datos) # Conectar a la base de datos
  25.     cursor = conn.cursor()         # Crear un cursor
  26.     cursor.execute(query)          # Ejecutar una consulta
  27.  
  28.     if query.upper().startswith('SELECT'):
  29.         data = cursor.fetchall()   # Traer los resultados de un select
  30.     else:
  31.         conn.commit()              # Hacer efectiva la escritura de datos
  32.         data = None
  33.  
  34.     cursor.close()                 # Cerrar el cursor
  35.     conn.close()                   # Cerrar la conexion
  36.  
  37.     return data
  38.  
  39. #conexion y ejecucion de query
  40. def run_queryBD2(query=''):
  41.     datos = [DB_HOST2, DB_USER2, DB_PASS2, DB_NAME2]
  42.     conn = MySQLdb.connect(*datos) # Conectar a la base de datos
  43.     cursor = conn.cursor()         # Crear un cursor
  44.     cursor.execute(query)          # Ejecutar una consulta
  45.  
  46.     if query.upper().startswith('SELECT'):
  47.         data = cursor.fetchall()   # Traer los resultados de un select
  48.     else:
  49.         conn.commit()              # Hacer efectiva la escritura de datos
  50.         data = None
  51.  
  52.     cursor.close()                 # Cerrar el cursor
  53.     conn.close()                   # Cerrar la conexion
  54.  
  55.     return data
  56.  
  57. initialValue=0
  58. flag=True
  59.  
  60.  
  61. while(1):
  62.     try:    
  63.         response=run_query("SELECT * FROM Harnes.Insertion ORDER BY idInsertion DESC LIMIT 1;")
  64.         idInsertionValue=response[0][6]
  65.         if idInsertionValue==initialValue:
  66.             flag=False
  67.     except:
  68.         pass
  69.     if flag:
  70.         try:
  71.             varIdDevice=response[0][0]
  72.             varTemperatura=response[0][4]
  73.             if int(varTemperatura)<25:
  74.                 varTime=response[0][5]
  75.  
  76.                 run_query("INSERT INTO APP_A(Temperatura,idDevice,Fecha) VALUES ("+str(varTemperature)+","+str(idDevice)+","+str(varTime)")")
  77.  
  78.             initialValue=idInsertionValue
  79.         except: pass
  80.     else: pass
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement