这篇文章主要带大家了解有关python数据库的操作,内容详细易懂,操作简单,相信大家阅读有关“Python写入MySQL数据库的方式有哪些?如何将Python写入MySQL数据库?”之后会有一定的收获,下面让我们一起来学习吧 。
【Python写入MySQL数据库的方式有哪些?如何将Python写入MySQL数据库?】

文章插图
如果你的数据需要频繁写入到mysql中,可以使用navicat工具的导入向导功能,它支持多种文件格式,可以根据不同的内容文字字段进行自动建表,同时还可以实现在自己的表中插入数据 。
第二种场景就是数据是增量式的,需要自动化并且频繁的写入到mysql,需要用到两种方式,具体实例如下:
首先你需要导入数据,进行测试阶段
import pandas as pddata = pd.read_csv('./hh.csv')data.shape #csv格式,运行数据大概有多少条方式一:利用python中pymysql库,首先需要安装pymysql,安装命令:pip install pymysql.
代码实现:
import pymysql #导入库# 数据库连接信息conn = pymysql.connect( host='127.0.0.1', user='root', passwd='hh123321', db='test01', port = 3306, charset="utf8")# 分块处理big_size = 100000# 分块遍历写入到 mysql with pd.read_csv('./hh.csv',chunksize=big_size) as reader: for df in reader: datas = [] print('处理:',len(df))# print(df) for i ,j in df.iterrows(): data = (j['user_id'],j['item_id'],j['behavior_type'], j['item_category'],j['time']) datas.append(data) _values = ",".join(['%s', ] * 5) sql = """insert into users(user_id,item_id,behavior_type ,item_category,time) values(%s)""" % _values cursor = conn.cursor() cursor.executemany(sql,datas) conn.commit() # 关闭服务 conn.close()cursor.close()print('存入成功!')方法二:利用python中pandas库,需要引用sqlalchemy,才能支持实现所有常见数据库类型的查询、更新等操作,相对于pymysql来说,代码简单 。
代码实现:
from sqlalchemy import create_engineengine = create_engine('mysql+pymysql://root:hh@localhost:3306/test01')data = pd.read_csv('./hh.csv')data.to_sql('user02',engine,chunksize=100000,index=None)print('存入成功!')有关“Python写入MySQL数据库的方式有哪些?如何将Python写入MySQL数据库?”的内容到此结束啦,希望对大家都有所帮助,想要了解更多,可继续关注哦,会给大家带来更多的小惊喜!
推荐阅读
- python怎么把txt文件读取为数组?txt文件读取为数组的方法有哪些?
- python文件读取失败怎么办?如何解决python文件读取失败
- python什么是素数?怎么用Python求某个范围内的所有素数
- Python如何批量转换多种音乐格式?Python如何将音乐格式批量转换?
- Python如何判断字符串是不是数字?判断算法的方法有哪些?
- Python和java哪个更值得学?python和java该如何选择?
- python中的百分号表示什么意思?如何使用python中百分号?
- for循环输出两种方法是什么? 如何在python中利用for循环实现内输出和外输出?
- python字符串切片如何使用?字符串切片的用法
- python和C语言之间有什么区别?python和C语言的区别