Permettre l'exécution de plusieurs instructions pendant l'exécution via sqlalchemy

J'ai un DDL objet (create_function_foo) qui contient une instruction create function. En première ligne de j'y ai mis DROP FUNCTION IF EXISTS foo; mais engine.execute(create_function_foo) retourne: 

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

J'ai mis multi=True en tant que paramètre pour create_engine, engine.execute_options et engine.execute mais ça ne fonctionne pas.

NOTE: engine si mon exemple de create_engine

NOTE: je suis à l'aide de python 3.2 + mysql.connecteur 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
""")

Où je dois le mettre?

InformationsquelleAutor Farhadix | 2013-11-05
  1. 10

    multi=True est une exigence pour MySql connector. Vous ne pouvez pas définir cet indicateur en le passant à SQLAlchemy méthodes. Ce faire:

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

    Plus d'infos ici: http://www.mail-archive.com/[email protected]/msg30129.html

    InformationsquelleAutor warvariuc
  2. 0

    Il y a certains cas où SQLAlchemy ne fournit pas de façon générique à l'accès à certains DBAPI fonctions, telles que de traiter avec plusieurs jeux de résultats. Dans ces cas, vous devez traiter le raw DBAPI connexion directement.

    De SQLAlchemy documentation:

    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()

    Vous pouvez également faire la même chose à l'aide de mysql connector comme on le voit ici:

    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))
    InformationsquelleAutor Antony Fuentes Artavia