Python调用MySQL存储过程实践可行

zhgc

范例SP如下，要能处理SP中人select返回，以及OUT和INOUT参数

1. DELIMITER $
   
2. 
   
3. DROP PROCEDURE IF EXISTS `sfc`.`TEST_PY`$
   
4. 
   
5. CREATE PROCEDURE `sfc`.`TEST_PY`(
   
6. IN A INT,
   
7. INOUT B INT,
   
8. OUT C INT
   
9. )
   
10. BEGIN
    
11.   SET B:=A*10+B;
    
12.   SET C:=A*100;
    
13. 
    
14. select a,b,c from dual
    
15. union
    
16. select 1,1,1 from dual;
    
17. 
    
18. END$
    
19. 
    
20. DELIMITER ;

复制代码

Python脚本：

1. import MySQLdb
   
2. 
   
3. db_config = {
   
4.   'host': '192.168.2.10',
   
5.   'user': 'root',
   
6.   'passwd': 'xxxx',
   
7.   'db': 'sfc',
   
8.   'charset': 'utf8'
   
9. }
   
10. 
    
11. conn=MySQLdb.connect(**db_config)
    
12. cursor = conn.cursor()
    
13. 
    
14. # 执行存储过程
    
15. row = cursor.callproc("test_py",(1,2,3))
    
16. print(row)
    
17. # 存储过程的查询结果
    
18. selc = cursor.fetchall()
    
19. print(selc)
    
20. # 获取存储过程返回
    
21. effect_row = cursor.execute('select @_test_py_0, @_test_py_1, @_test_py_2')
    
22. # 取存储过程返回值
    
23. result = cursor.fetchone()
    
24. print(result)
    
25. 
    
26. conn.commit()
    
27. cursor.close()
    
28. conn.close()

复制代码

得到的结果是：
(1, 2, 3)
((1, 12, 100), (1, 1, 1))
(1, 12, 100)

所以结论是：

1.row就显示的参数
2.查返回SP中的查询数据，用cursor.fetchall()
3.得到OUT/INOUT的参数，用@_SPNAME_ParamIndex