1. 程式人生 > >MYSQL儲存過程迴圈遍歷插入資料

MYSQL儲存過程迴圈遍歷插入資料

本示例通過 while...end while 迴圈控制遊標來實現插入表記錄。

DROP PROCEDURE IF exists pro_initCategoryForTradingEntity;
create procedure pro_initCategoryForTradingEntity(tradingEntityId int)
begin
    declare f_parent,entityId  int;
    declare b int default 0;    /*是否達到記錄的末尾控制變數*/
    declare f_name varchar(100);    
    DECLARE cur_1 CURSOR FOR select FName,FParent,tradingEntityId from t_category_tag;
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET b = 1;
    OPEN cur_1;
    FETCH cur_1 INTO f_name, f_parent, entityId; /*獲取第一條記錄*/
    while b<>1 do            
        insert into t_category(FName,FParent,FTradingEntity)  values(f_name, f_parent, entityId);
        FETCH cur_1 INTO f_name, f_parent, entityId; /*取下一條記錄*/
    end while;
    close cur_1;        
end;

call pro_initCategoryForTradingEntity(2);

本例項通過 repeat...end repeat 來迴圈控制。

CREATE DEFINER=`root`@`localhost` PROCEDURE `smt_update_goods_price`()
BEGIN
/*區域性變數的定義 declare*/
DECLARE goodsName varchar(50);
DECLARE goodsCode varchar(50);
DECLARE avgPrice varchar(50);
DECLARE maxPrice varchar(50);
DECLARE minPrice varchar(50);
DECLARE Done INT DEFAULT 0;
DECLARE rs cursor for(
select goods_name, goods_code, avg(goods_price), max(goods_price), min(goods_price) from smt_temp_goods group by goods_code );
DECLARE CONTINUE HANDLER FOR SQLSTATE '02000' SET Done = 1;
OPEN rs;
FETCH NEXT FROM rs INTO goodsName, goodsCode, avgPrice, maxPrice, minPrice;
REPEAT  
IF NOT Done THEN
insert into smt_goods_price(id,goods_name,goods_code,avg_price,max_price,min_price) values(REPLACE(UUID(), '-', ''),goodsName,goodsCode,avgPrice,maxPrice,minPrice);
  END IF;  
  FETCH NEXT FROM rs INTO goodsName, goodsCode, avgPrice, maxPrice, minPrice;
UNTIL Done END REPEAT;
CLOSE rs;
END