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

Barbara Streisand
发布: 2024-11-27 22:49:09
原创
217 人浏览过

How to Correctly Write Pandas DataFrames to MySQL Using SQLAlchemy?

使用 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中文网其他相关文章!

来源:php.cn
本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
作者最新文章
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板