如何从SqlAlchemy获取已替换参数的原始SQL语句？

使用SQLAlchemy实现 #

要直接获取参数替换后的SQL，可以利用SQLAlchemy语句的compile()方法，结合参数绑定和字面量渲染：

import sqlalchemy as sa

# 定义原始查询
query = """
select some_col from tbl where some_col > :value
"""

# 绑定参数
stmt = sa.text(query).bindparams(value=5)

# 编译语句，生成替换参数后的SQL
compiled_sql = stmt.compile(
    dialect=engine.dialect,  # 传入你创建的engine的方言
    render_postcompile=True,
    compile_kwargs={"literal_binds": True}
)

print(compiled_sql)

运行后会输出：

select some_col from tbl where some_col > 5

注意：literal_binds=True会直接将参数值嵌入SQL，仅用于调试场景，生产环境不要使用，避免SQL注入风险。

使用Psycopg2实现（保留:value语法） #

Psycopg2的cursor.mogrify()方法可以直接生成替换参数后的SQL，且支持命名参数语法：

import psycopg2

# 建立连接
conn = psycopg2.connect("<CONNECTION STRING>")
cur = conn.cursor()

# 原始查询
query = """
select some_col from tbl where some_col > :value
"""

# 生成替换参数后的SQL
mogrified_sql = cur.mogrify(query, {'value': 5}).decode('utf-8')
print(mogrified_sql)

# 关闭资源
cur.close()
conn.close()

该方法会输出参数替换后的完整SQL语句，同样仅建议用于调试。

补充说明 #

你之前设置echo=True无法得到替换参数的SQL，是因为SQLAlchemy的echo日志输出的是参数化查询模板，参数会单独传递给数据库驱动，这是参数化查询的标准机制，目的是防止SQL注入，所以不会直接输出嵌入参数的SQL。

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