python

create table data(id int not null auto_increment,
   create_time timestamp NOT NULL DEFAULT NOW(),
   value TEXT,
   PRIMARY KEY (`id`)
   );


#coding=utf-8
 
import pymysql
import serial
from time import sleep
 
# 打开数据库连接
db = pymysql.connect("localhost","root","samsung","test" )
 
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()
 


def insertDb(value):
    data=value 
    # 使用 execute()  方法执行 SQL 查询 
    sqlString = "insert into data(value) values('" +data+"')"
    try:
       # 执行sql语句
       cursor.execute(sqlString)
       # 提交到数据库执行
       db.commit()
       print("insert ok")
    except:
       # 如果发生错误则回滚
       db.rollback()
       print("insert error")
    # 关闭数据库连接
    db.close()




def recv(serial):
    while True:
        data = serial.read_all()
        if data == '':
            continue
        else:
            break
        sleep(0.02)
    return data

if __name__ == '__main__':
    serial = serial.Serial('COM9', 9600, timeout=0.5)  #/dev/ttyUSB0
    if serial.isOpen() :
        print("open success")
    else :
        print("open failed")

    while True:
        data =recv(serial)
        if data != b'' :
            print("receive : ",data)
            insertDb(data)
            serial.write(data) #数据写回