使用SQLAlchemy执行查询时避免参数绑定

Question

我正在使用SQLALchemy对Teradata执行查询。我执行的查询之一是替换存储过程的DDL语句：

REPLACE PROCEDURE DEV_MIGRATION_TOOL.UNIT_TEST_NEW_STORED_PROCEDURE()
UNIT_TEST_NEW_STORED_PROCEDURE:
BEGIN
    DECLARE V_VAR VARCHAR(50);
    SELECT 'Hello World!'
    INTO :V_VAR;
END;

此SQL语句被分配给变量query,并由SQLALchemy使用会话执行方法执行：

def execute_sql_statement(self, query):
    """Generic method to execute a SQL statement on target environment."""
    self.target_environment.db_session.execute(query)
    self.target_environment.db_session.commit()

问题是SQLAlchemy假设:v_var变量是一个应该随字典一起提供的参数。请参阅以下文档:http://docs.sqlalchemy.org/en/latest/orm/session_api.html#sqlalchemy.orm.session.session.execute

result = session.execute("SELECT * FROM user WHERE id=:param", {"param":5})

在当前配置中,它会触发错误消息：

2018-04-18 19:09:27，874-migration_script-info-UAT环境上执行对象DDL语句。2018-04-18 19:09:27,875-migration_script-ERROR-(SqlAlchemy.exc.InvalidRequesterRror）绑定参数'V_VAR'需要一个值[SQL:“()\runit_test_new_stored_procedure:\rbegin\r声明V_VAR VARCHAR(50)；\r选择'hello world！'\r INTO？；\rend；”][参数：[{}]]

你知道一种方法来避免这个错误信息，这样我上面的DDL语句就可以毫无错误地执行了吗？

Answer 1

session.execute()解释纯SQL字符串，就像在text()构造中传递一样。因此，您必须转义不希望被解释为占位符开头的冒号：

对于需要一个冒号的SQL语句（如在内联字符串中），使用反斜杠转义

因此您的DDL语句query应该是：

"""
REPLACE PROCEDURE DEV_MIGRATION_TOOL.UNIT_TEST_NEW_STORED_PROCEDURE()
UNIT_TEST_NEW_STORED_PROCEDURE:
BEGIN
    DECLARE V_VAR VARCHAR(50);
    SELECT 'Hello World!'
    INTO \\:V_VAR;
END;
"""

^{注意，反斜杠是故意转义的。Python的较新版本将为无效转义序列（如“\:”）生成SyntaxWarning，如果不使用原始字符串文本。}