import serial
import time
import _mysql
import sys

ser = serial.Serial('COM6', 9600, timeout=0)

try:
     con = _mysql.connect('localhost', 'temp', 'temp', 'temp')
except _mysql.Error, e:
     print "Error %d: %s" % (e.args[0], e.args[1])
     sys.exit(1)

while 1:
     try:
          data = ser.readline()

     except ser.SerialTimeoutException:
          print('Data could not be read')
          time.sleep(1)

     if data:
          data = data.replace('\n', '')
          data_array = data.split(',')

          print('Temp: ' + data_array[0])
          print('Addr: ' + data_array[1])
          print('Type: ' + data_array[2])

          query = 'INSERT INTO temp (temp,adresse,type) VALUES ("'+data_array[0]+'","'+data_array[1]+'","'+data_array[2]+'")'
          #print(query)
          con.query(query)

     time.sleep(1)