python访问mysql的存储过程怎么访问

cjaizss

存储过程返回结果集，获得这个结果集，现在写法有异常。
存储结果本身没有问题，mysql里都好用

1. 
   
2. #!/usr/bin/python
   
3. import MySQLdb
   
4. 
   
5. db = MySQLdb.Connect(host='localhost', user='root', passwd='123456', db='test')
   
6. 
   
7. cursor = db.cursor()
   
8. 
   
9. try:
   
10.         args=(2,2000)
    
11.         cursor.callproc("proc3",args) #call proc3(2,2000)
    
12.         print "XX1"
    
13.         for result in cursor.stored_results():
    
14.                 print "XX2";
    
15. except:
    
16.         print "Bad"
    
17. 
    
18. 
    
19. print "TEST"
    
20. db.close()
    

复制代码

运行结果会产生这个异常

1. 
   
2. XX1
   
3. Bad
   
4. TEST
   
5. Exception _mysql_exceptions.OperationalError: (2013, 'Lost connection to MySQL server during query') in <bound method Cursor.__del__ of <MySQLdb.cursors.Cursor object at 0xb6b81f6c>> ignored
   

复制代码

1. 
   
2. create database test;
   
3. use test;
   
4. create table t ( a int, b int);
   
5. insert into t(a,b) values (1,1000);
   
6. insert into t(a,b) values (1,2000);
   
7. insert into t(a,b) values (1,3000);
   
8. insert into t(a,b) values (2,1000);
   
9. insert into t(a,b) values (2,2000);
   
10. insert into t(a,b) values (2,3000);
    
11. insert into t(a,b) values (3,1000);
    
12. insert into t(a,b) values (3,2000);
    
13. insert into t(a,b) values (3,3000);
    
14. delimiter //
    
15. create procedure proc1()
    
16. begin
    
17. select a,b from t;
    
18. end
    
19. //
    
20. create procedure proc2(in a_max int)
    
21. begin
    
22. select a,b from t where a<=a_max;
    
23. end
    
24. //
    
25. create procedure proc3(in a_max int,in b_max int)
    
26. begin
    
27. select a,b from t where a<=a_max and b<=b_max;
    
28. end
    
29. //
    
30. delimiter ;
    

复制代码

lz66

模块用错了，import mysql.connector   才能用cursor.stored_results()

cjaizss

lz66 发表于 2016-08-01 12:14
模块用错了，import mysql.connector   才能用cursor.stored_results()

我回去试试

cjaizss

lz66 发表于 2016-08-01 12:14
模块用错了，import mysql.connector   才能用cursor.stored_results()

我安装不了mysql-connector-python
但我已经安装了MYSQLdb
请问用MYSQLdb如何搞定这个存储过程？

cjaizss

lz66 发表于 2016-08-01 12:14
模块用错了，import mysql.connector   才能用cursor.stored_results()

我还是用MYSQLdb

1. 
   
2. #!/usr/bin/python
   
3. import MySQLdb
   
4. 
   
5. db = MySQLdb.Connect(host='localhost', user='root', passwd='123456', db='test')
   
6. 
   
7. cursor = db.cursor()
   
8. 
   
9. try:
   
10.         sql = "select a,b from t where a<=2 and b<=2000";
    
11.         #sql = "call proc3(2,2000)";
    
12.         cursor.execute(sql)
    
13.         while 1:
    
14.                 data = cursor.fetchall()
    
15.                 if data:
    
16.                         for row in data:
    
17.                                 print "%s %s" % (row[0],row[1])
    
18.                 else:
    
19.                         break
    
20. except:
    
21.         print "Bad"
    
22. 
    
23. 
    
24. print "TEST"
    
25. db.close()
    

复制代码

还是一楼的数据库、存储过程
以上运行结果正常：

1. 
   
2. 1 1000
   
3. 1 2000
   
4. 2 1000
   
5. 2 2000
   
6. TEST
   

复制代码

如果把sql="call proc(2,2000)"
也可以执行
但db.close()为什么就崩溃了呢？

1. 
   
2. 1 1000
   
3. 1 2000
   
4. 2 1000
   
5. 2 2000
   
6. TEST
   
7. Exception _mysql_exceptions.OperationalError: (2013, 'Lost connection to MySQL server during query') in <bound method Cursor.__del__ of <MySQLdb.cursors.Cursor object at 0xb6bbbf4c>> ignored
   

复制代码

完全不懂python,请教这段怎么改?

lz66

我试了下，这样不会报错
cursor.close()
db.close()

lolizeppelin

你的TEST被打印出来了  ....

也就是说  call proc是非阻塞的

然后你关闭了数据库连接

自然就报错了

估计call完  游标还要fetchall一下

楼上的直接关闭游标也可以

cjaizss

lz66 发表于 2016-08-02 10:05
我试了下，这样不会报错
cursor.close()
db.close()

测试了，如果返回一个结果集的确没问题了，cursor.close()一下即可，下次再用再重新cursor=db.cursor()即可
但还有一个问题：如果存储过程返回多个结果集就不行了，以下代码只可以接收到第一个结果集。

1. 
   
2. #!/usr/bin/python
   
3. import MySQLdb
   
4. 
   
5. db = MySQLdb.Connect(host='localhost', user='root', passwd='123456', db='test')
   
6. cursor = db.cursor()
   
7. 
   
8. try:
   
9.         sql = "call proc_ddee33(0)";
   
10.         cursor.execute(sql)
    
11.         while 1:
    
12.                 data = cursor.fetchall()
    
13.                 if data:
    
14.                         for row in data:
    
15.                                 print "%s %s" % (row[0],row[1])
    
16.                 else:
    
17.                         break
    
18. except:
    
19.         print "Bad"
    
20. 
    
21. print "TEST3"
    
22. cursor.close()
    
23. db.close()
    
24. 
    

复制代码

ning_lianjie

用callproc(procname, args) 和 nextset()试试......
官方文档有说明:

Advances the cursor to the next result set, discarding the remaining rows in the current result set. If there are no additional result sets, it returns None; otherwise it returns a true value.

cjaizss

ning_lianjie 发表于 2016-08-03 11:56
用callproc(procname, args) 和 nextset()试试......
官方文档有说明:

终于完全明白了，这才是关键。
不需要cursor.close()

1. 
   
2. #!/usr/bin/python
   
3. import MySQLdb
   
4. 
   
5. db = MySQLdb.Connect(host='localhost', user='root', passwd='123456', db='test')
   
6. cursor = db.cursor()
   
7. 
   
8. try:
   
9.         sql = "call proc_ddee33(0)";
   
10.         cursor.execute(sql)
    
11.         while 1:
    
12.                 data = cursor.fetchall()
    
13.                 if data:
    
14.                         for row in data:
    
15.                                 print "%s %s" % (row[0],row[1])
    
16.                 else:
    
17.                         break
    
18.                 cursor.nextset(); #要加这句
    
19. except:
    
20.         print "Bad"
    
21. 
    
22. print "TEST3"
    
23. #cursor.close()
    
24. db.close()
    

复制代码