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(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。