文章目录
- 1、需求描述
- 2、思路
- 3、创建存储过程
1、需求描述
1、在项目中,需要将A表中主键id,逐个取出,作为条件,在B表中去逐一查询,将B表查询到的结果集(A表B表关系:一对多),逐一遍历,连同A表的id拼接运算,逐个插入到C表中。
2、 在Java中很容易实现,A表获取到的结果集,循环遍历取出id,去B表查询;遍历B表结果集,插入到C表中。 相当于2个循环,即可实现需求。 这样会有一个问题,频繁连接数据库,造成大量资源开销。 那么在存储过程中,该怎么实现呢?
2、思路
要实现逐行获取数据,需要用到MySQL中的游标,一个游标相当于一个for循环,这里需要用到2个游标。如何在MySQL中实现游标双层循环呢?
3、创建存储过程
CREATE DEFINER=`root`@`%` PROCEDURE `student`()
BEGIN
-- 定义变量
-- 假设有一张学生表,有id,student_name字段
DECLARE outer_done INT DEFAULT FALSE; -- 外层游标控制变量
DECLARE studentTableId int; -- 学生表ID
declare studentTableName VARCHAR(100); -- 学生姓名
declare outer_cursor cursor for select id,student_name from student_table where `disable` = '0';
DECLARE CONTINUE HANDLER FOR NOT FOUND SET outer_done = TRUE;
open outer_cursor;
while not outer_done do
fetch outer_cursor into studentTableId,studentTableName; -- 这里循环取值,赋值到上面定义的变量中
-- 开始定义内层游标
BEGIN -- inner BEGIN
-- 假设有一张成绩表,包含字段id,student_name,score字段
DECLARE scoreTableId int; -- 成绩Id
declare scoreTableName VARCHAR(100); -- 学生名字
declare scoreTableScore float; -- 学生分数
DECLARE inner_done int DEFAULT FALSE ;
DECLARE my_value VARCHAR(255);
declare inner_cursor cursor for select id,student_name,score from score_table where `disable` = '0';
DECLARE CONTINUE HANDLER FOR NOT FOUND SET inner_done = TRUE ;
OPEN inner_cursor; -- 打开内层游标
WHILE not inner_done DO -- inner WHILE
FETCH inner_cursor INTO scoreTableId,scoreTableName,scoreTableScore ; -- 从【内层游标】中获取数据,赋值到定义变量中
IF studentTableName = scoreTableName THEN -- 判断名字一样(测试,生产不要用名称进行判断)
set my_value = CONCAT_WS('-',studentTableName,scoreTableScore); -- 给变量赋值 CONCAT_WS函数可以按照固定的连接符,将数据进行连接,例如 张三-95
select my_value; -- 打印变量值
END IF;
-- 假设有一张汇总表(summary_table),将处理的数据进行更新
update summary_table set summary_column=my_value where summary_table_student_id=studentTableId;
END WHILE ; -- END inner WHILE
CLOSE inner_cursor; -- 循环结束后,关闭内层游标
END; -- END inner BEGIN
end while;
close outer_cursor;
END
看图清晰一点。
到这里就完成了,存储过程里面的注释很详细,就不多赘述了,我在写存储过程中也是踩了不少坑,记录下来,希望能帮到各位coder。
有问题欢迎评论区留言或者私信,我看到就会回复。