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

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
云数据库 RDS MySQL,高可用系列 2核4GB
简介: 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


相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
1月前
|
存储 关系型数据库 MySQL
环比、环比增长率、同比、同比增长率 ,占比,Mysql 8.0 实例(最简单的方法之一)(sample database classicmodels _No.2 )
环比、环比增长率、同比、同比增长率 ,占比,Mysql 8.0 实例(最简单的方法之一)(sample database classicmodels _No.2 )
92 1
|
1月前
|
SQL 前端开发 关系型数据库
全表数据核对 ,行数据核对,列数据核对,Mysql 8.0 实例(sample database classicmodels _No.3 )
全表数据核对 ,行数据核对,列数据核对,Mysql 8.0 实例(sample database classicmodels _No.3 )
47 0
全表数据核对 ,行数据核对,列数据核对,Mysql 8.0 实例(sample database classicmodels _No.3 )
|
17天前
|
存储 SQL NoSQL
|
8天前
|
关系型数据库 MySQL 数据库
【赵渝强老师】启动与关闭MySQL数据库实例
MySQL数据库安装完成后,可以通过命令脚本启动、查看状态、配置开机自启、查看自启列表及关闭数据库。本文提供了详细的操作步骤和示例代码,并附有视频讲解。
|
1月前
|
存储 关系型数据库 MySQL
mysql 8.0 的 建表 和八种 建表引擎实例
mysql 8.0 的 建表 和八种 建表引擎实例
20 0
|
1月前
|
存储 关系型数据库 MySQL
Key_Value 形式 存储_5级省市城乡划分代码 (mysql 8.0 实例)
本文介绍了如何使用MySQL8.0数据库中的Key_Value形式存储全国统计用区划代码和城乡划分代码(5级),包括导入数据、通过数学函数提取省市区信息,以及查询5级行政区划的详细数据。
30 0
|
1月前
|
算法 关系型数据库 MySQL
复购率 mysql 实例(sample database classicmodels _No.1 )
复购率 mysql 实例(sample database classicmodels _No.1 )
27 0
|
9天前
|
SQL 关系型数据库 MySQL
go语言数据库中mysql驱动安装
【11月更文挑战第2天】
24 4
|
7天前
|
SQL 关系型数据库 MySQL
12 PHP配置数据库MySQL
路老师分享了PHP操作MySQL数据库的方法,包括安装并连接MySQL服务器、选择数据库、执行SQL语句(如插入、更新、删除和查询),以及将结果集返回到数组。通过具体示例代码,详细介绍了每一步的操作流程,帮助读者快速入门PHP与MySQL的交互。
23 1
|
16天前
|
监控 关系型数据库 MySQL
数据库优化:MySQL索引策略与查询性能调优实战
【10月更文挑战第27天】本文深入探讨了MySQL的索引策略和查询性能调优技巧。通过介绍B-Tree索引、哈希索引和全文索引等不同类型,以及如何创建和维护索引,结合实战案例分析查询执行计划,帮助读者掌握提升查询性能的方法。定期优化索引和调整查询语句是提高数据库性能的关键。
82 1