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

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,高可用系列 2核4GB
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


相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发,帮助IT从业者们通过“阿里云Web应用上云解决方案”,了解一个企业级Web应用上云的常见架构,了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。   相关的阿里云产品:云数据库RDS MySQL 版 阿里云关系型数据库RDS(Relational Database Service)是一种稳定可靠、可弹性伸缩的在线数据库服务,提供容灾、备份、恢复、迁移等方面的全套解决方案,彻底解决数据库运维的烦恼。 了解产品详情: https://www.aliyun.com/product/rds/mysql 
目录
相关文章
|
7月前
|
存储 Java 关系型数据库
java调用mysql存储过程
在 Java 中调用 MySQL 存储过程主要借助 JDBC(Java Database Connectivity)。其核心原理是通过 JDBC 与 MySQL 建立连接,调用存储过程并处理结果。具体步骤包括:加载 JDBC 驱动、建立数据库连接、创建 CallableStatement 对象、设置存储过程参数并执行调用。此过程实现了 Java 程序与 MySQL 数据库的高效交互。
|
6月前
|
存储 关系型数据库 MySQL
【YashanDB知识库】MySQL返回结果集的存储过程的改写方法
本文介绍了将MySQL存储过程改写至YashanDB的解决方案。由于MySQL存储过程可直接返回结果集,而YashanDB需通过返回SYS_REF_CURSOR的函数实现类似功能,因此需要对代码进行转换。示例中展示了如何将MySQL存储过程`proc1`改写为YashanDB函数,并调整JDBC应用代码以适配REF_CURSOR输出参数,从而正确获取查询结果。此方法确保了跨数据库场景下的兼容性与功能性。
|
10月前
|
存储 SQL NoSQL
|
11月前
|
存储 关系型数据库 MySQL
MySQL 存储过程返回更新前记录
MySQL 存储过程返回更新前记录
163 3
|
11月前
|
存储 SQL 关系型数据库
MySQL 存储过程错误信息不打印在控制台
MySQL 存储过程错误信息不打印在控制台
193 1
|
11月前
|
存储 SQL 关系型数据库
MySql数据库---存储过程
MySql数据库---存储过程
137 5
|
存储 关系型数据库 MySQL
Mysql表结构同步存储过程(适用于模版表)
Mysql表结构同步存储过程(适用于模版表)
125 0
|
存储 SQL 关系型数据库
MySQL 创建存储过程注意项
MySQL 创建存储过程注意项
106 0
|
存储 SQL 关系型数据库
MySQL存储过程和存储函数的使用
MySQL的存储过程和存储函数在功能和用法上有明显的区别。存储过程是一组为了完成特定功能的SQL语句集,经编译后存储在数据库中,通过指定名称和参数(如果有)来调用执行,可以返回多个值或结果集,但不直接返回值。而存储函数则是一个有返回值的特殊存储过程,它返回一个值或表对象,可以直接嵌入SQL语句中使用,如SELECT语句中。两者都是为了提高SQL代码的重用性和性能,但使用场景和方式有所不同。
4435 4
|
存储 SQL 关系型数据库
MySQL数据库进阶第四篇(视图/存储过程/触发器)
MySQL数据库进阶第四篇(视图/存储过程/触发器)

推荐镜像

更多