MySQL 5.0 版本开始支持存储过程。
存储过程（Stored Procedure）是一种在数据库中存储复杂程序，以便外部程序调用的一种数据库对象。
存储过程是为了完成特定功能的SQL语句集，经编译创建并保存在数据库中，用户可通过指定存储过程的名字并给定参数(需要时)来调用执行。
存储过程思想上很简单，就是数据库 SQL 语言层面的代码封装与重用。

优点

• 存储过程可封装，并隐藏复杂的商业逻辑。
• 存储过程可以回传值，并可以接受参数。
• 存储过程无法使用 SELECT 指令来运行，因为它是子程序，与查看表，数据表或用户定义函数不同。

• 存储过程可以用在数据检验，强制实行商业逻辑等。

  缺点

• 存储过程，往往定制化于特定的数据库上，因为支持的编程语言不同。当切换到其他厂商的数据库系统时，需要重写原有的存储过程。

• 存储过程的性能调校与撰写，受限于各种数据库系统。

  一、存储过程的创建和调用

• 存储过程就是具有名字的一段代码，用来完成一个特定的功能。

• 创建的存储过程保存在数据库的数据字典中。

1. 创建存储过程 ``` create procedure 名称() begin ……… end

2. 创建简单存储过程示例

create procedure 名称() begin ……… end

3. 调用存储过程

call testa();

<a name="d30St"></a>
## 二、 存储过程的变量
1. 示例

create procedure test2() begin — 使用 declare语句声明一个变量 declare username varchar(32) default ‘’; — 使用set语句给变量赋值 set username=’xiaoxiao’; — 将users表中id=1的名称赋值给username select name into username from users where id=1; — 返回变量 select username; end;

2. 说明
        (1)、变量的声明使用declare,一句declare只声明一个变量，变量必须先声明后使用；<br />        (2)、变量具有数据类型和长度，与mysql的SQL数据类型保持一致，因此甚至还能制定默认值、字符集和排序规则等；<br />        (3)、变量可以通过set来赋值，也可以通过select into的方式赋值；<br />        (4)、变量需要返回，可以使用select语句，如：select 变量名。
<a name="oadIm"></a>
## 三、变量的作用域
    1、变量作用域说明：<br />        (1)、存储过程中变量是有作用域的，作用范围在begin和end块之间，end结束变量的作用范围即结束。<br />        (2)、需要多个块之间传值，可以使用全局变量，即放在所有代码块之前<br />        (3)、传参变量是全局的，可以在多个块之间起作用<br />    2、通过一个实例来验证变量的作用域<br />         需求: 创建一个存储过程，用来统计表users、orders表中行数数量和orders表中的最大金额和最小金额

create procedure test3() begin begin declare userscount int default 0; — 用户表中的数量 declare ordercount int default 0; — 订单表中的数量 select count() into userscount from users; select count() into ordercount from orders; select userscount,ordercount; — 返回用户表中的数量、订单表中的数量 end; begin declare maxmoney int default 0; — 最大金额 declare minmoney int default 0; — 最小金额 select max(money) into maxmoney from orders; select min(money) into minmoney from orders; select maxmoney,minmoney; — 返回最金额、最小金额 end; end;

<a name="Pbg7c"></a>
## 四、存储过程中的参数
MySQL存储过程的参数用在存储过程的定义，共有三种参数类型,IN,OUT,INOUT,形式如：

create procedure 名称([IN|OUT|INOUT] 参数名 参数数据类型 ) begin ……… end

<br />
- IN 输入参数：表示调用者向过程传入值（传入值可以是字面量或变量）,如果不显示指定为in,那么默认就是in类型
- OUT 输出参数：表示过程向调用者传出值(可以返回多个值)（传出值只能是变量）
- INOUT 输入输出参数：既表示调用者向过程传入值，又表示过程向调用者传出值（值只能是变量）
1. 输入参数示例：传入id,根据id返回name

create procedure test4(userId int) begin declare username varchar(32) default ‘’; declare ordercount int default 0; select name into username from users where id=userId; select username; end;

2. 输出参数示例：调用存储过程时，传入userId返回该用户的name

create procedure test5(in userId int,out username varchar(32)) begin select name into username from users where id=userId; end;

3. 输入输出示例：调用存储过程时，传入userId和userName,既是传入参数，也是传出参数

create procedure test6(inout userId int,inout username varchar(32)) begin set userId=2; set username=’’; select id,name into userId,username from users where id=userId; end;

<a name="KeDoN"></a>
# 五、存储过程条件语句
1、基本结构<br />   （1）、条件语句基本结构：

if() then…else…end if;

   （2）、多条件判断语句：

1. if() then…
2. elseif() then…
3. else …
4. end if;

   2、实例<br />    实例1：编写存储过程，如果用户userId是偶数则返回username,否则返回userId

   create procedure test7(in userId int) begin declare username varchar(32) default ‘’; if(userId%2=0) then select name into username from users where id=userId; select username; else select userId; end if; end;

   2、存储过程的多条件语句应用示例<br />        需求：根据用户传入的uid参数判断<br />        （1）、如果用户状态status为1，则给用户score加10分；<br />        （2）、 如果用户状态status为2，则给用户score加20分；<br />        （3）、 其他情况加30分

5. create procedure test8(in userid int)
6. begin
7. declare my_status int default 0;
8. select status into my_status from users where id=userid;
9. if(my_status=1)
10. then
11. update users set score=score+10 where id=userid;
12. elseif(my_status=2)
13. then
14. update users set score=score+20 where id=userid;
15. else
16. update users set score=score+30 where id=userid;
17. end if;
18. end;

    <a name="728nU"></a>
    ## 六、存储过程循环语句
    1、while语句<br />       （1）、while语句的基本结构

19. while(表达式) do
20. ……
21. end while;

          （2）、示例<br />    需求：使用循环语句，向表test1(id)中插入10条连续的记录

22. create procedure test9()
23. begin
24. declare i int default 0;
25. while(i<10) do
26. begin
27. select i;
28. set i=i+1;
29. insert into test1(id) values(i);
30. end;
31. end while;
32. end;

     2、repeat语句<br />    （1）、repeat语句基本的结构：

    repeat…until…end repeat;

     （2）、示例<br />需求：给test1表中的id字段插入数据，从1到10

33. create procedure test10()
34. begin
35. declare i int default 0;
36. repeat
37. begin
38. select i;
39. set i=i+1;
40. insert into test1(id) values(i);
41. end;
42. until i>=10 — 如果i>=10,则跳出循环
43. end repeat;
44. end;

    说明：until判断返回逻辑真或者假，表达式可以是任意返回真或者假的表达式，只有当until语句为真是，循环结束
    <a name="FNDZp"></a>
    ## 七、存储过程游标使用
    1、什么是游标<br />        游标是保存查询结果的临时区域<br />    2、示例<br />    需求：编写存储过程，使用游标，把users表中 id为偶数的记录逐一更新用户名<br />

45. create procedure test11()
46. begin
47. declare stopflag int default 0;
48. declare username VARCHAR(32);
49. — 创建一个游标变量，declare 变量名 cursor …
50. declare username_cur cursor for select name from users where id%2=0;
51. — 游标是保存查询结果的临时区域
52. — 游标变量username_cur保存了查询的临时结果，实际上就是结果集
53. — 当游标变量中保存的结果都查询一遍(遍历),到达结尾，将变量stopflag设置为1，用于循环中判断是否结束
54. declare continue handler for not found set stopflag=1;
56. open username_cur; — 打卡游标
57. fetch username_cur into username; — 游标向前走一步，取出一条记录放到变量username中
58. while(stopflag=0) do — 如果游标还没有结尾，就继续
59. begin
60. — 在用户名前门拼接 ‘_cur’ 字符串
61. update users set name=CONCAT(username,’_cur’) where name=username;
62. fetch username_cur into username;
63. end;
64. end while; — 结束循环
65. close username_cur; — 关闭游标
66. end;

    调用结果如图(19)：
    <a name="3cbev"></a>
    # ![](https://cdn.nlark.com/yuque/0/2020/png/2775479/1607477881113-c54a2764-096e-4d62-8811-1608da8b4f81.png#align=left&display=inline&height=112&margin=%5Bobject%20Object%5D&originHeight=112&originWidth=382&size=0&status=done&style=none&width=382)
                                 图(19)
    <a name="4Nk9A"></a>
    # 八、自定义函数
    函数与存储过程最大的区别是函数必须有返回值，否则会报错<br />    <br />    1、一个简单的函数

67. create function getusername(userid int) returns varchar(32)
68. reads sql data — 从数据库中读取数据，但不修改数据
69. begin
70. declare username varchar(32) default ‘’;
71. select name into username from users where id=userid;
72. return username;
73. end;

    <br />    调用及运行结果如图(20)：<br />![](https://cdn.nlark.com/yuque/0/2020/png/2775479/1607477881118-320f2ad4-1cb7-4b60-8604-eecdcfbf4e88.png#align=left&display=inline&height=144&margin=%5Bobject%20Object%5D&originHeight=144&originWidth=255&size=0&status=done&style=none&width=255)<br />                图(20)<br />    <br />    概括：<br />    1.创建函数使用create function 函数名(参数) returns 返回类型；<br />    2.函数体放在begin和end之间；<br />    3.returns指定函数的返回值；<br />    4.函数调用使用select getusername()。<br />    <br />    2、示例<br />    需求：根据userid，获取accoutid,id,name组合成UUID作为用户的唯一标识

74. create function getuuid(userid int) returns varchar(64)
75. reads sql data — 从数据库中读取数据，但不修改数据
76. begin
77. declare uuid varchar(64) default ‘’;
78. select concat(accontid,’‘,id,’‘,name) into uuid from users where id=userid;
79. return uuid;
80. end;

    调用及运行结果如图(21)<br />![](https://cdn.nlark.com/yuque/0/2020/png/2775479/1607477881116-6a53b15e-71a8-4a5f-a4df-a8ac8ec2d699.png#align=left&display=inline&height=126&margin=%5Bobject%20Object%5D&originHeight=126&originWidth=251&size=0&status=done&style=none&width=251)<br />             图(21)
    <a name="9ewdy"></a>
    #    
    <a name="Pxmeu"></a>
    # 九、触发器
    <a name="XyozA"></a>
    ###     1、什么是触发器
    触发器与函数、存储过程一样，触发器是一种对象，它能根据对表的操作时间，触发一些动作，这些动作可以是insert,update,delete等修改操作。
    <a name="534CX"></a>
    ###     2、示例1
    （1）、需求：出于审计目的，当有人往表users插入一条记录时，把插入的userid,username,插入动作和操作时间记录下来。<br />

81. create trigger tr_users_insert after insert on users
82. for each row
83. begin
84. insert into oplog(userid,username,action,optime)
85. values(NEW.id,NEW.name,’insert’,now());
86. end;

    创建成功后，给uses表中插入一条记录：<br />

87. insert into users(id,name,age,status,score,accontid)
88. values(6,’小周’,23,1,’60’,’10001’)；

    执行成功后，打开oplog表，可以看到oplog表中插入了一条记录如图(22)<br />    ![](https://cdn.nlark.com/yuque/0/2020/jpeg/2775479/1607477882562-85186746-810a-45db-9297-6e0cdd20d137.jpeg#align=left&display=inline&height=95&margin=%5Bobject%20Object%5D&originHeight=95&originWidth=564&size=0&status=done&style=none&width=564)<br />                                                     图(22)<br />  <br />  （2）、总结<br />        1、创建触发器使用create trigger 触发器名<br />        2、什么时候触发？after insert on users,除了after还有before,是在对表操作之前（before）或者之后（after）触发动作的。<br />        3、对什么操作事件触发？ after insert on users,操作事件包括insert,update,delete等修改操作；<br />        4、对什么表触发? after insert on users<br />        5、影响的范围？for each row<br /> 
    <a name="bg5FF"></a>
    ### 3、示例2
    需求：出于审计目的，当删除users表时，记录删除前该记录的主要字段值<br />

89. create trigger tr_users_delete before delete on users
90. for each row
91. begin
92. insert into oplog(userid,username,action,optime)
93. values(OLD.id,OLD.name,’delete’,now());
94. end;

    删除users表中的一条记录<br />

    delete from users where id=6;

    执行成功后，打开oplog表，可以看到oplog表中插入了一条记录如图（23）<br />![](https://cdn.nlark.com/yuque/0/2020/png/2775479/1607477881158-f323c709-503d-42f8-9251-b8a55998aa9c.png#align=left&display=inline&height=167&margin=%5Bobject%20Object%5D&originHeight=167&originWidth=594&size=0&status=done&style=none&width=594)<br />                                              图（23）
    <a name="pCbWM"></a>
    #          
    <a name="fL79N"></a>
    # 十、流程控制
    1、case分支<br />   （1）、基本语法结构

95. case …
96. when … then….
97. when…. then….
98. else …
99. end case;

    （2）、示例<br />users表中，根据userid获取status值，如果status为1，则修改score为10；如果status为2，则修改为20，如果status3，则修改为30；否则修改为40。<br />

100. create procedure testcate(userid int)
101. begin
102. declare my_status int default 0;
103. select status into my_status from users where id=userid;
105. case my_status
106. when 1 then update users set score=10 where id=userid;
107. when 2 then update users set score=20 where id=userid;
108. when 3 then update users set score=30 where id=userid;
109. else update users set score=40 where id=userid;
110. end case;
111. end;

     调用过程 call testcate(1); ，执行结果如图（24）；<br />![](https://cdn.nlark.com/yuque/0/2020/png/2775479/1607477881136-02423ac0-45d0-49cd-b867-dd2e7dfb6649.png#align=left&display=inline&height=201&margin=%5Bobject%20Object%5D&originHeight=201&originWidth=445&size=0&status=done&style=none&width=445)<br />                             图（24）<br /> 
     <a name="Tynps"></a>
     # 十一、存储过程+event（事件）
     1、使用存储过程+事件事件一个简单的实现福彩3D开奖<br />        <br />        需求：设计一个福彩的开奖过程，没3分钟开奖一次<br />            第一步：先编写一个存储过程open_lottery,产生3个随机数，生成一条开奖记录<br />            第二步：编写一个时间调度器，每3分钟调用一次这个过程<br />

112. create procedure open_lottery()
113. begin
114. insert into lottery(num1,num2,num3,ctime)
115. select FLOOR(rand()9)+1,FLOOR(rand()9)+1,FLOOR(rand()*9)+1,now();
116. end; ```

