Python Polars读取PostgreSQL时WHERE子句参数化查询语法错误

错误原因 #

你使用的:value命名参数格式是SQLAlchemy的语法，但psycopg2（PostgreSQL的Python官方驱动）不支持这种占位符，直接执行会触发语法错误。psycopg2有自己的参数化语法规则。

解决方案 #

方案1：使用位置占位符%s #

将查询语句中的:value替换为%s，参数以元组形式传入：

df = pl.read_database(
    query="SELECT * FROM <schema>.<table name> WHERE col1 = %s",
    execute_options={"parameters": (1,)},
    connection=conn
)

方案2：使用命名占位符%(value)s #

如果需要保留参数的可读性，可采用键值对格式的占位符，参数以字典形式传入：

df = pl.read_database(
    query="SELECT * FROM <schema>.<table name> WHERE col1 = %(value)s",
    execute_options={"parameters": {"value": 1}},
    connection=conn
)

补充说明 #

Polars的read_database在使用非SQLAlchemy连接时，会直接把查询和参数传递给底层数据库驱动，因此必须严格遵循驱动的参数化语法，而非SQLAlchemy的规则。

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