3828 字
19 分钟
MySQL06-存储过程
2023-06-04
2023-12-07
数据库
MySQL

详细的描述了MySQL中的存储过程。

存储过程介绍#

简介#

  • 存储过程是事先经过编译并存储在数据库中的一段SQL语句的集合，调用存储过程可以简化应用开发人员的很多工作，减少数据在数据库和应用服务器之间的传输，对于提高数据处理的效率是有好处的。
  • 存储过程思想上很简单，就是数据库SQL语言层面的代码封装与重用。

特点#

  • 封装，复用
  • 可以接收参数，也可以返回数据
  • 减少网络交互，效率提升

存储过程语法#

创建#

CREATE PROCEDURE 存储过程名称([参数列表])
BEGIN
  ...SQL语句
END;

调用#

CALL 名称([参数]);

查看#

SELECT * FROM INFORMATION_SCHEMA.ROUTINES WHERE ROUINE_SQHEMA = 'xxx';  --查询指定数据库的存储过程及状态信息
SHOW CREATE PROCEDURE 存储过程名称; --查询某个存储过程的定义

删除#

DROP PROCEDURE [IF EXISTS] 存储过程名称;

注意#

注意：在命令行中，执行创建存储过程的SQL时，需要通过关键字 delimiter 指定SQL语句的结束符。

可以设置为两个$$符号

Terminal window
delimiter $$

变量#

系统变量#

系统变量是MySQL服务器提供，不是用户定义的，属于服务器层面。分为全局变量（GLOBAL）、会话变量（SESSION）

查看系统变量#

SHOW [SESSION|GLOBAL] VARIABLES; --查看所有系统变量
SHOW [SESSION|GLOBAL] VARIABLES LIKE ...; --可以通过LIKE模糊匹配方式查找变量
SELECT @@[SESSION|GLOBAL] 系统变量名; --查看指定变量的值

设置系统变量#

SET [SESSION|GLOBAL] 系统变量名 = 值;
SET @@[SESSION|GLOBAL] 系统变量名 = 值;

注意:

  • 如果没有指定SESSION/GLOBAL，默认是SESSION，会话变量。
  • mysql服务重新启动之后，所设置的全局参数会失效，要想不失效，可以在/etc/my.cnf 中配置。

用户定义变量#

用户定义变量是用户根据需要自己定义的变量，用户变量不用提前声明，在用的时候直接用“@变量名”使用就可以。其作用域为当前连接即当前会话。

赋值#

SET @var_name = expr [,@var_name = expr] ...;
SET @var_name := expr [,@var_name := expr] ...;
SELECT @var_name := expr [, @var_name := expr]... ;
SELECT 字段名 INTO @var_name FROM 表名;

使用#

SELECT @var_name;

注意：

  • 在MySQL中， = 既可以作为赋值，也可以作为比较，因此在赋值时建议使用 :=
  • 用户定义的变量无需对其进行声明或初始化，只不过获取到的值为NULL.

局部变量#

局部变量是根据需要定义的在局部生效的变量，访问之前，需要DECLARE声明。可用作存储过程内的局部变量和输入参数，局部变量的范围是在其内声明的BEGIN….END块。

声明#

DECLARE 变量名变量类型 [DEFAULT ...];

赋值#

SET 变量名 = 值;
SET 变量名 := 值;
SELECT 字段名 INTO 变量名 FROM 表名 ...;

存储过程#

存储过程 - if 判断#

语法#

IF 条件1 THEN
  ...
ELSE IF 条件2 THEN --可选
  ...
ELSE --可选
  ...
END IF;

无参数的存储过程样例#

-- 判定分数对应的分数等级。
-- score >= 85分，等级为优秀。
-- score >= 60分且score < 85分，等级为及格。
-- score < 60分，等级为不及格。
create procedure p1()
begin
    declare score int default 58;
    declare result varchar(10);
    if score >= 85 then
        set result := '优秀';
    elseif score >= 60 then
        set result := '及格';
    else
        set result := '不及格';
    end if;
    select result;
end;


call p1();

运行结果：