1. create event if not exists lottery_event -- 创建一个事件
2.         on schedule every  3 minute  -- on schedule 什么时候来执行，没三分钟执行一次
3.         on completion preserve 
4.         do call open_lottery;

    运行结果如图(25)<br />        ![](https://cdn.nlark.com/yuque/0/2020/png/2775479/1607477881182-422b74c9-895c-4e96-ab25-1ea8d3409286.png#align=left&display=inline&height=293&margin=%5Bobject%20Object%5D&originHeight=293&originWidth=525&size=0&status=done&style=none&width=525)<br />                                                         图(25)<br />注意，如果event之一没有运行，请按照以下办法解决：<br />（1）、 show variables like '%event_scheduler%';<br />        set global event_scheduler=on;<br />（2）、 alert event lottery_event enable;<br />    2、解析event的创建格式<br />    （1）、基本语法

1. create event[IF NOT EXISTS]event_name -- 创建使用create event
2.     ON SCHEDULE schedule -- on schedule 什么时候来执行
3.     [ON COMPLETION [NOT] PRESERVE] -- 调度计划执行完成后是否还保留
4.     [ENABLE | DISABLE] -- 是否开启事件，默认开启
5.     [COMMENT 'comment'] -- 事件的注释
6.     DO sql_statement; -- 这个调度计划要做什么？

（2）、执行时间说明
1.单次计划任务示例
在2019年2月1日4点执行一次
on schedule at ‘2019-02-01 04:00:00’

2. 重复计划执行
on schedule every 1 second 每秒执行一次
on schedule every 1 minute 每分钟执行一次
on schedule every 1 day 没天执行一次

3.指定时间范围的重复计划任务
每天在20:00:00执行一次
on schedule every 1 day starts ‘2019-02-01 20:00:00’

十五、本文所用到的表

1、lottery表

2、oplog表

3、orders表

4、test1表

5、user表