利用Python读取实时更新csv文件,并导入到MySQL
时间: 2023-10-07 08:08:26 浏览: 227
Python实现将MySQL数据库表中的数据导出生成csv格式文件的方法
首先,需要安装`pandas`和`pymysql`库。可以使用以下命令进行安装:
```
pip install pandas
pip install pymysql
```
然后,可以使用以下代码读取csv文件并将其导入到MySQL数据库中:
```python
import pandas as pd
import pymysql
# MySQL连接信息
host = 'localhost'
port = 3306
user = 'root'
password = 'password'
database = 'test_db'
# 读取csv文件
df = pd.read_csv('/path/to/csv/file.csv')
# 连接MySQL
conn = pymysql.connect(host=host, port=port, user=user, password=password, database=database)
# 创建游标对象
cursor = conn.cursor()
# 将数据插入到MySQL表中
for index, row in df.iterrows():
sql = "INSERT INTO table_name (col1, col2, col3) VALUES (%s, %s, %s)"
cursor.execute(sql, (row['col1'], row['col2'], row['col3']))
# 提交更改
conn.commit()
# 关闭游标和连接
cursor.close()
conn.close()
```
需要注意的是,上述代码中需要修改的部分包括MySQL连接信息、csv文件路径、MySQL表名以及列名等部分。
阅读全文