此例中，局部变量 score 初始为 58，既不满足优秀分支，也不满足及格分支，因此进入最后的分支，将 result 设为“不及格”。过程末尾的 SELECT result 返回这一等级文本；这是根据分支与初值推导的含义，不涉及用户表中的数据。

参数#

类型含义备注
IN该类参数作为输入，也就是需要调用时传入值默认
OUT该类参数作为输出,也就是该参数可以作为返回值/
INOUT既可以作为输入参数,也可以作为输出参数/

语法#

CREATE PROCEDURE 存储过程名称 ([IN / OUT / INOUT 参数名 参数类型])
BEGIN
  --SQL语句
END;

有参数的存储过程样例#

-- 根据传入(in)参数score，判定当前分数对应的分数等级，并返回(out)。
-- score >= 85分，等级为优秀。
-- score >= 60分且score < 85分，等级为及格。
-- score < 60分，等级为不及格。
create procedure p1(in score int, out result varchar(10))
begin
    if score >= 85 then
        set result := '优秀';
    elseif score >= 60 then
        set result := '及格';
    else
        set result := '不及格';
    end if;
end;


call p1(68, @result);
select @result;

运行结果：

此例中，传入的分数为 68，未达到优秀阈值，但满足及格条件，因此输出参数 result 被赋为“及格”。调用结束后，输出值写入当前会话变量 @result，随后 SELECT @result 读取该等级；不要把输出参数与过程内部直接返回结果集混为一谈。

-- 将传入的 200分制的分数,进行换算,换算成百分制，然后返阿分数---> inout
create procedure p2(inout score double)
begin
    set score := score * 0.5;
end;


set @score = 163;
call p2(@score);
select @score;

运行结果：

此例中，@score 先设为 163，再作为输入输出参数传给过程。过程把分数乘以 0.5，按算术可得 81.5，并将新值写回同一个会话变量。随后的 SELECT @score 读取换算后的百分制分数，体现输入输出参数既接收值又带回修改值的作用。

存储过程 - Case#

语法一#

CASE case_value
  WHEN when_value1 THEN statement_list1
  [WHEN when_value2 THEN statement_Kist 2] ...
  [ELSE statement_list]
END CASE;

语法二#

CASE
  WHEN search_condition1 THEN statement_list1
  [WHEN search_condition2 THEN statement_list2] ...
  [ELSE statemept tlist]
END CASE;

样例#

-- 根据传入的月份，判定月份所属的季节（要求采用case结构)。
-- 1.1-3月份,为第一季度
-- 2.4-6月份，为第二季度
-- 3.7-9月份，为第三季度
-- 4.10-12月份，为第四季度
create procedure p3(in month int)
begin
    declare result varchar(10);


    case
        when month >= 1 and month <= 3
            then set result := '第一季度';
        when month >= 4 and month <= 6
            then set result := '第二季度';
        when month >= 7 and month <= 9
            then set result := '第三季度';
        when month >= 10 and month <= 12
            then set result := '第四季度';
        else
            set result := '非法参数';
    end case;
    select concat('您输入的月份为', month, '所属的季度为', result);
end;


call p3(4)

运行结果：

此例中，月份参数为 4，命中四月至六月的分支，因而将结果设为“第二季度”。末尾的字符串拼接表达式会形成“您输入的月份为4所属的季度为第二季度”。这里实际判断的是季度而不是气象季节；其余合法月份按各自区间分类，区间之外进入非法参数分支。

存储过程循环 - while#

while循环是有条件的循环控制语句。满足条件后，再执行循环体中的SQL语句。

语法#

#先判定条件，如果条件为true，则执行逻辑，否则，不执行逻辑
WHILE 条件 DO
  SQL逻辑...
END WHILE;

样例#

-- 计算从1紧加到的值，n为传入的参数值。
-- 1. 定义局部变量，记录累加后的值
-- 2. 每新环一次,就会n进行减1,如果n减到0，则退出循环
create procedure p4(in n int)
begin
    declare total int default 0;
    while n > 0 do
        set total := total + n;
        set n := n - 1;
    end while;
    select total;
end;


call p4(10);

运行结果：

