mysql使用游标遍历数据进行批量针对性更新数据,急求mysql大神解答

mysql使用游标遍历数据进行批量针对性更新数据,急求mysql大神解答,第1张

根据你的资料,正确的答案应该如下:望采纳

CREATE DEFINER=`root`@`localhost` PROCEDURE `P_updateUd18`(`Param` int(11))

BEGIN

declare Rcount,i,j,k,Rparentid,myId int(11) default 0

declare Robjname,Robjname23,Robjname45,Robjname67,Robjname89 varchar(9) default ""

select count(id) into Rcount from ud18

repeat

select id,objname into myId,Robjname from ud18 order by id limit i,1

set Robjname23=SUBSTRING(Robjname,2,2)

set Robjname45=SUBSTRING(Robjname,4,2)

set Robjname67=SUBSTRING(Robjname,6,2)

set Robjname89=SUBSTRING(Robjname,8,2)

if Robjname89>0 then

set @sql=concat("select id into @abc from ud18 where objname like '",left(Robjname,7),"00","'")

prepare stmt from @sql

EXECUTE stmt

set Rparentid=@abc

update ud18 set parentid=Rparentid where id=myId

elseif Robjname67>0 then

set @sql=concat("select id into @abc from ud18 where objname like '",left(Robjname,5),"0000","'")

prepare stmt from @sql

EXECUTE stmt

set Rparentid=@abc

update ud18 set parentid=Rparentid where id=myId

elseif Robjname45>0 then

set @sql=concat("select id into @abc from ud18 where objname like '",left(Robjname,3),"000000","'")

prepare stmt from @sql

EXECUTE stmt

set Rparentid=@abc

update ud18 set parentid=Rparentid where id=myId

elseif Robjname23>0 then

-- set @sql=concat("select id into @abc from ud18 where objname like '",left(Robjname,1),"00000000","'")

-- prepare stmt from @sql

-- EXECUTE stmt

-- set Rparentid=@abc

update ud18 set parentid=0 where id=myId

else

set j=0

end if

set i=i+1

until i>Rcount end repeat

END

游标:能够对结果集中的每一条记录进行定位,并对指向的记录中的数据进行 *** 作的数据结构。

创建游标: CREATE FUNCTION 函数名称 (参数)RETURNS 数据类型 程序体

存储过程中使用游标的4个步骤:定义游标、打开游标、读取游标数据和关闭游标。

定义游标: DECLARE 游标名 CURSOR FOR 查询语句

打开游标: OPEN 游标名称;

读取游标数据: FETCH 游标名 INTO 变量列表;

关闭游标: CLOSE 游标名;

条件处理语句: DECLARE 处理方式[CONTINUE 或EXIT] HANDLER FOR 问题 *** 作;

流程控制语句:跳转语句(ITERATE语句和LEAVE语句)、循环语句(LOOP、WHILE、REPEAT)、条件判断语句(IF语句和CASE语句)

创建游标: CREATE FUNCTION 函数名称 (参数)RETURNS 数据类型 程序体

存储函数与存储过程很像,但有几个不同点:

1、存储函数必须返回一个值或者数据表,存储过程可以不返回。

2、存储过程可以通过CALL语句调用,存储函数不可以

3、存储函数可以放在查询语句中使用,存储过程不可以

4、存储过程的功能更强大,包括能够执行对表的 *** 作(比如创建表、删除表等)和事务 *** 作

游标 *** 作步骤包含4个:定义游标、打开游标、读取游标数据和关闭游标。

1、创建存储过程

如果没有则插入数据,如果有则更新的方法:

insert into `test` values (a,b) ON DUPLICATE KEY UPDATE `a`=c

[sql] view plain copy

CREATE PROCEDURE `test`.`new_procedure` ()

BEGIN

-- 需要定义接收游标数据的变量

DECLARE a CHAR(16)

-- 游标

DECLARE cur CURSOR FOR SELECT i FROM test.t

-- 遍历数据结束标志

DECLARE done INT DEFAULT FALSE

-- 将结束标志绑定到游标

DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE

-- 打开游标

OPEN cur

-- 开始循环

read_loop: LOOP

-- 提取游标里的数据,这里只有一个,多个的话也一样;

FETCH cur INTO a

-- 声明结束的时候

IF done THEN

LEAVE read_loop

END IF

-- 这里做你想做的循环的事件

INSERT INTO test.t VALUES (a)

END LOOP

-- 关闭游标

CLOSE cur

END

实例2

[sql] view plain copy

BEGIN

DECLARE Done INT DEFAULT 0

DECLARE CurrentLingQi INT

DECLARE ShizuName VARCHAR(30)

/* 声明游标 */

DECLARE rs CURSOR FOR SELECT NodeName, LingQi FROM socialrelation

/* 异常处理 */

DECLARE CONTINUE HANDLER FOR SQLSTATE '02000' SET Done = 1

/* 打开游标 */

OPEN rs

/* 逐个取出当前记录LingQi字段的值,需要进行最大值的判断 */

FETCH NEXT FROM rs INTO ShizuName, CurrentLingQi

/* 遍历数据表 */

REPEAT

IF NOT Done THEN

SET CurrentLingQi = CurrentLingQi + 60

/* 如果更新后灵气值大于允许的最大值,则就设置为最大值 */

IF CurrentLingQi >= 1800 THEN

UPDATE socialrelation SET LingQi = 1800 WHERE NodeName = ShizuName

ELSE

/* 否则,正常更新 */

UPDATE socialrelation SET LingQi = LingQi + 60 WHERE NodeName = ShizuName

END IF

END IF

FETCH NEXT FROM rs INTO ShizuName, CurrentLingQi

UNTIL Done END REPEAT

/* 关闭游标 */

CLOSE rs

END


欢迎分享,转载请注明来源:内存溢出

原文地址: https://outofmemory.cn/zaji/7211989.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-04-03
下一篇 2023-04-03

发表评论

登录后才能评论

评论列表(0条)

保存