Chinaunix

标题: python访问mysql的存储过程怎么访问 [打印本页]
作者: cjaizss    时间: 2016-07-31 18:03
标题: python访问mysql的存储过程怎么访问
存储过程返回结果集，获得这个结果集，现在写法有异常。
存储结果本身没有问题，mysql里都好用

  2. #!/usr/bin/python
  3. import MySQLdb

  5. db = MySQLdb.Connect(host='localhost', user='root', passwd='123456', db='test')

  7. cursor = db.cursor()

  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"


  19. print "TEST"
  20. db.close()
复制代码
运行结果会产生这个异常

  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
复制代码

  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    时间: 2016-08-01 12:14
模块用错了，import mysql.connector   才能用cursor.stored_results()
作者: cjaizss    时间: 2016-08-01 14:20
lz66 发表于 2016-08-01 12:14
模块用错了，import mysql.connector   才能用cursor.stored_results()

我回去试试
作者: cjaizss    时间: 2016-08-01 21:40
lz66 发表于 2016-08-01 12:14
模块用错了，import mysql.connector   才能用cursor.stored_results()

我安装不了mysql-connector-python
但我已经安装了MYSQLdb
请问用MYSQLdb如何搞定这个存储过程？
作者: cjaizss    时间: 2016-08-01 22:18
lz66 发表于 2016-08-01 12:14
模块用错了，import mysql.connector   才能用cursor.stored_results()

我还是用MYSQLdb

  2. #!/usr/bin/python
  3. import MySQLdb

  5. db = MySQLdb.Connect(host='localhost', user='root', passwd='123456', db='test')

  7. cursor = db.cursor()

  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"


  24. print "TEST"
  25. db.close()
复制代码
还是一楼的数据库、存储过程
以上运行结果正常：

  2. 1 1000
  3. 1 2000
  4. 2 1000
  5. 2 2000
  6. TEST
复制代码
如果把sql="call proc(2,2000)"
也可以执行
但db.close()为什么就崩溃了呢？

  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    时间: 2016-08-02 10:05
我试了下，这样不会报错
cursor.close()
db.close()
作者: lolizeppelin    时间: 2016-08-02 10:18
本帖最后由 lolizeppelin 于 2016-08-02 10:21 编辑

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

也就是说  call proc是非阻塞的

然后你关闭了数据库连接

自然就报错了

估计call完  游标还要fetchall一下

楼上的直接关闭游标也可以
作者: cjaizss    时间: 2016-08-02 20:17
lz66 发表于 2016-08-02 10:05
我试了下，这样不会报错
cursor.close()
db.close()

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

  2. #!/usr/bin/python
  3. import MySQLdb

  5. db = MySQLdb.Connect(host='localhost', user='root', passwd='123456', db='test')
  6. cursor = db.cursor()

  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"

  21. print "TEST3"
  22. cursor.close()
  23. db.close()

复制代码
作者: ning_lianjie    时间: 2016-08-03 11:56
用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    时间: 2016-08-03 19:13
ning_lianjie 发表于 2016-08-03 11:56
用callproc(procname, args) 和 nextset()试试......
官方文档有说明:

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

  2. #!/usr/bin/python
  3. import MySQLdb

  5. db = MySQLdb.Connect(host='localhost', user='root', passwd='123456', db='test')
  6. cursor = db.cursor()

  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"

  22. print "TEST3"
  23. #cursor.close()
  24. db.close()
复制代码
作者: lolizeppelin    时间: 2016-09-05 16:55
学习了原来 fetchall不能返回所有的 结果级



欢迎光临 Chinaunix (http://bbs.chinaunix.net/) Powered by Discuz! X3.2