原文：https://blog.ansheng.me/article/python-full-stack-way-mysql-stored-procedures
存储过程是一个SQL语句集合，当主动去调用存储过程时，其中内部的SQL语句会按照逻辑执行。
存储过程过接收的参数
参数描述
in仅用于传入参数用
out仅用于返回值用
inout既可以传入又可以当作返回值
创建存储过程
创建一个简单的存储过程
-- 修改SQL语句的结束符为%delimiter%-- 创建这个存储过程先删除DROPPROCEDUREIFEXISTSproc_p1%CREATEPROCEDUREproc_p1()-- 开始BEGIN-- SQL语句块select*fromcolor;-- 结束END%-- 把SQL语句的结束符改为;delimiter;
通过call调用存储过程
callproc_p1();
输出为
+-----+--------+| nid | title |+-----+--------+| 1 | red || 2 | yellow |+-----+--------+2 rowsinset(0.00 sec)Query OK, 0 rows affected(0.01 sec)
删除存储过程
DROPPROCEDUREproc_p1;
创建一个存储过程，接收一个参数，传入的参数就是显示数据的个数，
delimiter%DROPPROCEDUREIFEXISTSproc_p1%createPROCEDUREproc_p1(-- i1就是传入的参数，传入的数据类型必须是int类型ini1int)BEGIN-- 定义两个局部变量d1和d2，数据类型都为int，d1默认值为空，d2默认值为1DECLAREd1int;DECLAREd2intDEFAULT1;-- d1的值等于传入过来的i1加上定义的局部变量d2的值SETd1=i1+d2;-- 查找person_info表中的nid大于d1的数据SELECT*FROMperson_infoWHEREnid>d1;END%delimiter;
查询，括号内输入定义的参数
CALL proc_p1(4);
显示结果
+-----+------+------------------+-------------+----------+----------+---------+-----------+| nid | name | email | phone | part_nid | position | caption | color_nid |+-----+------+------------------+-------------+----------+----------+---------+-----------+| 6 | w | as@anshengme.com | 13800138000 | 5 | Python | NULL | NULL || 9 | aa | a@ansheng.me | 13800138000 | 3 | DBA | NULL | 2 || 10 | b | b.ansheng.me | 13800138000 | 3 | DBA | NULL | 1 |+-----+------+------------------+-------------+----------+----------+---------+-----------+3 rowsinset(0.00 sec)Query OK, 0 rows affected(0.01 sec)
这次把nid大于5的数据全部输出出来了，传入的值是4，我们在内部让4+1了，所以就是大于5的数据.
delimiter%DROPPROCEDUREIFEXISTSproc_p1%createPROCEDUREproc_p1(-- 接收了三个参数，类型都是intini1int,inoutiiint,outi2int)BEGIN-- 定义一个局部变量d2，默认值是3，数据类型为intDECLAREd2intDEFAULT3;-- ii = ii + 1setii=ii+1;-- 如果传入的i1等于1IFi1=1THEN-- i2 = 100 + d2seti2=100+d2;-- 如果传入的i1等于2ELSEIFi1=2THEN-- i2 = 200 + d2seti2=200+d2;-- 否则ELSE-- i2 = 1000 + d2seti2=1000+d2;ENDIF;END%delimiter;
查看数据
set@o=5;CALLproc_p1(1,@o,@u);SELECT@o,@u;
显示的结果
+------+------+| @o | @u |+------+------+| 6 | 103 |+------+------+1 rowinset(0.00 sec)
使用pymysql模块操作存储过程
Python代码为：
importpymysqlconn=pymysql.connect(host="127.0.0.1",port=3306,user='root',passwd='as',db="dbname")cursor=conn.cursor(cursor=pymysql.cursors.DictCursor)# 执行存储过程row=cursor.callproc("proc_p2",(1,2,3))# 存储过程的查询结果selc=cursor.fetchall()print(selc)# 获取存储过程返回effect_row=cursor.execute('select @_proc_p2_0, @_proc_p2_1, @_proc_p2_2')# 取存储过程返回值result=cursor.fetchone()print(result)conn.commit()cursor.close()conn.close()
显示的结果
C:\Python\Python35\python.exe D:/PycharmProjects/pymysql_存储过程.py[{'nid': 1,'name':'man1'},{'nid': 2,'name':'man2'},{'nid': 3,'name':'man3'}]{'@_proc_p2_1': 3,'@_proc_p2_0': 1,'@_proc_p2_2': 103}Process finished withexitcode 0
存储过程使用into
into其实就是把一个select的执行结果当作另一个select的参数，例如下面的实例：
delimiter%DROPPROCEDUREIFEXISTSproc_p2%CREATEPROCEDUREproc_p2()BEGIN-- 定义一个局部变量n，类型为intDECLAREnint;-- 获取color_nid = 2的数据并赋值给nSELECTcolor_nidintonFROMperson_infowherecolor_nid=2;-- 输出nid = n的数据SELECT*fromcolorWHEREnid=n;END%delimiter;
执行
call proc_p2();
结果
+-----+--------+| nid | title |+-----+--------+| 2 | yellow |+-----+--------+1 rowinset(0.00 sec)Query OK, 0 rows affected(0.01 sec)
