使用SQLAlchemy+oracledb从Oracle读取数据至Pandas的参数传递报错问题

原本使用pyodbc连接Oracle数据库并将查询结果读取至Pandas DataFrame的代码如下：

connect_string = f"DSN={config.DB};UID={credentials['UID']};PWD={credentials['pwd']};DBQ={config.DB_server};DBA=W;APA=T;EXC=F;FEN=T;QTO=F;FRC=10;FDL=10;LOB=T;BTD=F;BNF=F;TABLE={config.table}"
select_string = f"SELECT * FROM {config.table} WHERE Foo LIKE '{config.bar}%'"
connection = pyodbc.connect(connect_string)
data = pd.read_sql(select_string, connection)

运行后收到警告：

UserWarning: pandas only supports SQLAlchemy connectable...

尝试改用SQLAlchemy搭配oracledb，并通过ConnectParams传递原连接参数：

cp = oracledb.ConnectParams(dba="W", apa="T", exc="F", fen="T", qto="F", frc=10, fdl=10, lob="T", btd="F", bnf="F", table=config.table)

却触发错误：

TypeError: ConnectParams.__init__() got an unexpected keyword argument 'dba'

需要解决如何正确传递这些原连接参数的问题。

核心原因 #

oracledb.ConnectParams是原生Oracle驱动的参数配置类，不支持pyodbc连接字符串中的ODBC专属参数（如DBA、APA等）。这些参数是ODBC驱动的特定配置，需转换为原生驱动对应参数，或换用SQLAlchemy+pyodbc的组合来保留原有配置。

方法1：使用SQLAlchemy + 原生oracledb驱动 #

将原ODBC参数转换为oracledb原生参数，通过SQLAlchemy的connect_args传递：

from sqlalchemy import create_engine
import oracledb
import pandas as pd

# 构建SQLAlchemy连接URL（格式：oracle+oracledb://用户名:密码@主机/服务名）
db_url = f"oracle+oracledb://{credentials['UID']}:{credentials['pwd']}@{config.DB_server}/?service_name={config.DB}"

# 转换原ODBC参数为原生oracledb对应配置
connect_args = {
    # DBA=W 对应SYSDBA认证模式
    "mode": oracledb.AUTH_MODE_SYSDBA,
    # FEN=T 对应启用事件通知
    "events": True,
    # LOB=T 相关配置：预取LOB数据，按需调整大小
    "lob_prefetch_size": 1024 * 1024,
    # 其他参数若有原生对应项，按官方文档转换，无对应项可忽略或通过URL query传递
}

# 创建SQLAlchemy引擎
engine = create_engine(db_url, connect_args=connect_args)

# 安全的参数化查询（避免SQL注入）
query = "SELECT * FROM {} WHERE Foo LIKE :bar".format(config.table)
data = pd.read_sql(query, engine, params={"bar": f"{config.bar}%"})

方法2：保留ODBC方式（SQLAlchemy + pyodbc） #

若不想切换原生驱动，可直接用SQLAlchemy包装原pyodbc连接字符串，消除Pandas警告：

from sqlalchemy import create_engine
import pandas as pd

# 复用原pyodbc连接字符串
connect_string = f"DSN={config.DB};UID={credentials['UID']};PWD={credentials['pwd']};DBQ={config.DB_server};DBA=W;APA=T;EXC=F;FEN=T;QTO=F;FRC=10;FDL=10;LOB=T;BTD=F;BNF=F;TABLE={config.table}"
# 构建SQLAlchemy的pyodbc连接URL
db_url = f"oracle+pyodbc:///?odbc_connect={connect_string}"

engine = create_engine(db_url)

# 参数化查询替代字符串拼接
query = "SELECT * FROM {} WHERE Foo LIKE :bar".format(config.table)
data = pd.read_sql(query, engine, params={"bar": f"{config.bar}%"})

重要提示 #

• 避免使用字符串拼接生成SQL语句，改用参数化查询（params参数）杜绝SQL注入风险。
• 原生oracledb的参数与ODBC参数并非一一对应，需参考官方文档调整配置，部分ODBC专属参数在原生驱动中可能无需配置或有替代方案。

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