本文共 1029 字，大约阅读时间需要 3 分钟。
import pymysqlimport pandas as pdimport csvdef connectdb(): print('连接到mysql服务器...') db = pymysql.connect("localhost","root","root","babyheart" ) print('连接上了!') return dbdef querydb(db, sql): try: return pd.read_sql(sql, con=db) except: return "Error: unable to fecth data" def createtable(db, sql): cursor = db.cursor() cursor.execute("DROP TABLE IF EXISTS heart_data") cursor.execute(sql)def insert_by_many(db, param, sql): cur = db.cursor() try: cur.executemany(sql, param) db.commit() except Exception as e: print(e) 插入json格式的一个例子：
json有种格式，JSON_ARRAY 和 JSON_OBJECT# 先创建表db = connectdb()sql = 'CREATE TABLE heart_data(id varchar(6) PRIMARY KEY NOT NULL,value json, nst_result varchar(6))'createtable(db,sql)# 插入一条数据s = "1,2,3,4,5,6,7" sql = 'INSERT INTO heart_data (id, value, nst_result) VALUES (%s, JSON_ARRAY(%s), %s)'param = [["a", s, "1"]]insert_by_many(db, param, sql)
另外使用参考：https://juejin.im/post/5cdd528351882508cb6f862e
转载地址：http://ikmfb.baihongyu.com/