python实现将json多行数据传入到mysql中使用
将json多行数据传入到mysql中使用python实现
表需要提前创建，字符集utf8如果不行换成utf8mb4
importjson
importpymysql
defreviewdata_insert(db):
withopen('data.txt',encoding='utf-8')asf:
i=0
whileTrue:
i+=1
print(u'正在载入第%s行......'%i)
try:
lines=f.readline()#使用逐行读取的方法
review_text=json.loads(lines)#解析每一行数据
result=[]
result.append((review_text['id'],review_text['created_at'],review_text['content'],
review_text['source'],review_text['reports_count'],review_text['comments_count'],
review_text['attitudes_count']))
print(result)
inesrt_re="insertintoreview(id,created_at,content,source,reports_count,comments_count,attitudes_count)values(%s,%s,%s,%s,%s,%s,%s)"
cursor=db.cursor()
cursor.executemany(inesrt_re,result)
db.commit()
exceptExceptionase:
db.rollback()
print(str(e))
break
if__name__=="__main__":#起到一个初始化或者调用函数的作用
db=pymysql.connect("192.168.67.41","root","123456","data",charset='utf8')
cursor=db.cursor()
reviewdata_insert(db)
cursor.close()
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。