主页
文章
知识库
云盘
工具
登录
登录
注册
忘记密码
反馈
文章
MySQL 存储过程
MySQL 存储过程
lyjin
2023-07-05
[TOC] # 前言 在项目开发中，经常会遇到这样一种场景，当修改A表的一条数据时，需要关联修改B表、C表甚至其他更多表的数据，为什么会这样呢？ 在真实的业务场景中，往往一张表的数据关联的业务是多样的，举例来说，用户在页面上完成一个订单，对服务端来说，与这个订单相关的业务还有很多，比如生成一条出库记录，扣减库存，用户的账户余额扣减，商家的账户余额增加，财务结算等等… 所有这些不同的业务员操作，在服务端来说，最终体现的就是与数据库的交互，可想而知，假如关联的业务越复杂，需要与数据库进行IO的次数就越多； 那么有没有什么办法，在面对此类场景业务时，提升服务端的性能，减少数据库IO呢？这就是本篇将要分享的存储过程。 # 什么是存储过程 存储过程就是事先经过编译并存储在数据库中的一段 SQL 语句的集合； # 为什么使用存储过程 调用存储过程可以简化应用开发人员的很多工作，减少数据在数据库和应用服务器之间的传输，对于提高数据处理的效率是有好处的。存储过程思想上很简单，就是数据库 SQL 语言层面的代码封装与重用。 存储过程特点： - 封装，复用， 可以把某一业务SQL封装在存储过程中，需要用到的时候直接调用即可； - 可以接收参数，也可以返回数据， 在存储过程中，可以传递参数，也可以接收返回值； - 减少网络交互，提升效率，如果一次操作涉及到多条SQL，每执行一次都是一次网络传 输。 如果将这些sql操作封装在存储过程中，只需网络交互一次可能就可以了； # 存储过程基础语法 ## 1、创建存储过程语法 ```mysql CREATE PROCEDURE 存储过程名称 ([ 参数列表 ]) BEGIN -- SQL语句 END ; ``` 一个简单的案例 ```mysql CREATE PROCEDURE p1() BEGIN SELECT count(*) FROM account; END; ``` ## 2、调用存储过程 ```mysql CALL 名称 ([ 参数 ]); ``` 调用上面的存储过程 ```mysql call p1(); ```  ## 3、查看存储过程 ```mysql SHOW CREATE PROCEDURE 存储过程名称 ; -- 查询某个存储过程的定义 ```  ##4、删除存储过程 ```mysql DROP PROCEDURE [ IF EXISTS ] 存储过程名称 ; ```  >注意点：上面创建存储过程的语句在navicat或者sqlyog中没问题，但是放到命令行中执行会报错，在命令行中模式下，需要通过关键字 delimiter 指定SQL语句的结束符 # 存储过程中的变量 在MySQL中，变量一般可分为分为三种类型: 系统变量、用户定义变量、局部变量； ## 一、系统变量 系统变量是MySQL服务器系统自身提供的，分为全局变量（GLOBAL）、会话变量（SESSION）； ### 1）查看系统变量 ```mysql SHOW [ SESSION | GLOBAL ] VARIABLES ; -- 查看所有系统变量 SHOW [ SESSION | GLOBAL ] VARIABLES LIKE '......'; -- 可以通过LIKE模糊匹配方 式查找变量 SELECT @@[SESSION | GLOBAL] 系统变量名; -- 查看指定变量的值 ``` ### 2）设置系统变量 ```mysql SET [ SESSION | GLOBAL ] 系统变量名 = 值 ; SET @@[SESSION | GLOBAL]系统变量名 = 值 ; ``` > 如果没有指定SESSION/GLOBAL，默认是SESSION，会话变量。 **注意点：** - mysql服务重新启动之后，所设置的全局参数会失效，要想不失效，可以在 /etc/my.cnf 中配置； - 全局变量(GLOBAL): 全局变量针对于所有的会话； - 会话变量(SESSION): 会话变量针对于单个会话，在另外一个会话窗口就不生效了； 比如使用下面的语句查看系统的query_cache值 ```mysql SHOW VARIABLES LIKE '%query_cache%'; ``` ## 二、用户自定义变量 用户定义变量，是用户根据需要自己定义的变量，用户自定义变量不用提前声明，在用的时候直接用 “@变量名” 使用就可以。其作用域为当前session的连接。 ### 1、使用如下方式自定义变量 ```mysql SET @var_name = expr [, @var_name = expr] ... ; SET @var_name := expr [, @var_name := expr] ... ; ``` 赋值时，可以使用 = ，也可以使用 := 。  ### 2、使用select into 的方式给变量赋值 ```mysql SELECT @var_name := expr [, @var_name := expr] ... ; SELECT 字段名 INTO @var_name FROM 表名; ```  > 注意: 用户定义变量无需对其进行声明或初始化，只不过获取到的值为NULL而已； ## 三、局部变量 ### 1、局部变量定义 > 根据需要定义的在局部生效的变量，访问前，需通过DECLARE声明。可用作存储过程内的局部变量和输入参数，局部变量的范围是在其内声明的BEGIN … END块。 ### 2、定义方式 ```mysql DECLARE 变量名 变量类型 [DEFAULT ... ] ; ``` > 变量类型就是数据库字段类型，可选值包括：INT、BIGINT、CHAR、VARCHAR、DATE、TIME等。 一个简单的案例 ```mysql create procedure p2() BEGIN declare my_count int default 0; select count(*) into my_count from account; select my_count; END; ``` 执行下调用  # 条件判断语句if的使用 条件判断可以说在很多编程语言中都不陌生，在存储过程中也一样，而且使用的场景很多，务必掌握； ## 1、if 条件语句语法结构 ```mysql IF 条件1 THEN ..... ELSEIF 条件2 THEN -- 可选 ..... ELSE -- 可选 ..... END IF; ``` > 在if条件判断结构中，ELSE IF 结构可以有多个，也可以没有。 ELSE结构可以有，也可以没有。 一个简单的案例，判断分数在不同的区间，然后输出不同的值； ```mysql create procedure p3() BEGIN declare score int default 59; declare result VARCHAR(12); if score >= 85 then set result := '优秀'; elseif score >= 60 then set result := '及格'; else set result := '不及格'; end if; select result; END; ``` 执行下调用  ## 2、case - when 语法 在实际编码中，与if-else 相似作用的还有case-when 这种写法，也是比较常用的写法； ```mysql CASE case_value WHEN when_value1 THEN statement_list1 [ WHEN when_value2 THEN statement_list2] ... [ ELSE statement_list ] END CASE; ``` 解释说明 - 当case_value的值为 when_value1时，执行statement_list1； - 当值为 when_value2时， 执行statement_list2， 否则就执行 statement_list； 还有另一种语法结构如下： ```mysql CASE WHEN search_condition1 THEN statement_list1 [WHEN search_condition2 THEN statement_list2] ... [ELSE statement_list] END CASE; ``` 解释说明： - 当条件search_condition1成立时，执行statement_list1 - 当条件search_condition2成 立时，执行statement_list2， 否则就执行 statement_list； 如果用case-when对上面的进行改造如下： ```mysql create procedure p5() BEGIN declare score int default 77; declare result VARCHAR(12); case when score >= 85 then set result := '优秀'; when score >= 60 then set result := '及格'; else set result := '未知结果'; end case; select result; END; ``` 执行调用  上面的这种写法存在什么问题呢？很明显，不够灵活，通常来说，在实际业务中，我们更希望存储过程能够接收参数，并且返回处理结果，以便提供给后续的业务逻辑使用，这就需要用到存储过程的输入输出参数了； # 存储过程输入输出参数使用 存储过程中使用到的参数的类型，主要分为以下三种：IN、OUT、INOUT； 类型 含义 备注说明 IN 该类参数作为输入，也就是需要调用时传入值 默认 OUT 该类参数作为输出，也就是该参数可以作为返回值 INOUT 既可以作为输入参数，也可以作为输出参数 ## 1、语法定义 ```mysql CREATE PROCEDURE 存储过程名称 ([ IN/OUT/INOUT 参数名 参数类型 ]) BEGIN -- SQL END; ``` 将上面的案例进行简单改造，通过外面传入的参数，判断分数在不同的区间，从而返回不同的结果； ```mysql create procedure p4(in score int,out result varchar(12)) BEGIN if score >= 85 then set result := '优秀'; elseif score >= 60 then set result := '及格'; else set result := '不及格'; end if; END; ``` 执行下调用 ```mysql call p4(90,@result); select @result; ```  ## 案例演示 下面有一张员工表  ***案例需求：*** 创建存储过程show_emp_salary()，查看 employees 表的某个员工的薪资，并用IN参数emp_name 输入员工姓名，并返回薪资； ```mysql CREATE PROCEDURE show_emp_salary (IN emp_name VARCHAR(20),OUT emp_salary INT) BEGIN select salary into emp_salary from employees WHERE first_name = emp_name; END ; ``` 执行调用  # 存储过程中的循环使用 循环语句在编程中经常被用到，常用于对批量的数据进行循环处理，在mysql的存储过程中，也提供了几种常用的循环语句，包括：while循环，repeat循环，和loop循环； ## 1、while循环语句 while 循环是有条件的循环控制语句。满足条件时，再执行循环体中的SQL语句； ```mysql WHILE 条件 DO SQL逻辑... END WHILE; ``` > 先判定条件，如果条件为true，则执行逻辑，否则，不执行逻辑 ***需求：从1累加到N，并求出累加的结果*** ```mysql create procedure p6(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 ; ``` 执行下调用  ## 2、repeat 循环语句 repeat是有条件的循环控制语句, 当满足 until 声明的条件的时候，则退出循环,语法结构为： ```mysql REPEAT SQL逻辑... UNTIL 条件 END REPEAT; ``` > 先执行一次逻辑，然后判定UNTIL条件是否满足，如果满足，则退出。如果不满足，则继续下一次循环； 仍然使用上面的累计求和的需求进行改造如下： ```mysql create procedure p7(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 ; ``` 执行调用  ## 3、loop 循环语句 LOOP 可以实现简单的循环，如果不在SQL逻辑中增加退出循环的条件，可以用其来实现简单的死循环。LOOP可以配合一下两个语句使用： - LEAVE ：配合循环使用，退出循环； - ITERATE：必须用在循环中，作用是跳过当前循环剩下的语句，直接进入下一次循环； 语法结构如下： ```mysql [begin_label:] LOOP SQL逻辑... END LOOP [end_label]; ``` 说明： - LEAVE label; – 退出指定标记的循环体 - ITERATE label; – 直接进入下一次循环 上述语法中的 begin_label，end_label，label 指的是我们自定义的标记名称； 使用loop语法完成上面的从1到N的累加求和 ```mysql create procedure p8(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 ; ``` 执行调用  # 存储函数 存储函数是有返回值的存储过程，存储函数的参数只能是IN类型的，语法定义如下： ```mysql CREATE FUNCTION 存储函数名称 ([ 参数列表 ]) RETURNS type [characteristic ...] BEGIN -- SQL语句 RETURN ...; END ; ``` characteristic说明： - DETERMINISTIC：相同的输入参数总是产生相同的结果； - NO SQL ：不包含 SQL 语句； - READS SQL DATA：包含读取数据的语句，但不包含写入数据的语句； 存储函数案例1：求1到N的累加 ```mysql create function fun_add(n int) returns int deterministic BEGIN declare sum int default 0; while n > 0 do set sum := sum + n; set n := n - 1; end while; return sum; END; ``` 执行调用  通常来说，存储函数能够完成的事情，使用存储过程也可以完成，但是存储函数的局限在于，函数必须要有返回结果； # 存储过程中游标的使用 游标（CURSOR）是用来存储查询结果集的数据类型 , 在存储过程和函数中可以使用游标对结果集进行循环的处理； 游标，提供了一种灵活的操作方式，让我们能够对结果集中的每一条记录进行定位，并对指向的记录中的数据进行操作的数据结构。游标让 SQL 这种面向集合的语言有了面向过 程开发的能力； 在 SQL 中，游标是一种临时的数据库对象，可以指向存储在数据库表中的数据行指针。这里游标 充当了 指针的作用 ，我们可以通过操作游标来对数据行进行操作。 游标的使用包括游标的声明、OPEN、FETCH 和 CLOSE，其语法分别如下： ## 1、声明游标 ```mysql DECLARE 游标名称 CURSOR FOR 查询语句 ; ``` ## 2、 打开游标 ```mysql OPEN 游标名称 ; ``` ## 3、获取游标记录 ```mysql FETCH 游标名称 INTO 变量 [, 变量 ] ; ``` ## 4、关闭游标 ```mysql CLOSE 游标名称 ; ``` 案例需求，有下面一张员工表，创建一个存储过程，声明IN参数 limit_total_salary，DOUBLE类型；声明OUT参数total_count，INT类型。函数的功能可以实现累加薪资最高的几个员工的薪资值，直到薪资总和达到limit_total_salary参数的值，返回累加的人数给total_count； ```mysql CREATE PROCEDURE get_count_by_limit_total_salary(IN limit_total_salary DOUBLE,OUT total_count INT) BEGIN DECLARE sum_salary DOUBLE DEFAULT 0; #记录累加的总工资 DECLARE cursor_salary DOUBLE DEFAULT 0; #记录某一个工资值 DECLARE emp_count INT DEFAULT 0; #记录循环个数 #定义游标 DECLARE emp_cursor CURSOR FOR SELECT salary FROM employees ORDER BY salary DESC; #打开游标 OPEN emp_cursor; REPEAT #使用游标（从游标中获取数据） FETCH emp_cursor INTO cursor_salary; SET sum_salary = sum_salary + cursor_salary; SET emp_count = emp_count + 1; UNTIL sum_salary >= limit_total_salary END REPEAT; SET total_count = emp_count; #关闭游标 CLOSE emp_cursor; END ; ``` 执行下调用  通过上面的案例，我们体验了一下游标的强大之处，事实上，在很多时候，我们希望通过游标将获取到的记录输出到一个中间记录表中，以供后续的业务处理，利用游标来做就非常合适，看下面的需求： 根据传入的参数salary，来查询用户表employees中，所有工资大于等于15000的员工ID，以及first_name，并将员工的ID和first_name插入到一张新表； ```mysql create procedure p_emp(in in_salary int) begin declare u_empid int(12); declare u_fname varchar(100); declare u_cursor cursor for select employee_id,first_name from employees where salary >= in_salary; -- 声明条件处理程序 ： 当SQL语句执行抛出的状态码为02000时，将关闭游标u_cursor，并退出 declare exit handler for SQLSTATE '02000' close u_cursor; drop table if exists tb_em_pro; create table if not exists tb_em_pro( id int primary key auto_increment, employee_id int(12), first_name varchar(20) ); -- 打开游标 open u_cursor; while true do fetch u_cursor into u_empid,u_fname; insert into tb_em_pro values (null, u_empid, u_fname); end while; -- 关闭游标 close u_cursor; end; ``` 执行下调用  执行完毕后，可以看到通过游标处理完毕的数据写到一张中间表中去了
分享
×
用手机扫码分享
没有评论
请登陆后评论
新建评论
移除
关闭
提交
lyjin
2023-07-05