20

我有一个create_function_foo包含创建函数语句的 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
""")

我应该把它放在哪里？

4

3 回答 3

25

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

于 2013-11-05T07:08:56.677 回答
5

是的......这对我来说似乎很无赖。我不想使用 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。

于 2019-08-18T02:57:42.697 回答
3

在某些情况下，SQLAlchemy 不提供访问某些DBAPI函数的通用方法，例如处理多个结果集。在这些情况下，您应该直接处理原始 DBAPI 连接。

来自 SQLAlchemy 文档：

connection = engine.raw_connection()
try:
    cursor = connection.cursor()
    cursor.execute("select * from table1; select * from table2")
    results_one = cursor.fetchall()
    cursor.nextset()
    results_two = cursor.fetchall()
    cursor.close()
finally:
    connection.close()

您也可以使用 mysql 连接器执行相同操作，如下所示：

operation = 'SELECT 1; INSERT INTO t1 VALUES (); SELECT 2'
for result in cursor.execute(operation, multi=True):
  if result.with_rows:
    print("Rows produced by statement '{}':".format(
      result.statement))
    print(result.fetchall())
  else:
    print("Number of rows affected by statement '{}': {}".format(
      result.statement, result.rowcount))
于 2018-08-22T00:13:56.243 回答