mysql -- 存储过程，游标

Posted 2022-06-07 daijiabao

 错误异常处理：

语法如下：

declare

exit | continue

handler for

error-number | sqlstate error-string | condition 

sql statement

这个语句指定了每个可以处理一个或多个条件的处理程序。如果产生一个或多个条件，则指定的语句将被执行，对于一个continue处理程序，当前子程序的执行将在执行处理程序语句之后继续。对于exit处理程序，当前的begin...end 复合语句的执行将被终止。

实例一：

DELIMITER $$

USE `csp` $$

DROP PROCEDURE IF EXISTS `curdemo` $$

CREATE DEFINER = `root` @`%` PROCEDURE `curdemo` (IN p_source VARCHAR (100)) 
BEGIN
  -- 需要定义接收游标数据的变量 
  DECLARE done INT DEFAULT 0 ;
  -- 自定义变量
  DECLARE var_price DOUBLE DEFAULT NULL ;
  DECLARE var_pay_time TIMESTAMP DEFAULT NULL ;
  DECLARE var_product VARCHAR (100) DEFAULT NULL ;
  DECLARE var_source VARCHAR (100) DEFAULT NULL ;
  -- 声明游标
  DECLARE cur CURSOR FOR 
  -- 作用于哪个语句
  SELECT 
    price,
    pay_time,
    product,
    source 
  FROM
    cms_aw_order 
  WHERE source = p_source ;
  -- 设置结束标志
  -- 这条语句定义了一个 CONTINUE HANDLER，它是在条件出现时被执行的代码。这里，它指出当 SQLSTATE ‘02000‘出现时，SET done=1 。SQLSTATE ‘02000‘是一个未找到条件，当REPEAT由于没有更多的行供循环而不能继续时，出现这个条件
  DECLARE CONTINUE HANDLER FOR SQLSTATE ‘02000‘ SET done = 1 ;
  -- 打开游标
  OPEN cur ;
  -- 使用repeat循环语法
  REPEAT
    -- 批读取数据到指定变量上
    FETCH cur INTO var_price,
    var_pay_time,
    var_product,
    var_source ;
    -- 进行逻辑操作
    INSERT INTO cms_aw_order_copy (price, pay_time, product, source) 
    VALUES
      (
        var_price,
        var_pay_time,
        var_product,
        var_source
      ) ;
    -- 循环结束条件
    UNTIL done 
  END REPEAT ;
  -- 关闭游标
  CLOSE cur ;
END $$

DELIMITER ;

实例二：

需求：编写存储过程，使用游标，把uid为偶数的记录逐一更新用户名。

delimiter $$
create procedure testf(IN my_userId varchar(32))
begin
  declare stopflag int default 0;
  declare my_uname varchar(32) default ‘‘;
  declare uname_cur CURSOR for select uname from temp_user where uid%2=0;
  #1 游标是保存查询结果的临时内存区域
  #2 游标变量uname_cur保存了查询的临时结果，实际上就是查询结果集
  declare continue handler for not found set stopflag=1;
  #3 声明句柄，当游标变量中保存的结果都查询一遍(遍历)，到达结尾，就把变量stopflag设置为1 用于循环中判断是否遍历结束
  open uname_cur; # 打开游标
  fetch uname_cur into my_uname; # 游标向前走一步，取出一条记录放到变量my_uname中。
  while(stopflag=0) DO # 如果游标还没到结尾，就继续循环
  begin
    update temp_user set uname=CONCAT(my_uname,‘_cur‘) where uname=my_uname;
    fetch uname_cur into my_uname;
  end;
  end while;
  close uname_cur;
end;
$$
delimiter ;