此例中，初始参数为 10、累计值为零，循环逐次把当前参数加入累计值，再将参数减一，直到退出。因此，从十累加到一可推导出 total = 55，末尾的 SELECT total 读取该累计值。这一输入下，先判断的循环、后判断的循环以及显式退出的循环可得到相同总和，但退出条件的检查位置不同。

存储过程循环 - repeat#

repeat是有条件的循环控制语句，当满足条件的时候退出循环。

语法#

#先执行一次逻辑，然后判定逻辑是否满足，如果满足，则退出。如果不满足，则继续下一次循环
REPEAT
  SQL逻辑 ...
  UNTIL 条件
END REPEAT;

样例#

-- 计算从1紧加到的值，n为传入的参数值。
-- 1. 定义局部变量，记录累加后的值
-- 2. 每新环一次,就会n进行减1,如果n减到0，则退出循环
create procedure p5(in n int)
begin
    declare total int default 0;
    repeat
        set total := total + n;
        set n := n - 1;
    until n <= 0
    end repeat;
    select total;
end;


call p5(10);

运行结果：

此例中，初始参数为 10、累计值为零，循环逐次把当前参数加入累计值，再将参数减一，直到退出。因此，从十累加到一可推导出 total = 55，末尾的 SELECT total 读取该累计值。这一输入下，先判断的循环、后判断的循环以及显式退出的循环可得到相同总和，但退出条件的检查位置不同。

存储过程循环 - loop#

LOOP实现简单的循环，如果不在SQL逻辑中增加退出循环的条件，可以用其来实现简单的死循环。

OOP可以配合一下两个语句使用**

  • LEAVE：配合循环使用，退出循环。
  • ITERATE：必须用在循环中，作用是跳过当前循环剩下的语句，直接进入下一次循环。

语法#

[begin_label:] LOOP
  SQL逻辑 ...
END LOOP [end_label];
LEAVE label; --退出指定标记的循环体
ITERATE label; --直接进入下一次循环

样例1#

-- 计算从1紧加到的值,n为传入的参数值。
-- 1. 定义局部变量,记录累加后的值
-- 2. 每新环一次,就会n进行减1,如果n减到0，则退出循环   ---> leave xxx;
create procedure p6(in n int)
begin
    declare total int default 0;
    sum : loop
        if n <= 0 then
            leave sum;
        end if;


        set total := total + n;
        set n := n - 1;
    end loop;
    select total;
end;


call p6(10);

运行结果：

此例中，初始参数为 10、累计值为零，循环逐次把当前参数加入累计值，再将参数减一，直到退出。因此，从十累加到一可推导出 total = 55，末尾的 SELECT total 读取该累计值。这一输入下，先判断的循环、后判断的循环以及显式退出的循环可得到相同总和，但退出条件的检查位置不同。

样例2#

-- 计算从1到n之问的偶数累加的值，n为传入的参数值。
-- 1．定义局部变量，记录累加之后的值;
-- 2．每循环一次，就会对n进行-1，如果n减到0，则退出循环   ---> leave xxx
-- 3．如果当次累加的数据是奇数，则直接进入下一次循环   ---> iterate xxx
create procedure p7(in n int)
begin
    declare total int default 0;
    sum : loop
        if n <= 0 then
            leave sum;
        end if;


        if n % 2 = 1 then
            set n := n - 1;
            iterate sum;
        end if;


        set total := total + n;
        set n := n - 1;
    end loop;
    select total;
end;


call p7(10);

运行结果：

此例中，p7(10) 只累加十以内的正偶数。遇到奇数时，先把参数减一，再通过 ITERATE 跳过本轮余下语句；偶数则加入累计值。因而十、八、六、四、二之和为 30，最后的 SELECT total 读取该值；当参数降到零时，由 LEAVE 退出循环。

游标 - Cursor#

游标（CURSOR）是用来存储查询结果集的数据类型，在存储过程和函数中可以使用游标对结果集进行循环的处理。

游标的使用包括游标的声明、OPEN、FETCH 和 CLOSE，其语法分别如下。

语法：#

声明游标#

DECLARE 游标名称 CURSOR FOR 查询语句;

打开游标#

OPEN 游标名称;

获取游标记录#

FETCH 游标名称 INTO 变量[变量];

关闭游标#

CLOSE 游标名称;

