存储过程是一个SQL语句集合，当主动去调用存储过程时，其中内部的SQL语句会按照逻辑执行。存储过程过接收的参数

参数 描述
in 仅用于传入参数用
out 仅用于返回值用
inout 既可以传入又可以当作返回值

一、创建与删除存储过程

创建一个简单的存储过程

 1-- 修改SQL语句的结束符为%
 2delimiter %
 3-- 创建这个存储过程先删除
 4DROP PROCEDURE IF EXISTS proc_p1 %
 5CREATE PROCEDURE proc_p1()
 6-- 开始
 7BEGIN
 8-- SQL语句块
 9     select * from color;
10-- 结束
11END %
12-- 把SQL语句的结束符改为;
13delimiter ;

通过call调用存储过程

1call proc_p1();

输出为

1+-----+--------+
2| nid | title  |
3+-----+--------+
4|   1 | red    |
5|   2 | yellow |
6+-----+--------+
72 rows in set (0.00 sec)
8Query OK, 0 rows affected (0.01 sec)

删除存储过程

1DROP PROCEDURE proc_p1;

二、存储过程传参

创建一个存储过程，接收一个参数，传入的参数就是显示数据的个数

 1delimiter %
 2DROP PROCEDURE IF EXISTS proc_p1 %
 3create PROCEDURE proc_p1(
 4    -- i1就是传入的参数，传入的数据类型必须是int类型
 5    in i1 int
 6)
 7BEGIN
 8    -- 定义两个局部变量d1和d2，数据类型都为int，d1默认值为空，d2默认值为1
 9    DECLARE d1 int;
10    DECLARE d2 int DEFAULT 1;
11    -- d1的值等于传入过来的i1加上定义的局部变量d2的值
12    SET d1 = i1 + d2;
13    -- 查找person_info表中的nid大于d1的数据
14    SELECT * FROM person_info WHERE nid > d1;
15END %
16delimiter ;

查询，括号内输入定义的参数CALL proc_p1(4);，显示结果

1+-----+------+------------------+-------------+----------+----------+---------+-----------+
2| nid | name | email            | phone       | part_nid | position | caption | color_nid |
3+-----+------+------------------+-------------+----------+----------+---------+-----------+
4|   6 | w    | as@361way.com    | 13800138000 |        5 | Python   | NULL    |      NULL |
5|   9 | aa   | a@361way.com     | 13800138000 |        3 | DBA      | NULL    |         2 |
6|  10 | b    | b@361way.com     | 13800138000 |        3 | DBA      | NULL    |         1 |
7+-----+------+------------------+-------------+----------+----------+---------+-----------+
83 rows in set (0.00 sec)
9Query OK, 0 rows affected (0.01 sec)

这次把nid大于5的数据全部输出出来了，传入的值是4，我们在内部让4+1了，所以就是大于5的数据.

 1delimiter %
 2DROP PROCEDURE IF EXISTS proc_p1 %
 3create PROCEDURE proc_p1(
 4    -- 接收了三个参数，类型都是int
 5    in i1 int,
 6    inout ii int,
 7    out i2 int
 8)
 9BEGIN
10    -- 定义一个局部变量d2，默认值是3，数据类型为int
11    DECLARE d2 int DEFAULT 3;
12    -- ii = ii + 1
13    set ii = ii + 1;
14    -- 如果传入的i1等于1
15    IF i1 = 1 THEN
16        -- i2 = 100 + d2
17        set i2 = 100 + d2;
18    -- 如果传入的i1等于2
19    ELSEIF i1 = 2 THEN
20        -- i2 = 200 + d2
21        set i2 = 200 + d2;
22    -- 否则
23    ELSE
24        -- i2 = 1000 + d2
25        set i2 = 1000 + d2;
26    END IF;
27END %
28delimiter ;

查看数据

1set @o = 5;
2CALL proc_p1(1,@o,@u);
3SELECT @o,@u;

显示的结果

1+------+------+
2| @o   | @u   |
3+------+------+
4|    6 |  103 |
5+------+------+
61 row in set (0.00 sec)

使用pymysql模块操作存储过程，Python代码为：

 1import pymysql
 2conn = pymysql.connect(host="127.0.0.1", port=3306, user='root', passwd='as', db="dbname")
 3cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
 4# 执行存储过程
 5row = cursor.callproc("proc_p2",(1,2,3))
 6# 存储过程的查询结果
 7selc = cursor.fetchall()
 8print(selc)
 9# 获取存储过程返回
10effect_row = cursor.execute('select @_proc_p2_0, @_proc_p2_1, @_proc_p2_2')
11# 取存储过程返回值
12result = cursor.fetchone()
13print(result)
14conn.commit()
15cursor.close()
16conn.close()

显示的结果

1C:\Python\Python35\python.exe D:/PycharmProjects/pymysql_存储过程.py
2[{'nid': 1, 'name': 'man1'}, {'nid': 2, 'name': 'man2'}, {'nid': 3, 'name': 'man3'}]
3{'@_proc_p2_1': 3, '@_proc_p2_0': 1, '@_proc_p2_2': 103}
4Process finished with exit code 0

三、存储过程使用into

into其实就是把一个select的执行结果当作另一个select的参数，例如下面的实例：

 1delimiter %
 2DROP PROCEDURE IF EXISTS proc_p2 %
 3CREATE PROCEDURE proc_p2()
 4BEGIN
 5    -- 定义一个局部变量n，类型为int
 6    DECLARE n int;
 7    -- 获取color_nid = 2的数据并赋值给n
 8    SELECT color_nid into n FROM person_info where color_nid = 2;
 9    -- 输出nid = n的数据
10    SELECT * from color WHERE nid = n;
11END %
12delimiter ;

执行call proc_p2();，结果：

1+-----+--------+
2| nid | title  |
3+-----+--------+
4|   2 | yellow |
5+-----+--------+
61 row in set (0.00 sec)
7Query OK, 0 rows affected (0.01 sec)