Chinaunix首页 | 论坛 | 博客
  • 博客访问: 9267342
  • 博文数量: 1669
  • 博客积分: 16831
  • 博客等级: 上将
  • 技术积分: 12594
  • 用 户 组: 普通用户
  • 注册时间: 2011-02-25 07:23
个人简介

柔中带刚,刚中带柔,淫荡中富含柔和,刚猛中荡漾风骚,无坚不摧,无孔不入!

文章分类

全部博文(1669)

文章存档

2023年(4)

2022年(1)

2021年(10)

2020年(24)

2019年(4)

2018年(19)

2017年(66)

2016年(60)

2015年(49)

2014年(201)

2013年(221)

2012年(638)

2011年(372)

分类: Mysql/postgreSQL

2011-12-27 11:57:40

 
 
MySQL存储过程中使用游标和临时表
[日期:2011-10-06] 来源:Linux社区  作者:del1214
 
 
 
 
MySQL存储过程中使用游标和临时表:
 
BEGIN  
     DECLARE c_egid INTEGER;  
     DECLARE done INT DEFAULT 0;  
     DECLARE my_testCursor CURSOR FOR   
         (SELECT cp.tb_electricGroup_id FROM tb_chargingPole AS cp WHERE cp.tb_chargeStation_id = 12);  
     DECLARE CONTINUE HANDLER FOR NOT FOUND SET done=1;  
     DROP TABLE IF EXISTS tmp_table;  
     CREATE TEMPORARY TABLE tmp_table (创建临时表要写在DECLARE之后要不会语法错误   
    tmp_egid INTEGER        有的表数据格式变了,例如datetime变timestamp,bit就是0、1等等  
     );  
     OPEN my_testCursor;  
          emp_loop: LOOP  
               FETCH my_testCursor INTO c_egid;    游标有多少列就需要多少个参数  
               IF done=1 THEN                 这句话的位置很重要,如果不放在开头的话可能会产生某条数据的重复  
                     LEAVE emp_loop;  
               END IF;  
               INSERT INTO tmp_table(tmp_egid) VALUES(c_egid); 将数据插入临时表  
          END LOOP emp_loop;  
     CLOSE my_testCursor;  
     select * from tmp_table;              
     TRUNCATE tmp_table;  
END 
这里值得注意的是DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1
 
在游标循环中我们使用done是否为0来作为判断是否退出循环的标准,在普通插入语句中没有问题
 
但是一旦在游标中使用select语句查找出来的东西为null时会触发Handler,done会从0变为1
 
因此游标中有select语句的可以使用应使用其他方式,例如while循环等,下面是个利用判断结果集长度退出while循环的例子
 
SELECT COUNT(*) INTO @pageCount FROM tmp_bwGetChargePoleCommunicationtable;  
SET @num = 0;  
OPEN my_testCursor;  
    WHILE @num < @pageCount DO  
        SET @num = @num + 1;  
        FETCH my_testCursor INTO param_id,param_ip,param_port,param_key;  
  
        IF param_key IS NULL THEN  
            SELECT kiosk_key INTO @tmpParam_key FROM tb_kiosk WHERE kiosk_id = (SELECT tb_kiosk_id FROM tb_chargingPole WHERE cp_id = param_id);  
            UPDATE tmp_bwGetChargePoleCommunicationtable SET tmp_key = @tmpParam_key WHERE tmp_id = param_id;  
        END IF;  
    END WHILE;  
CLOSE my_testCursor; 
 

本篇文章来源于 Linux公社网站()  原文链接:
阅读(2125) | 评论(0) | 转发(3) |
给主人留下些什么吧!~~