通过sqlalchemy执行时启用执行多个语句

Question

我有一个create_function_foo包含create function语句的DDL对象().在它的第一行我放,DROP FUNCTION IF EXISTS foo;但engine.execute(create_function_foo)返回:

sqlalchemy.exc.InterfaceError: (InterfaceError) Use multi=True when executing multiple statements

我把multi=True作为参数create_engine,engine.execute_options并且engine.execute但它不工作.

注意:engine如果我的实例create_engine

注意:我使用的是python 3.2 + mysql.connector 1.0.12 + sqlalchemy 0.8.2

create_function_foo = DDL("""\
DROP FUNCTION IF EXISTS foo;
CREATE FUNCTION `foo`(
    SID INT
) RETURNS double
READS SQL DATA
BEGIN
  ...
END
""")

我应该把它放在哪里？

Answer 1

multi=True是MySql连接器的要求.您无法设置此标志将其传递给SQLAlchemy方法.做这个:

conn  = session.connection().connection
cursor = conn.cursor()  # get mysql db-api cursor
cursor.execute(sql, multi=True)

更多信息请访问:http://www.mail-archive.com/sqlalchemy@googlegroups.com/msg30129.html

Answer 2

是的...这对我来说似乎很糟糕。我不想使用 ORM，所以接受的答案对我不起作用。

我这样做了：

with open('sql_statements_file.sql') as sql_file:
    for statement in sql_file.read().split(';'):
        if len(statement.strip()) > 0:
             connection.execute(statement + ';')

然后 CREATE 函数失败了...... YMMV。