MySQL存储过程之循环遍历查询的结果集详解

create table `member_album` (
  `id` int(11) not null auto_increment comment '数据id',
  `member_id` int(11) default null comment '会员id',
  `file_type` varchar(8) collate utf8mb4_unicode_ci default null comment '文件类型(image：照片；video：视频)',
  `file_id` int(11) default null comment '文件id',
  `file_path` varchar(255) collate utf8mb4_unicode_ci default null comment '文件地址(相对地址)',
  `create_date` datetime default null comment '创建时间',
  `del_flag` tinyint(1) default '0' comment '删除标识(0：正常；1：已删除)',
  primary key (`id`)
) engine=innodb auto_increment=7 default charset=utf8mb4 collate=utf8mb4_unicode_ci comment='会员相册';

create table `member_album_count` (
  `id` int(11) not null auto_increment comment '数据id',
  `member_id` int(11) default null comment '会员id',
  `img_pass_count` int(11) default '0' comment '照片通过的数量',
  `img_verify_count` int(11) default '0' comment '照片审核中的数量',
  `img_fail_count` int(11) default '0' comment '照片未通过的数量',
  primary key (`id`)
) engine=innodb auto_increment=4 default charset=utf8mb4 collate=utf8mb4_unicode_ci comment='会员照片数量表';

-- 建立存储过程之前需要判断该存储过程是否存在，若存在则删除
drop procedure if exists update_album_count;
-- 创建存储过程，update_album_count为存储过程名
create procedure update_album_count()
-- 标识存储过程开始
begin
	-- 定义变量
	declare s int default 0;
	declare memberid int;
	declare count int;
	-- 定义游标，并将sql结果集赋值到游标中，report为游标名
	declare report cursor for select member_id, count(member_id)
							  from member_album 
							  group by member_id
							  having count(member_id) > 0
							  order by member_id asc;
	-- 声明当游标遍历完后将标志变量置为某个值
	declare continue handler for not found set s = 1;
	-- 打开游标
	open report;
	-- 将游标中的值赋值给变量，注意：变量名不要与sql返回的列名相同，变量顺序要和sql结果列的顺序一致
	fetch report into memberid, count;
	-- 当s不等于1时，也就是未遍历完时，会一直循环
	while s <> 1 do
	-- 执行业务逻辑
	update member_album_count t set t.img_pass_count = count where t.member_id = memberid;
	-- 当s等于1时代表遍历已完成，退出循环
	fetch report into memberid, count;
	end while;
	-- 关闭游标
	close report;
-- 标识存储过程结束
end;

call update_album_count();

-- 显示存储过程的状态
show procedure status;
-- 查询指定数据库的存储过程名称
select `name` from mysql.proc where db = 'your_db_name' and `type` = 'procedure'