样例#

-- 游标
-- 根据传入的参数uage，来查询用户表tb_user中，所有的用户年龄小于等于uage的用户姓名(name)和专业（profession)，
-- 并将用户的姓名和专业插入到所创建的一张新表(id,name,profession)中


-- 逻辑
-- 1. 声明游标，存储查询到的结果集
-- 2. 准备：创建表结构
-- 3. 开启游标
-- 4， 获取游标中的记录
-- 5. 将记录插入到新的表中
-- 6. 关闭游标
create procedure p8(in uage int)
begin
    declare uname varchar(100);
    declare upro varchar(100);
    declare u_cursor cursor for select name, profession from tb_user where age <= uage;


    drop table if exists tb_user_pro;
    create table if not exists tb_user_pro(
        id int primary key auto_increment,
        name varchar(100),
        profession varchar(100)
    );


    open u_cursor;


    while true do
        fetch u_cursor into uname, upro;
        insert into tb_user_pro values (null, uname, upro);
    end while;


    close u_cursor;


end;


call p8(30);

注意while的循环退出条件为true，即死循环，产生如下bug

此例中，游标读取年龄不大于三十的用户姓名和专业，但 WHILE TRUE 本身没有退出条件。结果集耗尽后，下一次 FETCH 会触发 NOT FOUND 条件（SQLSTATE '02000'）。按 MySQL 的处理器规则，正常产生的 NOT FOUND 在没有处理器时默认执行 CONTINUE，而不是 EXIT，所以过程不会自动退出控制流：它会继续执行后面的 INSERT，再次进入循环并执行下一次 FETCH。要结束循环，必须在过程中显式处理耗尽，例如像后面的改进例那样用退出型处理器捕获该条件并关闭游标；实际插入次数和最终表内容取决于运行时的游标与表状态，不能仅凭这段代码确定。

注意

  • 普通变量的声明先与游标
  • 循环中如何得知循环结束的条件？即游标什么时候遍历完？

条件处理程序#

条件处理程序（Handler）可以用来定义在流程控制结构执行过程中遇到问题时相应的处理步骤。

语法#

DECLARE handler_action HANDLER FOR condition_value [,condition_value] ... statement;


handler_action
  cONTINUE:继续执行当前程序
  EXIT:终止执行当前程序
condition_value
  SQLSTATE:sqlstate_value:状态码，如02000
  SQLWARNING:所有以01开头的SQLSTATE代码的简写
  NOT FOUND:所有以02开头的SQLSTATE代码的简写
  SQLEXCEPTION:所有没有被SQLWARNING 或 NOT FOUND捕获的SQLSTATE代码的简写

样例(改进了循环退出判断条件)#

-- 游标
-- 根据传入的参数uage，来查询用户表tb_user中，所有的用户年龄小于等于uage的用户姓名(name)和专业（profession)，
-- 并将用户的姓名和专业插入到所创建的一张新表(id,name,profession)中


-- 逻辑
-- 1. 声明游标，存储查询到的结果集
-- 2. 准备：创建表结构
-- 3. 开启游标
-- 4， 获取游标中的记录
-- 5. 将记录插入到新的表中
-- 6. 关闭游标
create procedure p8(in uage int)
begin
    declare uname varchar(100);
    declare upro varchar(100);
    declare u_cursor cursor for select name, profession from tb_user where age <= uage;


    -- 声明条件处理程序，当状态码为 02000 时关闭游标
    -- 也可以写为 declare exit handler for not found close u_cursor;
    declare exit handler for sqlstate '02000' close u_cursor;


    drop table if exists tb_user_pro;
    create table if not exists tb_user_pro(
        id int primary key auto_increment,
        name varchar(100),
        profession varchar(100)
    );


    open u_cursor;


    while true do
        fetch u_cursor into uname, upro;
        insert into tb_user_pro values (null, uname, upro);
    end while;


    close u_cursor;


end;


call p8(30);

具体的详细的官方解释的状态码如下

MySQL官网文档状态码解释

MySQL08-触发器
HTML5+CSS301-HTML
© 2026 Wang-nine. All Rights Reserved. / RSS / Sitemap
Powered by Astro & Fuwari