Python SQLAlchemy 将 DataFrame 数据导入 MySQL 数据库
要将 DataFrame 存入 MySQL 数据库中,可以使用 SQLAlchemy 库来完成。下面是一个示例代码:
from sqlalchemy import create_engine
import pandas as pd
# 创建 MySQL 数据库连接
engine = create_engine('mysql+pymysql://username:password@localhost:port/database_name')
# 读取 DataFrame 数据
# 请确保 `data.csv` 文件存在于您的工作目录中
# 或者指定完整路径
df = pd.read_csv('data.csv')
# 将 DataFrame 数据存入 MySQL 数据库中的表
df.to_sql('table_name', engine, if_exists='replace', index=False)
在上面的代码中,需要替换以下内容:
'username':MySQL 数据库的用户名'password':MySQL 数据库的密码'localhost':MySQL 服务器的地址'port':MySQL 服务器的端口号'database_name':要连接的数据库名称'data.csv':要存入数据库的 CSV 文件路径'table_name':要创建的表名
在执行上述代码后,DataFrame 数据将被存储到 MySQL 数据库中的指定表中。如果表已经存在,将使用 if_exists='replace' 参数替换原有表,如果表不存在,则会自动创建新表。
请根据实际情况修改上述代码中的参数,并确保正确安装了 SQLAlchemy 和 pandas 库。
原文地址: https://www.cveoy.top/t/topic/pZF4 著作权归作者所有。请勿转载和采集!