Python解析Json⽂件，写⼊到mysql
import json
import pymysql查找iphone
def prem(db):
cursor = db.cursor()
data = cursor.fetchone()
print("Databa version : %s "% data)# 结果表明已经连接成功
sql ="""CREATE TABLE review (
** VARCHAR(100)"""
青鱼怎么钓
def reviewdata_inrt(db,dir_name,tablename,tup):
with open(dir_name,'r', encoding='utf-8')as f:
i =0
while True:
i +=1
print(u'正在载⼊第%s⾏......'% i)
#try:
lines = f.readline()
if len(lines)>0:
冷酷动漫头像review_text = json.loads(lines)
el:大班建构游戏教案
break
result =[]
result.append(([review_text[i]for i in tup]))
print(result)
mid =""
per =""
for field in tup:
mid += field+","
per +="%s,"
print(mid[:-1])
print(per[:-1])
inesrt_re ="inrt into {0}".format(tablename)+"("+mid[:-1]+") values ("+ per[:-1]+")"
print(inesrt_re)
cursor = db.cursor()
新年食谱
# except Exception as e:
# db.rollback()
# print(str(e))
# break
if __name__ =="__main__":# 起到⼀个初始化或者调⽤函数的作⽤
db = t("localhost","root","root","sobot_db", chart='utf8')
cursor = db.cursor()
黑叶猴#prem(db)
tablename ="rpt_stafflogin_log"
json_name ='test.json'
tup =['logType','companyId','datetime','loginLogType','source','operation','staffId']
reviewdata_inrt(db,json_name,tablename,tup)
cursor.clo()
测试数据
{“logType”:2,“companyId”:“51198d62b6574403a0b7e85d72d31b78”,“datetime”:1557804551790,“loginLogTy pe”:0,“source”:0,“operation”:2,“staffId”:“1ebcc059b3ca478aaecde4b5e9fca9df”}
图书借阅{“logType”:2,“companyId”:“51198d62b6574403a0b7e85d72d31b78”,“datetime”:1557806744163,“loginLogTy pe”:0,“source”:0,“operation”:0,“staffId”:“efef7570fa9b4021890d815144776a99”}
举例说明{“logType”:2,“companyId”:“51198d62b6574403a0b7e85d72d31b78”,“datetime”:1558767573813,“loginLogTy pe”:0,“source”:0,“operation”:6,“staffId”:“73177bcddbf047f596bc9a6e6574abc4”}
{“logType”:2,“companyId”:“51198d62b6574403a0b7e85d72d31b78”,“datetime”:1559361115531,“loginLogTy pe”:0,“source”:0,“operation”:0,“staffId”:“c107d24efccc4096ae0a37eba093bf9a”}
