使用 pandas 的 to_sql() 函数可以将数据框中的数据写入数据库中。如果要在写入数据时实现「ON DUPLICATE KEY UPDATE」操作,可以使用如下代码:
import pandas as pd
from sqlalchemy import create_engine
# 建立数据库连接
engine = create_engine("mysql+pymysql://username:password@localhost/database_name")
# 读取数据框
df = pd.read_csv("data.csv")
# 将数据框中的数据写入数据库,如果遇到重复键则执行更新操作
df.to_sql("table_name", engine, if_exists="replace", index=False, chunksize=1000, method="multi")
如果您在使用过程中遇到任何问题,欢迎再次提问。