• 第五章:存储过程【mysql数据库-进阶】


    1.简介

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

    特点:

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

    2.存储过程语法

    2.1 创建

    【语法】

    CREATE PROCEDURE存储过程名称([参数列表])
    BEGIN
    
    		-- SQL语句
    
    END ;
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6

    【例子】

    create procedure p1()
    begin
        select count(*) from tb_stu;
    end;
    
    • 1
    • 2
    • 3
    • 4

    在DataGrid的左边工具栏就会显示一个routines
    在这里插入图片描述
    注意:在命令行中,执行创建存储过程的SQL时,需要通过关键字delimiter指定SQL语句的结束符
    在这里插入图片描述
    在你执行完毕之后,你就要使用delimiter重新还原。

    2.2 调用

    【语法】

    CALL名称([ 参数]);
    
    • 1

    【例子】

    call p1();
    
    • 1

    2.3 查看

    【语法】

    SELECT* FROM INFORMATION_ SCHEMA.ROUTINES WHERE ROUTINE_ SCHEMA= 'xx'; -- 查询指定数据库的存储过程及状态信息
    SHOW CREATE PROCEDURE存储过程名称: -- 查询某个存储过程的定义
    
    • 1
    • 2

    【例子】

    -- 查看有哪些存储过程
    select * from information_schema.ROUTINES where ROUTINE_SCHEMA='itcast';
    -- 查看存储过程的代码
    show create procedure p1;
    
    • 1
    • 2
    • 3
    • 4

    在这里插入图片描述

    在这里插入图片描述
    还可以双击routines中的存储过程:
    在这里插入图片描述

    2.4 删除

    【语法】

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

    【例子】

    drop procedure p1;
    
    • 1

    3.变量

    3.1 系统变量

    系统变量:是MySQL服务器提供,不是用户定义的,属于服务器层面。分为全局变量(GLOBAL)会话变量(SESSION)

    3.1.1 查看系统变量

    【语法】

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

    【例子】

    -- 查看全部系统变量
    show variables;
    
    • 1
    • 2

    -- 查看会话级的系统变量
    show seesion variables;
    
    • 1
    • 2

    在这里插入图片描述

    -- 查看与自动相关的会话变量
    show session variables like 'auto%';
    -- 查看与自动相关的全局变量
    sow global variables like 'auto%';
    -- 如何已经准确知道了变量名,可以直接查询,不用模糊查询
    -- 比如查询autocommit,自动提交
    select @@session.autocommit
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7

    在这里插入图片描述

    3.1.2 设置系统变量

    【语法】

    SET [ SESSION|GLOBAL ]系统变量名=;
    SET @@[SESSION| GLOBAL]系统变量名=;
    
    • 1
    • 2

    【例子】

    -- 设置自动提交关闭
    set session autocommit =0;
    select @@session.autocommit
    
    • 1
    • 2
    • 3

    此时的查询结果是autocommit已经关闭了:
    在这里插入图片描述

    -- 当我们关闭了提交按钮之后,如果提交sql代码就需要自己commit
    -- 比如我们往数据库中插入一条数据
    insert into tb_stu values(27,18,'jeci');
    commit;
    
    • 1
    • 2
    • 3
    • 4

    如果设置全局的,只要把session改为global

    set global autocommit=0
    • 1

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

    3.2 用户自定义变量

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

    3.2.1 赋值用户自定义变量

    【语法】

    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表名;
    
    • 1
    • 2
    • 3
    • 4

    【例子】

    set @myname='itcast';
    set @myage:='10';
    -- 赋值多个
    set @mygender:='男',@myhobby='java';
    -- 将查询结果赋值
    select count(*) into @mycount from tb_user;
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6

    注意: 用户定义的变量无需对其进行声明或初始化,只不过获取到的值为NULL。

    3.2.2 使用自定义变量

    【语法】

    select @变量名
    
    • 1

    【例子】

    select @myname,@myage,@mygender,@myhobby;
    
    • 1

    在这里插入图片描述

    3.3 局部变量

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

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

    变量类型就是数据库字段类型: INT、BIGINT、CHAR、VARCHAR、 DATE、 TIME等。

    【赋值局部变量】

    SET变量名=;
    SET变量名:=;
    SELECT 字段名INTO变量名FROM表名.
    
    • 1
    • 2
    • 3

    【例子】

    -- 变量: 局部变量
    -- 声明: declare
    create procedure p2()
    begin
        declare stu_count int default 0; -- 声明局部变量
        select count(*) into stu_count from tb_stu;
        select stu_count;
    end;
    
    -- 调用
    call p2();
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11

    4.条件判断语句

    4.1 if条件判断语句

    【介绍】
    if 用于做条件判断,具体的语法结构为:

    IF 条件1 THEN
    .....
    ELSEIF 条件2 THEN -- 可选
    .....
    ELSE -- 可选
    .....
    END IF;
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7

    在if条件判断的结构中,ELSE IF 结构可以有多个,也可以没有。 ELSE结构可以有,也可以没有。

    【举例子】
    例如满足以下需求:
    根据定义的分数score变量,判定当前分数对应的分数等级。

    • score >= 85分,等级为优秀。
    • score >= 60分 且 score < 85分,等级为及格。
    • score < 60分,等级为不及格。
    create procedure p3()
    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 p3();
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15

    上述的需求我们虽然已经实现了,但是也存在一些问题,比如:score 分数我们是在存储过程中定义
    死的,而且最终计算出来的分数等级,我们也仅仅是最终查询展示出来而已。
    那么我们能不能,把score分数动态的传递进来,计算出来的分数等级是否可以作为返回值返回呢?
    答案是肯定的,我们可以通过接下来所讲解的 参数 来解决上述的问题。

    4.2 参数

    参数的类型,主要分为以下三种:IN、OUT、INOUT。 具体的含义如下:

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

    【语法】

    CREATE PROCEDURE 存储过程名称 ([ IN/OUT/INOUT 参数名 参数类型 ])
    BEGIN
    
    		-- SQL语句
    		
    END ;
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6

    【举例】
    案例一:
    根据传入参数score,判定当前分数对应的分数等级,并返回。

    • score >= 85分,等级为优秀。
    • score >= 60分 且 score < 85分,等级为及格。
    • score < 60分,等级为不及格。
    create procedure p4(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;
    
    -- 定义用户变量 @result来接收返回的数据, 用户变量可以不用声明
    call p4(18,@result);
    -- 调用result
    select @result;
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15

    案例二:
    将传入的200分制的分数,进行换算,换算成百分制,然后返回。

    create procedure p5(in score float,out percent float)
    begin
        set percent := score*0.5;
    end;
    
    call p5(68,@percent);
    select @percent;
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7

    4.2 case

    【语法】
    case结构及作用,和我们在基础篇中所讲解的流程控制函数很类似。有两种语法格式:
    语法1:

    -- 含义: 当case_value的值为 when_value1时,执行statement_list1,当值为 when_value2时,
    -- 执行statement_list2, 否则就执行 statement_list
    CASE case_value
    		WHEN when_value1 THEN statement_list1
    		[ WHEN when_value2 THEN statement_list2] ...
    		[ ELSE statement_list ]
    END CASE;
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7

    语法2:

    -- 含义: 当条件search_condition1成立时,执行statement_list1,当条件search_condition2成立时,执行statement_list2, 否则就执行 statement_list
    CASE
    		WHEN search_condition1 THEN statement_list1
    		[WHEN search_condition2 THEN statement_list2] ...
    		[ELSE statement_list]
    END CASE;
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6

    【案例】
    需求:
    根据传入的月份,判定月份所属的季节(要求采用case结构)。

    • 1-3月份,为第一季度
    • 4-6月份,为第二季度
    • 7-9月份,为第三季度
    • 10-12月份,为第四季度
    create procedure p6(in month int, out festerval varchar(10))
    begin
        case
            when month >= 0 and month <= 3 then
                set festerval = '春季';
            when month >= 3 and month <= 6 then
                set festerval = '夏季';
            when month >= 6 and month <= 9 then
                set festerval = '秋季';
            when month >= 9 and month <= 12 then
                set festerval = '冬季';
            else
                set festerval = '非法参数';
    
            end case;
    end;
    
    call p6(8,@festerval);
    select  @festerval;
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19

    注意:如果判定条件有多个,多个条件之间,可以使用 and 或 or 进行连接。

    5.循环语句

    5.1 while

    【介绍】
    while 循环是有条件的循环控制语句。满足条件后,再执行循环体中的SQL语句。具体语法为:

    -- 先判定条件,如果条件为true,则执行逻辑,否则,不执行逻辑
    WHILE 条件 DO
    
    		SQL逻辑...
    		
    END WHILE;
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6

    【案例】
    需求:计算从1累加到n的值,n为传入的参数值。

    create procedure p7(in n int,out result int)
    begin
    
        declare i int default 0;
        set result=0;
        while i<=n do
            set result=result+i;
            set i=i+1;
        end while;
    end;
    
    call p7(5,@result);
    select @result
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13

    5.2 repeat

    【语法】
    repeat是有条件的循环控制语句, 当满足until声明的条件的时候,则退出循环 。具体语法为:

    -- 先执行一次逻辑,然后判定UNTIL条件是否满足,如果满足,则退出。如果不满足,则继续下一次循环
    REPEAT
    		SQL逻辑...
    		UNTIL 条件
    END REPEAT;
    
    • 1
    • 2
    • 3
    • 4
    • 5

    【案例】
    需求:计算从1累加到n的值,n为传入的参数值。(使用repeat实现)

    create procedure p8(in n int, out result int)
    begin
        set result=0;
        repeat
            set result = result + n;
            set n = n - 1;
        until n <= 0 end repeat;
    end;
    
    call p8(5,@result2);
    select @result2;
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11

    5.3 loop

    【语法】
    LOOP 实现简单的循环,如果不在SQL逻辑中增加退出循环的条件,可以用其来实现简单的死循环。
    LOOP可以配合一下两个语句使用:

    • LEAVE :配合循环使用,退出循环。
    • ITERATE:必须用在循环中,作用是跳过当前循环剩下的语句,直接进入下一次循环。
    [begin_label:] LOOP
    SQL逻辑...
    END LOOP [end_label];
    
    • 1
    • 2
    • 3
    LEAVE label; -- 退出指定标记的循环体
    ITERATE label; -- 直接进入下一次循环
    
    • 1
    • 2

    上述语法中出现的 begin_label,end_label,label 指的都是我们所自定义的标记。

    【举例】
    需求1:计算从1累加到n的值,n为传入的参数值。

    create procedure p9(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 sum;
        select total;
    end;
    
    call p9(10)
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15

    需求2:计算从1累加到n的偶数值,n为传入的参数值。

    -- A.定义局部变量, 记录累加之后的值;
    -- B.每循环一次,就会劝进行-1,如果n减到日, 则退出循环 ----> Leave XX
    --  C. 如果当次累加的数据是奇数, 则直接进入下一次循环.---->iterate XX
    create procedure p10(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 sum;
        select  total;
    end;
    
    call p10(10);
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21

    6. 游标

    6.1 基本用法

    加入下面我有一个这样的需求,想在存储过程中将查询的所有记录保存到一个变量中,然后在存储过程中查询这个记录。

    -- 通过变量记录查询结果
    create procedure p11()
    begin
        declare stu_count int default 0;
        select * into stu_count from tb_stu;
        select stu_count;
    end;
    
    call p11();
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9

    在执行call p11()的时候,就会报错[21000][1222] The used SELECT statements have a different number of columns,在存储过程中定义的变量只能接收单行单列的内容,如果要保存结果集就需要使用到游标。

    【语法】
    游标(CURSOR)是用来存储查询结果集的数据类型,在存储过程和函数中可以使用游标对结果集进行循环的处理。游标的使用包括游标的声明、OPEN、FETCH 和CLOSE,其语法分别如下。
    声明游标:

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

    打开游标:

    OPEN 游标名称;
    
    • 1

    获取游标记录:

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

    关闭游标:

    CLOSE游标名称;
    
    • 1

    【例子】
    需求:根据传入的参数uage,来查询用户表tb_ _user中, 所有的用户年龄小于等于uage的用户姓名(name) 和专业(profession) ,并将用户的姓名和专业插入到所创建的一张新表(id,name,profession)中。

    -- 逻辑:
    -- A.声明游标, 存储查询结果集
    -- B.准备:创建表结构
    -- C.开启游标
    -- D.获取游标中的记录
    -- E.插入数据到新表中
    -- F. 关闭游标
    create procedure p12(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 p12(50);
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30

    但是在执行call的时候会报错[02000][1329] No data - zero rows fetched, selected, or processed,这是用while ture是一个死循环,一直没有停止运行;
    虽然报错了,但是数据还是插入成功了:
    在这里插入图片描述

    6.2 条件处理程序

    条件处理程序(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开头的SQL STATE代码的简写
    		SQLEXCEPTION:所有没有被SQLWARNING或NOT FOUND捕获的SQLSTATE代码的简写
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9

    则解决上面的问题,就可以使用这种方法:

    create procedure p12(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;
        -- 声明条件处理程序
        declare exit handler for SQLSTATE '02000' close u_cursor; -- 这条SQL语句的意思就是在SQL状态码是02000的时候,就退出,并且关闭游标;
    
    
        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 p12(30);
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27

    除了上面的SQLSTATE '02000'状态码的形式,也可以写成SQLWARNINGSQLWARNINGNOT FOUNDSQLEXCEPTION几种形式。
    具体可以访问mysql的官方文档:
    https://dev.mysql.com/doc/mysql-errors/8.0/en/server-error-reference.html

  • 相关阅读:
    分布式系统部署Redis
    自用工具类整理
    Kubernetes----基于kubeadm工具在CentOS7.9虚拟机上部署一主两从类型的Kubernetes集群环境
    DDD 项目包结构 + 调用关系说明
    Python3 语法简明教程
    flask-smorest 库
    MongoDB命令
    【51单片机】10-蜂鸣器
    java面试——JVM(内存结构、垃圾回收、内存溢出)
    计算机毕业设计Java的学生社团管理系统的研究设计(源码+系统+mysql数据库+lw文档)
  • 原文地址:https://blog.csdn.net/qq_35653657/article/details/134539242