使用MySQLdb从Python中获取MySQL存储过程的返回值

我在MySQL数据库中有一个存储过程,它只是更新日期列并返回上一个日期.如果我从MySQL客户端调用这个存储过程,它工作正常,但是当我尝试使用MySQLdb从Python调用存储过程时,我似乎无法让它给我返回值.

这是存储过程的代码:

CREATE PROCEDURE test_stuff.get_lastpoll()
BEGIN
    DECLARE POLLTIME TIMESTAMP DEFAULT NULL;
    START TRANSACTION;

    SELECT poll_date_time
      FROM test_stuff.poll_table
      LIMIT 1 
      INTO POLLTIME
    FOR UPDATE;

    IF POLLTIME IS NULL THEN
        INSERT INTO 
               test_stuff.poll_table 
               (poll_date_time)
        VALUES 
               ( UTC_TIMESTAMP() );

        COMMIT;
        SELECT NULL as POLL_DATE_TIME;
    ELSE
        UPDATE test_stuff.poll_table SET poll_date_time = UTC_TIMESTAMP();
        COMMIT;
        SELECT DATE_FORMAT(POLLTIME, '%Y-%m-%d %H:%i:%s') as POLL_DATE_TIME;
    END IF;
END

我用来尝试调用存储过程的代码与此类似:

#!/usr/bin/python

import sys
import MySQLdb

try:
    mysql = MySQLdb.connect(user=User,passwd=Passwd,db="test_stuff")
    mysql_cursor = mysql.cursor()

    results=mysql_cursor.callproc( "get_lastpoll", () )
    print results

    mysql_cursor.close()
    mysql.close()

except MySQLdb.Error, e:
    print "MySQL Error %d:  %s" % ( e.args[0], e.args[1] )
    sys.exit(1)

我知道你可以做IN和OUT参数,但是我可以从MySQLdb文档中确定,这对MySQLdb来说是不可能的.有没有人知道如何获得存储过程的结果？

如果我从SQL工具运行它,这是输出:

POLL_DATE_TIME       
-------------------  
2009-02-18 22:27:07  

如果我运行Python脚本,它会返回一个空集,如下所示:

()

m0j0.. 11

我要做的是修改Python代码以使用execute()而不是callproc(),然后使用fetchone()来获取结果.我自己回答,因为mluebke的回答并不完全(尽管它很有帮助!).

mysql_cursor.execute( "call get_lastpoll();" )
results=mysql_cursor.fetchone()
print results[0]

这给了我正确的输出:

2009-02-19 17:10:42

有关高级用法等的信息,请参阅/sf/ask/17360801/.fetchonefetchall

我要做的是修改Python代码以使用execute()而不是callproc(),然后使用fetchone()来获取结果.我自己回答,因为mluebke的回答并不完全(尽管它很有帮助!).

mysql_cursor.execute( "call get_lastpoll();" )
results=mysql_cursor.fetchone()
print results[0]

这给了我正确的输出:

2009-02-19 17:10:42

有关高级用法等的信息,请参阅/sf/ask/17360801/.fetchonefetchall

callproc也工作正常,你不需要使用execute:

mysql_cursor.callproc( "get_lastpoll", () )
result = mysql_cursor.fetchone()

您仍然需要获取结果.

results = cursor.fetchone()

要么

results = cursor.fetchall()

请参阅/sf/ask/17360801/