mysql - 使用 Twisted adbapi 调用 MySQL 存储过程

Question

我正在尝试使用 MySQLdb 接口(interface)从 Twisted adbapi 调用 MySQL 存储过程，但无法使其正常工作。看到mysqldb中有调用存储过程的特殊方式(callproc)，想知道adbapi中有没有特殊的调用方式。

我的存储过程有两个字段 A_PROCEDURE(field1 VARCHAR(20), field2 VARCHAR(25)) 并且我试图以对我来说最明显的方式在我的程序中调用它:dbpool.runOperation("CALL A_PROCEDURE(%s,%s)", arg1, arg2)。这种尝试称为 errback。如果我只是从我的终端连接到数据库来测试它，这个过程就可以正常工作。

Answer 1

您可以使用 runInteraction 来执行任意数据库或特定于适配器的操作，如下所示:

def aProcedure(cursor, arg1, arg2):
    cursor.execute("CALL A_PROCEDURE(%s, %s)", (arg1, arg2))
    return cursor.fetchall()

d = dbpool.runInteraction(aProcedure, arg1, arg2)
...