使用SQLAlchemy与vertica_python执行df.to_sql()时遇SQL无效错误

错误原因 #

你使用engine.raw_connection()获取了原生Vertica连接，但pandas的df.to_sql()无法识别这个原生连接对应的数据库方言，默认采用了SQLite的处理逻辑——生成了SQLite专属的查询语句（如查询sqlite_master），同时用了SQLite风格的?占位符，而Vertica要求使用%s作为占位符，最终触发错误。

解决方案 #

方案1：直接使用SQLAlchemy Engine对象（推荐） #

不要用原生连接，直接将SQLAlchemy创建的engine传给to_sql，pandas会自动适配Vertica的SQL方言：

import sqlalchemy
import pandas as pd

# 创建引擎
engine = sqlalchemy.create_engine('vertica+vertica_python://username:password@localhost:3306/db_name')

# 直接使用engine作为con参数
df.to_sql("df", if_exists="replace", con=engine, schema="schema_name")

方案2：使用SQLAlchemy连接对象而非原生连接 #

如果需要显式管理连接，使用engine.connect()获取SQLAlchemy的连接对象：

import sqlalchemy
import pandas as pd

engine = sqlalchemy.create_engine('vertica+vertica_python://username:password@localhost:3306/db_name')

with engine.connect() as connection:
    df.to_sql("df", if_exists="replace", con=connection, schema="schema_name")

补充说明 #

• 确保vertica_python和SQLAlchemy版本相互兼容，避免因版本不匹配导致方言适配问题。
• 若仍有问题，可尝试安装sqlalchemy-vertica-python包（专门的Vertica SQLAlchemy适配器），它能提供更完善的方言支持。

内容的提问来源于stack exchange，提问作者Tinkinc