MySQL存储过程中双层游标嵌套循环实例

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: MySQL存储过程中双层游标嵌套循环实例
用户操作统计表
CREATE TABLE `count_active_user` (
  `id` varchar(20) NOT NULL COMMENT 'ID-20190220',
  `type` varchar(50) NOT NULL COMMENT '分类',
  `user_id` varchar(32) NOT NULL COMMENT '用户ID',
  `count` int(3) DEFAULT NULL COMMENT '计数',
  PRIMARY KEY (`id`,`type`,`user_id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=DYNAMIC;

count_active_user的数据

view_transfer_person 的数据

  • 需求: user_id可能是企业用户也可能是个人用户 ,现在个人用户升级为企业用户需要把企业用户和个人用户的计数字段合并起来,并且只保留企业用户的数据
  • 分析:个人用户id作为入参,把两层循环都定位到个人用户,再把个人用户的计数字段加到对应企业用户的计数字段,最后删掉个人用户数据
存储过程
CREATE DEFINER=`root`@`%` PROCEDURE `proc_person_data_to_enterprise`(IN userId varchar(32))
BEGIN
    declare cur_person_user_id varchar(32);
    declare cur_orguser_id varchar(32);
  declare cur_id varchar(32);
  declare cur_type varchar(32);
    declare cur_user_id varchar(32);
    declare cur_count int;
    declare done int default 0;
    declare cur_transferPerson CURSOR FOR  SELECT person_user_id,orguser_id FROM view_transfer_person where person_user_id = userId;
  declare cur_count_active_user CURSOR FOR  select * from count_active_user;
    -- 在游标循环到最后会将 done 设置为 1(如果不加该行  游标为空的时候  就会报错)
    declare continue handler for not found set done=1;
    OPEN cur_transferPerson; -- 打开游标
        myLoop1: LOOP -- 开始循环体,myLoop为自定义循环名,结束循环时用到
        FETCH cur_transferPerson into cur_person_user_id,cur_orguser_id; -- 将游标当前读取行的数据顺序赋予自定义变量12
           IF done = 1 THEN -- 判断是否继续循环
               LEAVE myLoop1; -- 结束循环
           END IF;
          update attestation a set  a.user_id = cur_orguser_id where a.user_id  = cur_person_user_id;     
          OPEN cur_count_active_user;  
            myLoop2: LOOP  
             FETCH cur_count_active_user into cur_id,cur_type,cur_user_id,cur_count; 
             IF done = 1 THEN  
                           LEAVE myLoop2; 
             END IF;
       update count_active_user a set  a.count = a.count + cur_count where  a.user_id = cur_orguser_id 
           and cur_user_id = userId and cur_person_user_id =userId   and a.id = cur_id and a.type = cur_type;  
         END LOOP myLoop2;  
       CLOSE cur_count_active_user;  
             -- 注意这里,当内层游标循环完毕以后需要将done设置成0,否则外层循环只会进行一次
         SET done = 0;
    COMMIT; -- 提交事务
  END LOOP myLoop1; -- 结束自定义循环体
  CLOSE cur_transferPerson; -- 关闭游标
  DELETE from count_active_user   where  user_id =  userId ;   
END


相关实践学习
基于CentOS快速搭建LAMP环境
本教程介绍如何搭建LAMP环境,其中LAMP分别代表Linux、Apache、MySQL和PHP。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
20天前
|
存储 SQL 关系型数据库
20. Mysql 游标的定义和使用
20. Mysql 游标的定义和使用
16 1
|
20天前
|
存储 关系型数据库 MySQL
19. Mysql 循环语句
19. Mysql 循环语句
13 1
|
11天前
|
存储 SQL 关系型数据库
MySQL存储过程_触发器_游标——Baidu Comate
MySQL存储过程_触发器_游标——Baidu Comate
12 0
|
11天前
|
存储 SQL 关系型数据库
MySQL游标的创建与使用——Baidu Comate全文SQL-AI生成
MySQL游标的创建与使用——Baidu Comate全文SQL-AI生成
13 0
|
19天前
|
存储 关系型数据库 MySQL
MySQL数据库——存储过程-游标(介绍-声明游标、打开游标、获取游标记录、关闭游标,案例)
MySQL数据库——存储过程-游标(介绍-声明游标、打开游标、获取游标记录、关闭游标,案例)
19 0
|
19天前
|
存储 SQL 关系型数据库
MySQL数据库——存储过程-循环(while、repeat、loop)
MySQL数据库——存储过程-循环(while、repeat、loop)
57 0
|
21天前
|
存储 关系型数据库 MySQL
mysql 存储过程游标 循环输出select 查询结果
mysql 存储过程游标 循环输出select 查询结果
22 0
|
1天前
|
存储 关系型数据库 MySQL
关系型数据库MySQL的MyISAM
【6月更文挑战第17天】
18 11
|
3天前
|
存储 关系型数据库 MySQL
|
3天前
|
SQL 关系型数据库 MySQL