如何使用 SQLAlchemy 正确地将 Pandas DataFrame 写入 MySQL？

使用 SQLAlchemy 和 MySQL 将 Pandas DataFrame 写入 MySQL

当尝试使用 to_sql 方法将 pandas DataFrame 写入 MySQL 表时从已弃用的 'flavor='mysql'' 语法过渡到推荐的 SQLAlchemy 引擎方法，用户可以遇到类似以下错误：

DatabaseError: Execution failed on sql 'SELECT name FROM sqlite_master
WHERE type='table' AND name=?;': Wrong number of arguments during
string formatting

此错误表明正在使用 SQLite 而不是 MySQL。要解决此问题，请确保正确使用与 MySQL 的 SQLAlchemy 连接，特别是 mysql.connector。

解决方案

可以通过使用创建的引擎来解决该错误SQLAlchemy 直接作为 to_sql 方法的连接，而不是从引擎获取原始连接。下面是更正后的代码：

import pandas as pd
import mysql.connector
from sqlalchemy import create_engine

# Create an SQLAlchemy engine
engine = create_engine('mysql+mysqlconnector://[user]:[pass]@[host]:[port]/[schema]', echo=False)

# Read data from the MySQL table
data = pd.read_sql('SELECT * FROM sample_table', engine)

# Write the DataFrame to a new table
data.to_sql(name='sample_table2', con=engine, if_exists='append', index=False)

通过使用引擎作为连接，SQLAlchemy 连接已正确建立，并且消除了有关 SQLite 的错误。这使得DataFrame能够成功写入MySQL表。

以上是如何使用 SQLAlchemy 正确地将 Pandas DataFrame 写入 MySQL？的详细内容。更多信息请关注PHP中文网其他相关文章！