• MySQL【变量、流程控制与游标】


    目录

    一、变量

    1.系统变量 

    查看系统变量

    查询全局系统变量

    查询会话系统变量 

    查询部分系统变量

    查看指定系统变量

    修改系统变量的值

    2.用户变量

    用户变量分类

    会话用户变量 

    局部变量

    练习

    二、定义条件与处理程序

    定义条件

    定义处理程序

    三、流程控制

    分支结构 IF 

    分支结构 case

    循环结构loop

    循环结构while

    循环结构repeat

    对比三种循环结构:

    跳转语句leave 

    跳转语句ITERATE 

    四、游标

    全局变量的持久化 


    一、变量

    在MySQL数据库的存储过程和函数中,可以使用变量来存储查询或计算的中间结果数据,或者输出最终的结果数据。
    在 MySQL 数据库中,变量分为 系统变量 以及 用户自定义变量 。

    1.系统变量 

    变量由系统定义,不是用户定义,属于 服务器 层面。启动MySQL服务,生成MySQL服务实例期间,MySQL将为MySQL服务器内存中的系统变量赋值,这些系统变量定义了当前MySQL服务实例的属性、特征。这些系统变量的值要么是 编译MySQL时参数 的默认值,要么是 配置文件 (例如my.ini等)中的参数值。大家可以通过网址 https://dev.mysql.com/doc/refman/8.0/en/server-systemvariables.html 查看MySQL文档的系统变量。


    系统变量分为全局系统变量(需要添加 global 关键字)以及会话系统变量(需要添加 session 关键字),有时也把全局系统变量简称为全局变量,有时也把会话系统变量称为local变量。如果不写,默认会话级别。静态变量(在 MySQL 服务实例运行期间它们的值不能使用 set 动态修改)属于特殊的全局系统变量。


    每一个MySQL客户机成功连接MySQL服务器后,都会产生与之对应的会话。会话期间,MySQL服务实例会在MySQL服务器内存中生成与该会话对应的会话系统变量,这些会话系统变量的初始值是全局系统变量值的复制。

    全局系统变量针对于所有会话(连接)有效,但 不能跨重启会话系统变量仅针对于当前会话(连接)有效。会话期间,当前会话对某个会话系统变量值的修改,不会影响其他会话同一个会话系统变量的值。


    会话1对某个全局系统变量值的修改会导致会话2中同一个全局系统变量值的修改。


    在MySQL中有些系统变量只能是全局的,例如 max_connections 用于限制服务器的最大连接数;有些系统变量作用域既可以是全局又可以是会话,例如 character_set_client 用于设置客户端的字符集;有些系统变量的作用域只能是当前会话,例如 pseudo_thread_id 用于标记当前会话的 MySQL 连接 ID。

    查看系统变量

    查询全局系统变量

    1. #查询全局系统变量
    2. SHOW GLOBAL VARIABLES; #627

    查询会话系统变量 

    1. #查询会话系统变量
    2. SHOW SESSION VARIABLES; #650

     

    SHOW VARIABLES; #默认查询的是会话系统变量

    查询部分系统变量

    1. #查询部分系统变量
    2. SHOW GLOBAL VARIABLES LIKE 'admin_%';

     

    SHOW VARIABLES LIKE 'character_%';

    查看指定系统变量

    作为 MySQL 编码规范,MySQL 中的系统变量以 两个“@” 开头,其中“@@global”仅用于标记全局系统变量,“@@session”仅用于标记会话系统变量。“@@”首先标记会话系统变量,如果会话系统变量不存在,则标记全局系统变量。

    1. # 查看指定系统变量
    2. SELECT @@global.max_connections;

    SELECT @@global.character_set_client;

     session和global不能搞错了,如果搞错了全局系统变量和会话系统变量就会报错。

    1. #错误:
    2. SELECT @@global.pseudo_thread_id;

    1. #错误:
    2. SELECT @@session.max_connections;

    SELECT @@session.pseudo_thread_id;

    如果不指明是会话系统变量还是全局系统变量的话,默认先查询会话系统变量,后查询全局系统变量。 

    SELECT @@session.character_set_client;

    SELECT @@character_set_client; #先查询会话系统变量,再查询全局系统变量

    修改系统变量的值

    方式1:修改MySQL 配置文件 ,继而修改MySQL系统变量的值(该方法需要重启MySQL服务)
    方式2:在MySQL服务运行期间,使用“set”命令重新设置系统变量的值

    1. #全局系统变量:
    2. #方式1
    3. SET @@global.max_connections = 161;

    1. #方式2
    2. SET GLOBAL max_connections = 171;

    #针对于当前的数据库实例是有效的,一旦重启mysql服务,就失效了。
    1. #会话系统变量:
    2. #方式1
    3. SET @@session.character_set_client = 'gbk';
    4. #方式2
    5. SET SESSION character_set_client = 'gbk';

    #针对于当前会话是有效的,一旦结束会话,重新建立起新的会话,就失效了。

    2.用户变量

    用户变量分类

    用户变量是用户自己定义的,作为 MySQL 编码规范,MySQL 中的用户变量以 一个“@” 开头。根据作用范围不同,又分为 会话用户变量 局部变量
    会话用户变量:作用域和会话变量一样,只对 当前连接 会话有效。
    局部变量:只在 BEGIN 和 END 语句块中有效。局部变量只能在 存储过程和函数 中使用。

    会话用户变量 

    1. ① 变量的声明和赋值:
    2. #方式1:“=”或“:=
    3. SET @用户变量 = 值;
    4. SET @用户变量 := 值;
    5. #方式2:“:=” 或 INTO关键字
    6. SELECT @用户变量 := 表达式 [FROM 等子句];
    7. SELECT 表达式 INTO @用户变量 [FROM 等子句];
    8. ② 使用
    9. SELECT @变量名
    1. #测试:
    2. #方式1
    3. SET @m1 = 1;
    4. SET @m2 := 2;
    5. SET @sum := @m1 + @m2;
    6. SELECT @sum;

    1. #方式2
    2. SELECT @count := COUNT(*) FROM employees;

    SELECT @count;

    1. SELECT AVG(salary) INTO @avg_sal FROM employees;
    2. SELECT @avg_sal;

     

    局部变量

    1. 1、局部变量必须满足:
    2. ① 使用DECLARE声明
    3. ② 声明并使用在BEGIN ... END 中 (使用在存储过程、函数中)
    4. DECLARE的方式声明的局部变量必须声明在BEGIN中的首行的位置。
    5. 2、声明格式:
    6. DECLARE 变量名 类型 [default 值]; # 如果没有DEFAULT子句,初始值为NULL
    7. 3、赋值:
    8. 方式1
    9. SET 变量名=值;
    10. SET 变量名:=值;
    11. 方式2
    12. SELECT 字段名或表达式 INTO 变量名 FROM 表;
    13. 4、使用
    14. SELECT 局部变量名;
    1. #举例:
    2. DELIMITER //
    3. CREATE PROCEDURE test_var()
    4. BEGIN
    5. #1、声明局部变量
    6. DECLARE a INT DEFAULT 0;
    7. DECLARE b INT ;
    8. #可以合并在一起定义
    9. #DECLARE a,b INT DEFAULT 0;
    10. DECLARE emp_name VARCHAR(25);
    11. #2、赋值
    12. #这两种方式都行
    13. SET a = 1;
    14. SET b := 2;
    15. SELECT last_name INTO emp_name FROM employees WHERE employee_id = 101;
    16. #3、使用
    17. SELECT a,b,emp_name;
    18. END //
    19. DELIMITER ;
    20. #调用存储过程
    21. CALL test_var();

    练习

    1. #举例1:声明局部变量,并分别赋值为employees表中employee_id为102的last_name和salary
    2. DELIMITER //
    3. CREATE PROCEDURE test_pro()
    4. BEGIN
    5. #声明
    6. DECLARE emp_name VARCHAR(25);
    7. DECLARE sal DOUBLE(10,2) DEFAULT 0.0;
    8. #赋值
    9. SELECT last_name,salary INTO emp_name,sal
    10. FROM employees
    11. WHERE employee_id = 102;
    12. #使用
    13. SELECT emp_name,sal;
    14. END //
    15. DELIMITER ;
    16. #调用存储过程
    17. CALL test_pro();

    1. #举例2:声明两个变量,求和并打印 (分别使用会话用户变量、局部变量的方式实现)
    2. #方式1:使用会话用户变量
    3. #加不加冒号都可以的
    4. SET @v1 = 10;
    5. SET @v2 := 20;
    6. SET @result := @v1 + @v2;
    7. #查看
    8. SELECT @result;

    1. #方式2:使用局部变量
    2. DELIMITER //
    3. CREATE PROCEDURE add_value()
    4. BEGIN
    5. #声明
    6. DECLARE value1,value2,sum_val INT;
    7. #赋值
    8. SET value1 = 10;
    9. SET value2 := 100;
    10. SET sum_val = value1 + value2;
    11. #使用
    12. SELECT sum_val;
    13. END //
    14. DELIMITER ;
    15. #调用存储过程
    16. CALL add_value();

     

    1. #举例3:创建存储过程“different_salary”查询某员工和他领导的薪资差距,并用IN参数emp_id接收员工id,
    2. #用OUT参数dif_salary输出薪资差距结果。
    3. DELIMITER //
    4. CREATE PROCEDURE different_salary(IN emp_id INT,OUT dif_salary DOUBLE)
    5. BEGIN
    6. #分析:查询出emp_id员工的工资;查询出emp_id员工的管理者的id;查询管理者id的工资;计算两个工资的差值
    7. #声明变量
    8. DECLARE emp_sal DOUBLE DEFAULT 0.0; #记录员工的工资
    9. DECLARE mgr_sal DOUBLE DEFAULT 0.0; #记录管理者的工资
    10. DECLARE mgr_id INT DEFAULT 0; #记录管理者的id
    11. #赋值
    12. SELECT salary INTO emp_sal FROM employees WHERE employee_id = emp_id;
    13. SELECT manager_id INTO mgr_id FROM employees WHERE employee_id = emp_id;
    14. SELECT salary INTO mgr_sal FROM employees WHERE employee_id = mgr_id;
    15. SET dif_salary = mgr_sal - emp_sal;
    16. END //
    17. DELIMITER ;
    18. #调用存储过程
    19. SET @emp_id := 103;
    20. SET @dif_sal := 0;
    21. CALL different_salary(@emp_id,@dif_sal);
    22. SELECT @dif_sal;

     

    二、定义条件与处理程序

    定义条件 是事先定义程序执行过程中可能遇到的问题, 处理程序 定义了在遇到问题时应当采取的处理方式,并且保证存储过程或函数在遇到警告或错误时能继续执行。这样可以增强存储程序处理问题的能力,避免程序异常停止运行。
    说明:定义条件和处理程序在存储过程、存储函数中都是支持的。

    1. #2.1 错误演示:
    2. #错误代码: 1364
    3. #Field 'email' doesn't have a default value
    4. INSERT INTO employees(last_name)
    5. VALUES('Tom');

    出现如下的措施是因为我们设定的employees的email是不允许为空值的,而我们不传入email的数据,MySQL默认又是空值。 

     

    1. #错误演示:
    2. DELIMITER //
    3. CREATE PROCEDURE UpdateDataNoCondition()
    4. BEGIN
    5. SET @x = 1;
    6. UPDATE employees SET email = NULL WHERE last_name = 'Abel';
    7. SET @x = 2;
    8. UPDATE employees SET email = 'aabbel' WHERE last_name = 'Abel';
    9. SET @x = 3;
    10. END //
    11. DELIMITER ;
    12. #调用存储过程
    13. #错误代码: 1048
    14. #Column 'email' cannot be null
    15. CALL UpdateDataNoCondition();

    这里的错误原因和上面相同 

     

    SELECT @x;

    可以看到我们的x再等于1之后的代码就没有继续运行下去。 

    定义条件

    定义条件就是给MySQL中的错误码命名,这有助于存储的程序代码更清晰。它将一个 错误名字 和 指定的错误条件 关联起来。这个名字可以随后被用在定义处理程序的 DECLARE HANDLER 语句中。
    定义条件使用DECLARE语句,语法格式如下:

    DECLARE 错误名称 CONDITION FOR 错误码(或错误条件)

    错误码的说明:
    MySQL_error_code 和 sqlstate_value 都可以表示MySQL的错误。
    MySQL_error_code是数值类型错误代码。
    sqlstate_value是长度为5的字符串类型错误代码。
            例如,在ERROR 1418 (HY000)中,1418是MySQL_error_code,'HY000'是sqlstate_value。
            例如,在ERROR 1142(42000)中,1142是MySQL_error_code,'42000'是sqlstate_value。

    1. #举例1:定义“Field_Not_Be_NULL”错误名与MySQL中违反非空约束的错误类型
    2. #是“ERROR 1048 (23000)”对应。
    3. #方式1:使用MySQL_error_code
    4. DECLARE Field_Not_Be_NULL CONDITION FOR 1048;
    5. #方式2:使用sqlstate_value
    6. DECLARE Field_Not_Be_NULL CONDITION FOR SQLSTATE '23000';
    7. #举例2:定义"ERROR 1148(42000)"错误,名称为command_not_allowed。
    8. #方式1:使用MySQL_error_code
    9. DECLARE command_not_allowed CONDITION FOR 1148;
    10. #方式2:使用sqlstate_value
    11. DECLARE command_not_allowed CONDITION FOR SQLSTATE '42000';

    定义处理程序

    可以为SQL执行过程中发生的某种类型的错误定义特殊的处理程序。定义处理程序时,使用DECLARE语句的语法如下:

    DECLARE 处理方式 HANDLER FOR 错误类型 处理语句

    处理方式:处理方式有3个取值:CONTINUE、EXIT、UNDO。
            CONTINUE :表示遇到错误不处理,继续执行。
            EXIT :表示遇到错误马上退出。
            UNDO :表示遇到错误后撤回之前的操作。MySQL中暂时不支持这样的操作。
    错误类型(即条件)可以有如下取值:
            SQLSTATE '字符串错误码' :表示长度为5的sqlstate_value类型的错误代码;
            MySQL_error_code :匹配数值类型错误代码;
            错误名称 :表示DECLARE ... CONDITION定义的错误条件名称。
            SQLWARNING :匹配所有以01开头的SQLSTATE错误代码;
            NOT FOUND :匹配所有以02开头的SQLSTATE错误代码;
            SQLEXCEPTION :匹配所有没有被SQLWARNING或NOT FOUND捕获的SQLSTATE错误代码;


    处理语句:如果出现上述条件之一,则采用对应的处理方式,并执行指定的处理语句。语句可以是像“ SET 变量 = 值 ”这样的简单语句,也可以是使用 BEGIN ... END 编写的复合语句

    1. #2.3 定义处理程序
    2. #格式:DECLARE 处理方式 HANDLER FOR 错误类型 处理语句
    3. #举例:
    4. #方法1:捕获sqlstate_value
    5. DECLARE CONTINUE HANDLER FOR SQLSTATE '42S02' SET @info = 'NO_SUCH_TABLE';
    6. #方法2:捕获mysql_error_value
    7. DECLARE CONTINUE HANDLER FOR 1146 SET @info = 'NO_SUCH_TABLE';
    8. #方法3:先定义条件,再调用
    9. DECLARE no_such_table CONDITION FOR 1146;
    10. DECLARE CONTINUE HANDLER FOR no_such_table SET @info = 'NO_SUCH_TABLE';
    11. #方法4:使用SQLWARNING
    12. DECLARE EXIT HANDLER FOR SQLWARNING SET @info = 'ERROR';
    13. #方法5:使用NOT FOUND
    14. DECLARE EXIT HANDLER FOR NOT FOUND SET @info = 'NO_SUCH_TABLE';
    15. #方法6:使用SQLEXCEPTION
    16. DECLARE EXIT HANDLER FOR SQLEXCEPTION SET @info = 'ERROR';
    1. DROP PROCEDURE UpdateDataNoCondition;
    2. #重新定义存储过程,体现错误的处理程序
    3. DELIMITER //
    4. CREATE PROCEDURE UpdateDataNoCondition()
    5. BEGIN
    6. #声明处理程序
    7. #处理方式1
    8. DECLARE CONTINUE HANDLER FOR 1048 SET @prc_value = -1;
    9. #处理方式2
    10. #DECLARE CONTINUE HANDLER FOR sqlstate '23000' SET @prc_value = -1;
    11. SET @x = 1;
    12. UPDATE employees SET email = NULL WHERE last_name = 'Abel';
    13. SET @x = 2;
    14. UPDATE employees SET email = 'aabbel' WHERE last_name = 'Abel';
    15. SET @x = 3;
    16. END //
    17. DELIMITER ;
    18. #调用存储过程:
    19. CALL UpdateDataNoCondition();
    20. #查看变量:
    21. SELECT @x,@prc_value;

     如下是这张表的结构

    1. # 定义存储过程:
    2. DELIMITER //
    3. CREATE PROCEDURE InsertDataWithCondition()
    4. BEGIN
    5. SET @x = 1;
    6. INSERT INTO departments(department_name) VALUES('测试');
    7. SET @x = 2;
    8. INSERT INTO departments(department_name) VALUES('测试');
    9. SET @x = 3;
    10. END //
    11. DELIMITER ;
    12. # 调用
    13. CALL InsertDataWithCondition();
    SELECT @x;  #2

     因为我们前面的代码设置的department_id应该是不能重复的,但是我们传入了重复的数据,所以报错了。

    我们可以根据这个错误码来进行下面的程序编写 

    1. # 删除此存储过程
    2. DROP PROCEDURE IF EXISTS InsertDataWithCondition;
    3. # 重新定义存储过程(考虑到错误的处理程序)
    4. DELIMITER //
    5. CREATE PROCEDURE InsertDataWithCondition()
    6. BEGIN
    7. #处理程序
    8. #方式1
    9. #declare exit handler for 1062 set @pro_value = -1;
    10. #方式2
    11. #declare exit handler for sqlstate '23000' set @pro_value = -1;
    12. #方式3
    13. #定义条件
    14. DECLARE duplicate_entry CONDITION FOR 1062;
    15. DECLARE EXIT HANDLER FOR duplicate_entry SET @pro_value = -1;
    16. SET @x = 1;
    17. INSERT INTO departments(department_name) VALUES('测试');
    18. SET @x = 2;
    19. INSERT INTO departments(department_name) VALUES('测试');
    20. SET @x = 3;
    21. END //
    22. DELIMITER ;
    23. #调用
    24. CALL InsertDataWithCondition();
    25. SELECT @x,@pro_value;

    三、流程控制

    解决复杂问题不可能通过一个 SQL 语句完成,我们需要执行多个 SQL 操作。流程控制语句的作用就是控制存储过程中 SQL 语句的执行顺序,是我们完成复杂操作必不可少的一部分。只要是执行的程序,流程就分为三大类:
            顺序结构 :程序从上往下依次执行
            分支结构 :程序按条件进行选择执行,从两条或多条路径中选择一条执行
            循环结构 :程序满足一定条件下,重复执行一组语句
    针对于MySQL 的流程控制语句主要有 3 类。注意:只能用于存储程序。
            条件判断语句 :IF 语句和 CASE 语句
            循环语句 :LOOP、WHILE 和 REPEAT 语句
            跳转语句 :ITERATE 和 LEAVE 语句

    分支结构 IF 

    1. IF 表达式1 THEN 操作1
    2. [ELSEIF 表达式2 THEN 操作2]……
    3. [ELSE 操作N]
    4. END IF

    根据表达式的结果为TRUE或FALSE执行相应的语句。这里“[]”中的内容是可选的。
    特点:① 不同的表达式对应不同的操作 ② 使用在begin end中

    1. DELIMITER //
    2. CREATE PROCEDURE test_if()
    3. BEGIN
    4. #情况1
    5. #声明局部变量
    6. declare stu_name varchar(15);
    7. if stu_name is null
    8. then select 'stu_name is null';
    9. end if;
    10. END //
    11. DELIMITER ;
    12. #调用
    13. CALL test_if();

     

    1. DELIMITER //
    2. CREATE PROCEDURE test_if()
    3. BEGIN
    4. #情况2:二选一
    5. declare email varchar(25) default 'aaa';
    6. if email is null
    7. then select 'email is null';
    8. else
    9. select 'email is not null';
    10. end if;
    11. END //
    12. DELIMITER ;
    13. #调用
    14. CALL test_if();

    1. DELIMITER //
    2. CREATE PROCEDURE test_if()
    3. BEGIN
    4. #情况3:多选一
    5. DECLARE age INT DEFAULT 20;
    6. IF age > 40
    7. THEN SELECT '中老年';
    8. ELSEIF age > 18
    9. THEN SELECT '青壮年';
    10. ELSEIF age > 8
    11. THEN SELECT '青少年';
    12. ELSE
    13. SELECT '婴幼儿';
    14. END IF;
    15. END //
    16. DELIMITER ;
    17. #调用
    18. CALL test_if();

    1. #举例2:声明存储过程“update_salary_by_eid1”,定义IN参数emp_id,输入员工编号。
    2. #判断该员工薪资如果低于8000元并且入职时间超过5年,就涨薪500元;否则就不变。
    3. DELIMITER //
    4. CREATE PROCEDURE update_salary_by_eid1(IN emp_id INT)
    5. BEGIN
    6. #声明局部变量
    7. DECLARE emp_sal DOUBLE; #记录员工的工资
    8. DECLARE hire_year DOUBLE; #记录员工入职公司的年头
    9. #赋值
    10. SELECT salary INTO emp_sal FROM employees WHERE employee_id = emp_id;
    11. SELECT DATEDIFF(CURDATE(),hire_date)/365 INTO hire_year FROM employees WHERE employee_id = emp_id;
    12. #判断
    13. IF emp_sal < 8000 AND hire_year >= 5
    14. THEN UPDATE employees SET salary = salary + 500 WHERE employee_id = emp_id;
    15. END IF;
    16. END //
    17. DELIMITER ;
    18. #调用存储过程
    19. CALL update_salary_by_eid1(104);
    20. SELECT DATEDIFF(CURDATE(),hire_date)/365, employee_id,salary
    21. FROM employees
    22. WHERE salary < 8000 AND DATEDIFF(CURDATE(),hire_date)/365 >= 5;

    1. #举例3:声明存储过程“update_salary_by_eid2”,定义IN参数emp_id,输入员工编号。
    2. #判断该员工薪资如果低于9000元并且入职时间超过5年,就涨薪500元;否则就涨薪100元。
    3. DELIMITER //
    4. CREATE PROCEDURE update_salary_by_eid2(IN emp_id INT)
    5. BEGIN
    6. #声明局部变量
    7. DECLARE emp_sal DOUBLE; #记录员工的工资
    8. DECLARE hire_year DOUBLE; #记录员工入职公司的年头
    9. #赋值
    10. SELECT salary INTO emp_sal FROM employees WHERE employee_id = emp_id;
    11. SELECT DATEDIFF(CURDATE(),hire_date)/365 INTO hire_year FROM employees WHERE employee_id = emp_id;
    12. #判断
    13. IF emp_sal < 9000 AND hire_year >= 5
    14. THEN UPDATE employees SET salary = salary + 500 WHERE employee_id = emp_id;
    15. ELSE
    16. UPDATE employees SET salary = salary + 100 WHERE employee_id = emp_id;
    17. END IF;
    18. END //
    19. DELIMITER ;
    20. #调用
    21. CALL update_salary_by_eid2(103);
    22. CALL update_salary_by_eid2(104);
    23. SELECT * FROM employees
    24. WHERE employee_id IN (103,104);

    1. #举例4:声明存储过程“update_salary_by_eid3”,定义IN参数emp_id,输入员工编号。
    2. #判断该员工薪资如果低于9000元,就更新薪资为9000元;薪资如果大于等于9000元且
    3. #低于10000的,但是奖金比例为NULL的,就更新奖金比例为0.01;其他的涨薪100元。
    4. DELIMITER //
    5. CREATE PROCEDURE update_salary_by_eid3(IN emp_id INT)
    6. BEGIN
    7. #声明变量
    8. DECLARE emp_sal DOUBLE; #记录员工工资
    9. DECLARE bonus DOUBLE; #记录员工的奖金率
    10. #赋值
    11. SELECT salary INTO emp_sal FROM employees WHERE employee_id = emp_id;
    12. SELECT commission_pct INTO bonus FROM employees WHERE employee_id = emp_id;
    13. #判断
    14. IF emp_sal < 9000
    15. THEN UPDATE employees SET salary = 9000 WHERE employee_id = emp_id;
    16. ELSEIF emp_sal < 10000 AND bonus IS NULL
    17. THEN UPDATE employees SET commission_pct = 0.01 WHERE employee_id = emp_id;
    18. ELSE
    19. UPDATE employees SET salary = salary + 100 WHERE employee_id = emp_id;
    20. END IF;
    21. END //
    22. DELIMITER ;
    23. #调用
    24. CALL update_salary_by_eid3(102);
    25. CALL update_salary_by_eid3(103);
    26. CALL update_salary_by_eid3(104);
    27. SELECT *
    28. FROM employees
    29. WHERE employee_id IN (102,103,104);

    分支结构 case

    CASE 语句的语法结构1:

    1. #情况一:类似于switch
    2. CASE 表达式
    3. WHEN1 THEN 结果1或语句1(如果是语句,需要加分号)
    4. WHEN2 THEN 结果2或语句2(如果是语句,需要加分号)
    5. ...
    6. ELSE 结果n或语句n(如果是语句,需要加分号)
    7. END [case](如果是放在begin end中需要加上case,如果放在select后面不需要)

    CASE 语句的语法结构2:

    1. #情况二:类似于多重if
    2. CASE
    3. WHEN 条件1 THEN 结果1或语句1(如果是语句,需要加分号)
    4. WHEN 条件2 THEN 结果2或语句2(如果是语句,需要加分号)
    5. ...
    6. ELSE 结果n或语句n(如果是语句,需要加分号)
    7. END [case](如果是放在begin end中需要加上case,如果放在select后面不需要)
    1. DELIMITER //
    2. CREATE PROCEDURE test_case()
    3. BEGIN
    4. #演示1case ... when ...then ...
    5. declare var int default 2;
    6. case var
    7. when 1 then select 'var = 1';
    8. when 2 then select 'var = 2';
    9. when 3 then select 'var = 3';
    10. else select 'other value';
    11. end case;
    12. END //
    13. DELIMITER ;
    14. #调用
    15. CALL test_case();

    1. #举例1:基本使用
    2. DELIMITER //
    3. CREATE PROCEDURE test_case()
    4. BEGIN
    5. #演示2case when ... then ....
    6. DECLARE var1 INT DEFAULT 10;
    7. CASE
    8. WHEN var1 >= 100 THEN SELECT '三位数';
    9. WHEN var1 >= 10 THEN SELECT '两位数';
    10. ELSE SELECT '个数位';
    11. END CASE;
    12. END //
    13. DELIMITER ;
    14. #调用
    15. CALL test_case();

     

    1. #举例2:声明存储过程“update_salary_by_eid4”,定义IN参数emp_id,输入员工编号。
    2. #判断该员工薪资如果低于9000元,就更新薪资为9000元;薪资大于等于9000元且低于10000的,
    3. #但是奖金比例为NULL的,就更新奖金比例为0.01;其他的涨薪100元。
    4. DELIMITER //
    5. CREATE PROCEDURE update_salary_by_eid4(IN emp_id INT)
    6. BEGIN
    7. #局部变量的声明
    8. DECLARE emp_sal DOUBLE; #记录员工的工资
    9. DECLARE bonus DOUBLE; #记录员工的奖金率
    10. #局部变量的赋值
    11. SELECT salary INTO emp_sal FROM employees WHERE employee_id = emp_id;
    12. SELECT commission_pct INTO bonus FROM employees WHERE employee_id = emp_id;
    13. CASE
    14. WHEN emp_sal < 9000 THEN UPDATE employees SET salary = 9000 WHERE employee_id = emp_id;
    15. WHEN emp_sal < 10000 AND bonus IS NULL THEN UPDATE employees SET commission_pct = 0.01
    16. WHERE employee_id = emp_id;
    17. ELSE UPDATE employees SET salary = salary + 100 WHERE employee_id = emp_id;
    18. END CASE;
    19. END //
    20. DELIMITER ;
    21. #调用
    22. CALL update_salary_by_eid4(103);
    23. CALL update_salary_by_eid4(104);
    24. CALL update_salary_by_eid4(105);
    25. SELECT *
    26. FROM employees
    27. WHERE employee_id IN (103,104,105);

    1. #举例3:声明存储过程update_salary_by_eid5,定义IN参数emp_id,输入员工编号。
    2. #判断该员工的入职年限,如果是0年,薪资涨50;如果是1年,薪资涨100
    3. #如果是2年,薪资涨200;如果是3年,薪资涨300;如果是4年,薪资涨400;其他的涨薪500
    4. DELIMITER //
    5. CREATE PROCEDURE update_salary_by_eid5(IN emp_id INT)
    6. BEGIN
    7. #声明局部变量
    8. DECLARE hire_year INT; #记录员工入职公司的总时间(单位:年)
    9. #赋值
    10. SELECT ROUND(DATEDIFF(CURDATE(),hire_date) / 365) INTO hire_year
    11. FROM employees WHERE employee_id = emp_id;
    12. #判断
    13. CASE hire_year
    14. WHEN 0 THEN UPDATE employees SET salary = salary + 50 WHERE employee_id = emp_id;
    15. WHEN 1 THEN UPDATE employees SET salary = salary + 100 WHERE employee_id = emp_id;
    16. WHEN 2 THEN UPDATE employees SET salary = salary + 200 WHERE employee_id = emp_id;
    17. WHEN 3 THEN UPDATE employees SET salary = salary + 300 WHERE employee_id = emp_id;
    18. WHEN 4 THEN UPDATE employees SET salary = salary + 400 WHERE employee_id = emp_id;
    19. ELSE UPDATE employees SET salary = salary + 500 WHERE employee_id = emp_id;
    20. END CASE;
    21. END //
    22. DELIMITER ;
    23. #调用
    24. CALL update_salary_by_eid5(101);
    25. SELECT *
    26. FROM employees;

    循环结构loop

    LOOP循环语句用来重复执行某些语句。LOOP内的语句一直重复执行直到循环被退出(使用LEAVE子句),跳出循环过程。
    LOOP语句的基本格式如下:

    1. [loop_label:] LOOP
    2. 循环执行的语句
    3. END LOOP [loop_label]

     其中,loop_label表示LOOP语句的标注名称,该参数可以省略。

    1. #举例1
    2. DELIMITER //
    3. CREATE PROCEDURE test_loop()
    4. BEGIN
    5. #声明局部变量
    6. DECLARE num INT DEFAULT 1;
    7. #使用标签指明循环结构
    8. loop_label:LOOP
    9. #重新赋值
    10. SET num = num + 1;
    11. #可以考虑某个代码程序反复执行。(略)
    12. IF num >= 10 THEN LEAVE loop_label;
    13. END IF;
    14. END LOOP loop_label;
    15. #查看num
    16. SELECT num;
    17. END //
    18. DELIMITER ;
    19. #调用
    20. CALL test_loop();

     

     

    1. #举例2:当市场环境变好时,公司为了奖励大家,决定给大家涨工资。
    2. #声明存储过程“update_salary_loop()”,声明OUT参数num,输出循环次数。
    3. #存储过程中实现循环给大家涨薪,薪资涨为原来的1.1倍。直到全公司的平
    4. #均薪资达到12000结束。并统计循环次数。
    5. DELIMITER //
    6. CREATE PROCEDURE update_salary_loop(OUT num INT)
    7. BEGIN
    8. #声明变量
    9. DECLARE avg_sal DOUBLE ; #记录员工的平均工资
    10. DECLARE loop_count INT DEFAULT 0;#记录循环的次数
    11. #① 初始化条件
    12. #获取员工的平均工资
    13. SELECT AVG(salary) INTO avg_sal FROM employees;
    14. loop_lab:LOOP
    15. #② 循环条件
    16. #结束循环的条件
    17. IF avg_sal >= 12000
    18. THEN LEAVE loop_lab;
    19. END IF;
    20. #③ 循环体
    21. #如果低于12000,更新员工的工资
    22. UPDATE employees SET salary = salary * 1.1;
    23. #④ 迭代条件
    24. #更新avg_sal变量的值
    25. SELECT AVG(salary) INTO avg_sal FROM employees;
    26. #记录循环次数
    27. SET loop_count = loop_count + 1;
    28. END LOOP loop_lab;
    29. #给num赋值
    30. SET num = loop_count;
    31. END //
    32. DELIMITER ;
    33. SELECT AVG(salary) FROM employees;
    34. CALL update_salary_loop(@num);
    35. SELECT @num;

     

    循环结构while

    WHILE语句创建一个带条件判断的循环过程。WHILE在执行语句执行时,先对指定的表达式进行判断,如果为真,就执行循环内的语句,否则退出循环。WHILE语句的基本格式如下: 

    1. [while_label:] WHILE 循环条件 DO
    2. 循环体
    3. END WHILE [while_label];

     while_label为WHILE语句的标注名称;如果循环条件结果为真,WHILE语句内的语句或语句群被执行,直至循环条件为假,退出循环。

    1. #举例1
    2. DELIMITER //
    3. CREATE PROCEDURE test_while()
    4. BEGIN
    5. #初始化条件
    6. DECLARE num INT DEFAULT 1;
    7. #循环条件
    8. WHILE num <= 10 DO
    9. #循环体(略)
    10. #迭代条件
    11. SET num = num + 1;
    12. END WHILE;
    13. #查询
    14. SELECT num;
    15. END //
    16. DELIMITER ;
    17. #调用
    18. CALL test_while();

     

    1. #举例2:市场环境不好时,公司为了渡过难关,决定暂时降低大家的薪资。
    2. #声明存储过程“update_salary_while()”,声明OUT参数num,输出循环次数。
    3. #存储过程中实现循环给大家降薪,薪资降为原来的90%。直到全公司的平均薪资
    4. #达到5000结束。并统计循环次数。
    5. DELIMITER //
    6. CREATE PROCEDURE update_salary_while(OUT num INT)
    7. BEGIN
    8. #声明变量
    9. DECLARE avg_sal DOUBLE ; #记录平均工资
    10. DECLARE while_count INT DEFAULT 0; #记录循环次数
    11. #赋值
    12. SELECT AVG(salary) INTO avg_sal FROM employees;
    13. WHILE avg_sal > 5000 DO
    14. UPDATE employees SET salary = salary * 0.9 ;
    15. SET while_count = while_count + 1;
    16. SELECT AVG(salary) INTO avg_sal FROM employees;
    17. END WHILE;
    18. #给num赋值
    19. SET num = while_count;
    20. END //
    21. DELIMITER ;
    22. #调用
    23. CALL update_salary_while(@num);
    24. SELECT @num;
    25. SELECT AVG(salary) FROM employees;

     

     

    循环结构repeat

    REPEAT语句创建一个带条件判断的循环过程。与WHILE循环不同的是,REPEAT 循环首先会执行一次循环,然后在 UNTIL 中进行表达式的判断,如果满足条件就退出,即 END REPEAT;如果条件不满足,则会就继续执行循环,直到满足退出条件为止。
    REPEAT语句的基本格式如下:

    1. [repeat_label:] REPEAT
    2. 循环体的语句
    3. UNTIL 结束循环的条件表达式
    4. END REPEAT [repeat_label]

     repeat_label为REPEAT语句的标注名称,该参数可以省略;REPEAT语句内的语句或语句群被重复,直至expr_condition为真。

    1. #举例1
    2. DELIMITER //
    3. CREATE PROCEDURE test_repeat()
    4. BEGIN
    5. #声明变量
    6. DECLARE num INT DEFAULT 1;
    7. REPEAT
    8. SET num = num + 1;
    9. UNTIL num >= 10
    10. END REPEAT;
    11. #查看
    12. SELECT num;
    13. END //
    14. DELIMITER ;
    15. #调用
    16. CALL test_repeat();

     

     

    1. #举例2:当市场环境变好时,公司为了奖励大家,决定给大家涨工资。
    2. #声明存储过程“update_salary_repeat()”,声明OUT参数num,输出循环次数。
    3. #存储过程中实现循环给大家涨薪,薪资涨为原来的1.15倍。直到全公司的平均
    4. #薪资达到13000结束。并统计循环次数。
    5. DELIMITER //
    6. CREATE PROCEDURE update_salary_repeat(OUT num INT)
    7. BEGIN
    8. #声明变量
    9. DECLARE avg_sal DOUBLE ; #记录平均工资
    10. DECLARE repeat_count INT DEFAULT 0; #记录循环次数
    11. #赋值
    12. SELECT AVG(salary) INTO avg_sal FROM employees;
    13. REPEAT
    14. UPDATE employees SET salary = salary * 1.15;
    15. SET repeat_count = repeat_count + 1;
    16. SELECT AVG(salary) INTO avg_sal FROM employees;
    17. UNTIL avg_sal >= 13000
    18. END REPEAT;
    19. #给num赋值
    20. SET num = repeat_count;
    21. END //
    22. DELIMITER ;
    23. #调用
    24. CALL update_salary_repeat(@num);
    25. SELECT @num;
    26. SELECT AVG(salary) FROM employees;

     

    对比三种循环结构:

    1. 凡是循环结构,一定具备4个要素:
    2. 1. 初始化条件
    3. 2. 循环条件
    4. 3. 循环体
    5. 4. 迭代条件

     

    1、这三种循环都可以省略名称,但如果循环中添加了循环控制语句(LEAVE或ITERATE)则必须添加名称。

    2、 LOOP:一般用于实现简单的"死"循环

           WHILE:先判断后执行

           REPEAT:先执行后判断,无条件至少执行一次。        

    跳转语句leave 

    LEAVE语句:可以用在循环语句内,或者以 BEGIN 和 END 包裹起来的程序体内,表示跳出循环或者跳出程序体的操作。如果你有面向过程的编程语言的使用经验,你可以把 LEAVE 理解为 break。
    基本格式如下:

    LEAVE 标记名

    其中,label参数表示循环的标志。LEAVE和BEGIN ... END或循环一起被使用。

     

    1. /*
    2. **举例1:**创建存储过程 “leave_begin()”,声明INT类型的IN参数num。给BEGIN...END加标记名,
    3. 并在BEGIN...END中使用IF语句判断num参数的值。
    4. - 如果num<=0,则使用LEAVE语句退出BEGIN...END;
    5. - 如果num=1,则查询“employees”表的平均薪资;
    6. - 如果num=2,则查询“employees”表的最低薪资;
    7. - 如果num>2,则查询“employees”表的最高薪资。
    8. IF语句结束后查询“employees”表的总人数。
    9. */
    10. DELIMITER //
    11. CREATE PROCEDURE leave_begin(IN num INT)
    12. begin_label:BEGIN
    13. IF num <= 0
    14. THEN LEAVE begin_label;
    15. ELSEIF num = 1
    16. THEN SELECT AVG(salary) FROM employees;
    17. ELSEIF num = 2
    18. THEN SELECT MIN(salary) FROM employees;
    19. ELSE
    20. SELECT MAX(salary) FROM employees;
    21. END IF;
    22. #查询总人数
    23. SELECT COUNT(*) FROM employees;
    24. END //
    25. DELIMITER ;
    26. #调用
    27. CALL leave_begin(1);

    这里由于我们MySQL的测试软件的问题,将num=1时的返回结构给覆盖掉了,所以只呈现出查询的总人数。 

      如果使用我们的终端去查看的话,可以查看到

     

     

    1. #举例2:当市场环境不好时,公司为了渡过难关,决定暂时降低大家的薪资。
    2. #声明存储过程“leave_while()”,声明OUT参数num,输出循环次数,存储过程中使用WHILE
    3. #循环给大家降低薪资为原来薪资的90%,直到全公司的平均薪资小于等于10000,并统计循环次数。
    4. DELIMITER //
    5. CREATE PROCEDURE leave_while(OUT num INT)
    6. BEGIN
    7. #
    8. DECLARE avg_sal DOUBLE;#记录平均工资
    9. DECLARE while_count INT DEFAULT 0; #记录循环次数
    10. SELECT AVG(salary) INTO avg_sal FROM employees; #① 初始化条件
    11. while_label:WHILE TRUE DO #② 循环条件
    12. #③ 循环体
    13. IF avg_sal <= 10000 THEN
    14. LEAVE while_label;
    15. END IF;
    16. UPDATE employees SET salary = salary * 0.9;
    17. SET while_count = while_count + 1;
    18. #④ 迭代条件
    19. SELECT AVG(salary) INTO avg_sal FROM employees;
    20. END WHILE;
    21. #赋值
    22. SET num = while_count;
    23. END //
    24. DELIMITER ;
    25. #调用
    26. CALL leave_while(@num);
    27. SELECT @num;
    28. SELECT AVG(salary) FROM employees;

     

    跳转语句ITERATE 

    ITERATE语句:只能用在循环语句(LOOP、REPEAT和WHILE语句)内,表示重新开始循环,将执行顺序转到语句段开头处。如果你有面向过程的编程语言的使用经验,你可以把 ITERATE 理解为 continue,意思为“再次循环”。
    语句基本格式如下:

    ITERATE label

    label参数表示循环的标志。ITERATE语句必须跟在循环标志前面。
    举例: 定义局部变量num,初始值为0。循环结构中执行num + 1操作。
            如果num < 10,则继续执行循环;
            如果num > 15,则退出循环结构;

    1. /*
    2. 举例: 定义局部变量num,初始值为0。循环结构中执行num + 1操作。
    3. - 如果num < 10,则继续执行循环;
    4. - 如果num > 15,则退出循环结构;
    5. */
    6. DELIMITER //
    7. CREATE PROCEDURE test_iterate()
    8. BEGIN
    9. DECLARE num INT DEFAULT 0;
    10. loop_label:LOOP
    11. #赋值
    12. SET num = num + 1;
    13. IF num < 10
    14. THEN ITERATE loop_label;
    15. ELSEIF num > 15
    16. THEN LEAVE loop_label;
    17. END IF;
    18. SELECT '啊哈哈哈,鸡汤来喽,哈哈哈';
    19. END LOOP;
    20. END //
    21. DELIMITER ;
    22. CALL test_iterate();
    23. SELECT * FROM employees;

     

    在终端中查看比在IDE中查看更加直观。也就是当num=10,11,12,13,14,15的时候都会打印鸡汤来咯。

     

    四、游标

    虽然我们也可以通过筛选条件 WHERE 和 HAVING,或者是限定返回记录的关键字 LIMIT 返回一条记录,但是,却无法在结果集中像指针一样,向前定位一条记录、向后定位一条记录,或者是 随意定位到某一条记录 ,并对记录的数据进行处理。


    这个时候,就可以用到游标。游标,提供了一种灵活的操作方式,让我们能够对结果集中的每一条记录进行定位,并对指向的记录中的数据进行操作的数据结构。游标让 SQL 这种面向集合的语言有了面向过程开发的能力。


    在 SQL 中,游标是一种临时的数据库对象,可以指向存储在数据库表中的数据行指针。这里游标 充当了指针的作用 ,我们可以通过操作游标来对数据行进行操作。
    MySQL中游标可以在存储过程和函数中使用。

    1. 游标使用的步骤:
    2. ① 声明游标
    3. ② 打开游标
    4. ③ 使用游标(从游标中获取数据)
    5. ④ 关闭游标

    第一步,声明游标
    在MySQL中,使用DECLARE关键字来声明游标,其语法的基本形式如下:

    DECLARE cursor_name CURSOR FOR select_statement;

    这个语法适用于 MySQL,SQL Server,DB2 和 MariaDB。如果是用 Oracle 或者 PostgreSQL,需要写成:

    DECLARE cursor_name CURSOR IS select_statement;

    要使用 SELECT 语句来获取数据结果集,而此时还没有开始遍历数据,这里 select_statement 代表的是SELECT 语句,返回一个用于创建游标的结果集。

    第二步,打开游标
    打开游标的语法如下:

    OPEN cursor_name

     当我们定义好游标之后,如果想要使用游标,必须先打开游标。打开游标的时候 SELECT 语句的查询结果集就会送到游标工作区,为后面游标的 逐条读取 结果集中的记录做准备。

    第三步,使用游标(从游标中取得数据)
    语法如下:

    FETCH cursor_name INTO var_name [, var_name] ...

     这句的作用是使用 cursor_name 这个游标来读取当前行,并且将数据保存到 var_name 这个变量中,游标指针指到下一行。如果游标读取的数据行有多个列名,则在 INTO 关键字后面赋值给多个变量名即可。
    注意:var_name必须在声明游标之前就定义好。

    注意:游标的查询结果集中的字段数,必须跟 INTO 后面的变量数一致,否则,在存储过程执行的时候,MySQL 会提示错误。

    第四步,关闭游标

    CLOSE cursor_name

    有 OPEN 就会有 CLOSE,也就是打开和关闭游标。当我们使用完游标后需要关闭掉该游标。因为游标会占用系统资源 ,如果不及时关闭,游标会一直保持到存储过程结束,影响系统运行的效率。而关闭游标的操作,会释放游标占用的系统资源。 

    关闭游标之后,我们就不能再检索查询结果中的数据行,如果需要检索只能再次打开游标。

    1. #举例:创建存储过程“get_count_by_limit_total_salary()”,声明IN参数 limit_total_salary,
    2. #DOUBLE类型;声明OUT参数total_count,INT类型。函数的功能可以实现累加薪资最高的几个员工的薪资值,
    3. #直到薪资总和达到limit_total_salary参数的值,返回累加的人数给total_count。
    4. DELIMITER //
    5. CREATE PROCEDURE get_count_by_limit_total_salary(IN limit_total_salary DOUBLE,OUT total_count INT)
    6. BEGIN
    7. #声明局部变量
    8. DECLARE sum_sal DOUBLE DEFAULT 0.0; #记录累加的工资总额
    9. DECLARE emp_sal DOUBLE; #记录每一个员工的工资
    10. DECLARE emp_count INT DEFAULT 0;#记录累加的人数
    11. #1.声明游标
    12. #让我们的游标指向的结果集是一个递减的
    13. DECLARE emp_cursor CURSOR FOR SELECT salary FROM employees ORDER BY salary DESC;
    14. #2.打开游标
    15. OPEN emp_cursor;
    16. REPEAT
    17. #3.使用游标
    18. FETCH emp_cursor INTO emp_sal;
    19. SET sum_sal = sum_sal + emp_sal;
    20. SET emp_count = emp_count + 1;
    21. UNTIL sum_sal >= limit_total_salary
    22. END REPEAT;
    23. SET total_count = emp_count;
    24. #4.关闭游标
    25. CLOSE emp_cursor;
    26. END //
    27. DELIMITER ;
    28. #调用
    29. CALL get_count_by_limit_total_salary(200000,@total_count);
    30. SELECT @total_count;

     

     游标是 MySQL 的一个重要的功能,为 逐条读取 结果集中的数据,提供了完美的解决方案。跟在应用层面实现相同的功能相比,游标可以在存储程序中使用,效率高,程序也更加简洁。
    但同时也会带来一些性能问题,比如在使用游标的过程中,会对数据行进行 加锁 ,这样在业务并发量大的时候,不仅会影响业务之间的效率,还会 消耗系统资源 ,造成内存不足,这是因为游标是在内存中进行的处理。
    建议:养成用完之后就关闭的习惯,这样才能提高系统的整体效率。

    全局变量的持久化 

    在MySQL数据库中,全局变量可以通过SET GLOBAL语句来设置。例如,设置服务器语句超时的限制,可以通过设置系统变量max_execution_time来实现:

    SET GLOBAL MAX_EXECUTION_TIME=2000;

     使用SET GLOBAL语句设置的变量值只会 临时生效 。 数据库重启 后,服务器又会从MySQL配置文件中读取变量的默认值。 MySQL 8.0版本新增了 SET PERSIST 命令。例如,设置服务器的最大连接数为1000:

    SET PERSIST global max_connections = 1000;

     MySQL会将该命令的配置保存到数据目录下的 mysqld-auto.cnf 文件中,下次启动时会读取该文件,用其中的配置来覆盖默认的配置文件。

  • 相关阅读:
    AR贴纸特效SDK,无缝贴合的虚拟体验
    week10|查阅文章
    Java数据结构——第十二节 - Map和Set
    js将图片或者文件转成base64格式的两种方法
    OrangePi Kunpeng Pro 开发板测评 | AI 边缘计算 & 大模型部署
    机器学习-(手推)线性回归-最小二乘法(矩阵表达)、几何意义
    HiSilicon352 android9.0 适配红外遥控器
    node.js学习之数据库及基本操作、SQL语句
    03贪心:摆动序列
    不用996,不用007,赚的还比我多?我直接好家伙
  • 原文地址:https://blog.csdn.net/weixin_62684026/article/details/126136988