如何在SQLAlchemy中禁用绑定参数执行Snowflake含JSON的SQL

问题背景 #

执行包含Snowflake JSON路径语法的SQL语句时，SQLAlchemy将:fruit误识别为绑定参数，触发错误：

select parse_json('{"fruit":"banana"}'):fruit

错误信息：

(sqlalchemy.exc.InvalidRequestError) A value is required for bind parameter 'fruit'
[SQL: select parse_json('{"fruit":"banana"}')%(fruit)s]

需求：

• 禁用绑定参数解析，避免:x格式被误判
• 不能用\转义冒号
• 替代connection.execute()的方法需保留编译、转译、事务回滚等核心流程，不能用缺失这些特性的exec_driver_sql()

解决方案 #

1. 用text()对象配合literal_binds参数 #

构造SQL文本时，通过literal_binds=True强制直接传递原始SQL，跳过绑定参数解析，同时保留connection.execute()的事务管理和编译逻辑：

from sqlalchemy import text

# 构造SQL文本，启用literal_binds
sql_stmt = text("select parse_json('{\"fruit\":\"banana\"}'):fruit").bindparams(literal_binds=True)
# 执行查询
result = connection.execute(sql_stmt)

2. 自定义Snowflake方言的绑定参数风格 #

修改SQLAlchemy对Snowflake方言的绑定参数识别规则，改用Snowflake支持的其他绑定格式（如%s或?），让原生:fruit语法正常生效：

from sqlalchemy import create_engine
from sqlalchemy.dialects import registry
from sqlalchemy_snowflake import SnowflakeDialect

# 自定义方言，替换绑定参数风格
class CustomSnowflakeDialect(SnowflakeDialect):
    # 改用pyformat风格（%s）作为绑定参数标识，也可选择"qmark"用?
    bindparam_style = "pyformat"

# 注册自定义方言
registry.register("snowflake.custom", __name__, "CustomSnowflakeDialect")

# 使用自定义方言创建引擎
engine = create_engine("snowflake+custom://<user>:<password>@<account>/<db>/<schema>")

后续绑定参数用%s，Snowflake的JSON路径:fruit不会被误判，同时保留所有事务和编译特性。

3. 通过execution_options临时禁用参数绑定 #

部分SQLAlchemy版本支持执行时临时跳过参数绑定解析，需确认sqlalchemy-snowflake驱动兼容性：

from sqlalchemy import text

sql_stmt = text("select parse_json('{\"fruit\":\"banana\"}'):fruit")
# 执行时禁用参数绑定
result = connection.execute(sql_stmt, execution_options={"skip_parameter_binding": True})

此方法无需修改全局配置，仅对当前查询生效，简洁高效。

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