如何使用 SQLAlchemy 正確地將 Pandas DataFrame 寫入 MySQL？

使用SQLAlchemy 和MySQL 將Pandas DataFrame 寫入MySQL

當嘗試使用to_sql 方法將Mypandas Data用的'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中文網其他相關文章！