要将 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 库。

Python SQLAlchemy 将 DataFrame 数据导入 MySQL 数据库

原文地址: https://www.cveoy.top/t/topic/pZF4 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录