Включить выполнение нескольких операторов во время выполнения через sqlalchemy

У меня есть объект DDL (create_function_foo), который содержит инструкцию функции create. В первой строке я положил 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
""")

Где я должен сказать?

Ответы

Ответ 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/[email protected]/msg30129.html

Ответ 2

В некоторых случаях 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))

Ответ 3

Да... Мне это кажется обломом. Я не хочу использовать 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.