Pandas调用to_sql写入本地MySQL报错Engine无cursor属性如何解决
问题原因解析
- 第一个报错
'Engine' object has no attribute 'cursor':你使用的SQLAlchemy 1.4.27属于1.4+版本,该版本调整了Engine对象的底层接口,你当前使用的pandas版本未适配该变更,直接将Engine传入to_sql的con参数会触发接口不匹配。 - 第二个报错出现sqlite相关SQL:你传入
engine.raw_connection()返回的是MySQL原生DBAPI连接,pandas无法自动识别该连接对应的数据库类型,默认按照sqlite语法生成元表查询语句,因此执行了查询sqlite_master的SQL,和你实际使用的MySQL不兼容导致报错。
修复方案
方案一:调整连接逻辑(无需升级现有依赖)
不要直接传Engine或者原生连接,而是通过SQLAlchemy的connect()方法获取连接实例传入,代码如下:
df = pd.read_csv("df.csv") engine = sqlalchemy.create_engine('mysql+mysqlconnector://{0}:{1}@{2}/{3}'.format(config.user, config.passwd, config.host, config.db)) # 使用上下文管理器获取连接 with engine.connect() as conn: df.to_sql('SQL_table', con=conn, if_exists='append', index=False) # 若写入后数据未持久化,新增下方提交语句 conn.commit()
该方案适配SQLAlchemy 1.4.x所有版本,pandas会自动识别连接对应的MySQL类型,生成正确的SQL语句。
方案二:升级pandas版本
将pandas升级到1.4.0及以上版本,新版pandas已经完成了SQLAlchemy 1.4+版本的接口适配,你最开始直接传Engine的原始代码即可正常运行,无需修改连接逻辑。
内容的提问来源于stack exchange,提问作者EntzY
相关产品推荐
相关产品推荐

