当前位置:首页 » 存储配置 » mysql存储过程游标遍历

mysql存储过程游标遍历

发布时间: 2022-07-01 18:19:41

① mysql存储过程的时候,当游标遍历结束后怎么让他跳出

DECLARE CONTINUE HANDLER FOR SQLSTATE '02000' SET DONE = 1;
这种语句是异常捕获内容,在mysql中都是使用HANDLER 来捕获异常的。

建议你看下:MySQL存储过程详解
MySQL游标循环遍历的使用

② mysql存储过程游标循环用哪种比较好

如果没有则插入数据,如果有则更新的方法:
insert into `test` values (a,b) ON DUPLICATE KEY UPDATE `a`=c;

[sql] view plain
CREATE PROCEDURE `test`.`new_procere` ()
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
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

③ MySql 存储过程遍历游标出错

MySql 存储过程遍历游标出错
DECLARE CONTINUE HANDLER FOR SQLSTATE '02000' SET DONE = 1;
这种语句是异常捕获内容,在mysql中都是使用HANDLER 来捕获异常的。

建议你看下:MySQL存储过程详解
MySQL游标循环遍历的使用

④ mysql里怎样循环遍历游标

传入id,输出name和sex的存储过程,这里同个id有多条数据,所以需要用到游标。
DELIMITER // CREATE PROCEDURE p5(IN v_id INT) BEGIN DECLARE nodata INT DEFAULT 0;#注意:这个变量声明必须放在游标声明前面DECLARE v_name VARCHAR(30); DECLARE v_sex CHAR(3); DECLARE c_ns CURSOR FOR SELECT NAME,sex FROM t WHERE id = v_id; DECLARE EXIT HANDLER FOR NOT FOUND SET nodata = 1;#当读到数据的最后一条时,设置变量为1 OPEN c_ns; WHILE nodata = 0 DO#判断是不是到了最后一条数据FETCH c_ns INTO v_name,v_sex; SELECT v_name,v_sex,nodata; END WHILE; CLOSE c_ns; END //

⑤ mysql存储过程游标结果集时,数据没有遍历完整

CREATEDEFINER=`root`@`%`PROCEDURE`insertPresale`()
BEGIN
#Routinebodygoeshere...
DECLAREdoneINTDEFAULT0;/*用于判断是否结束循环*/
DECLAREgoodsIdVARCHAR(255);#标记商品id
DECLAREflagINTDEFAULT0;#标记数据库是否包含此条商品记录
/*用于存储结果集的记录*/
/*定义游标*/
_idFROM`sys_goods_publish`WHEREpresale=1ANDpresale_time<=NOW();
/*定义设置循环结束标识done值怎么改变的逻辑*/
=1;/*done=true;亦可*/
OPENidCur;/*打开游标*/
/*循环开始*/
REPEAT
#/*如果要fetch多列应该这样写,fetchcur/*对应下面的idCur*/
FETCHidCurINTOgoodsId;/*还可以fetch多列(假设结果集的记录不是单列的话)*/
IFNOTdoneTHEN/*数值为非0,MySQL认为是true*/
SELECTCOUNT(*)INTOflagFROM`itemsinfonew`WHERETaoBaoitemId=goodsId;
IF(flag>0)THEN#如果数据库中有爬取此条记录则删除已用户发布的为准
DELETEFROM`itemsinfonew`WHERETaoBaoitemId=goodsId;
ENDIF;
INSERTINTO`itemsinfonew`(TaoBaoitemId,CouponID,CreateSourceName)
SELECTgoods_id,coupon_id,SUBSTRING("customer_fd",0.5)
FROM`sys_goods_publish`
WHEREpresale_time<=NOW()ANDgoods_id=goodsId;
UPDATE`sys_goods_publish`SETpresale=0WHEREpresale=1ANDpresale_time<=NOW()ANDgoods_id=goodsId;
ENDIF;
UNTILdoneENDREPEAT;
CLOSEidCur;/*关闭游标*/

⑥ mysql存储过程从表的第二条记录开始遍历,怎么使用游标

在老版本的MySQL3.22中,MySQL的单表限大小为4GB,当时的MySQL的存储引擎还是ISAM存储引擎。但是,当出现MyISAM存储引擎之后,也就是从MySQL3.23开始,MySQL单表最大限制就已经扩大到了64PB了(官方文档显示)。也就是说,从目前的技术环境来看,MySQL数据库的MyISAM存储引擎单表大小限制已经不是有MySQL数据库本身来决定,而是由所在主机的OS上面的文件系统来决定了。而MySQL另外一个最流行的存储引擎之一Innodb存储数据的策略是分为两种的,一种是共享表空间存储方式,还有一种是独享表空间存储方式。当使用共享表空间存储方式的时候,Innodb的所有数据保存在一个单独的表空间里面,而这个表空间可以由很多个文件组成,一个表可以跨多个文件存在,所以其大小限制不再是文件大小的限制,而是其自身的限制。从Innodb的官方文档中可以看到,其表空间的最大限制为64TB,也就是说,Innodb的单表限制基本上也在64TB左右了,当然这个大小是包括这个表的所有索引等其他相关数据。而当使用独享表空间来存放Innodb的表的时候,每个表的数据以一个单独的文件来存放,这个时候的单表限制,又变成文件系统的大小限制了。

⑦ mysql存储过程里怎么循环一张表

游标遍历即可

⑧ Mysql存储过程中游标的用法实例

本文实例讲述了Mysql存储过程中游标的用法。分享给大家供大家参考。具体如下:
1.
批量插入商户路由关联数据:
DELIMITER
$$
USE
`mmm_mac`$$
DROP
PROCEDURE
IF
EXISTS
`批量插入商户路由关联数据`$$
CREATE
DEFINER=`root`@`%`
PROCEDURE
`批量插入商户路由关联数据`()
BEGIN
DECLARE
v_partner_no
VARCHAR(32);
DECLARE
v_partner_id
INT(11);
DECLARE
v_sc_pid
INT(11);
DECLARE
v_mac_no
VARCHAR(32);
DECLARE
v_mac_addr
VARCHAR(32);
DECLARE
n_mac_no
BIGINT;
DECLARE
n_mac_addr
BIGINT;
DECLARE
n_mac_addr_str
VARCHAR(32);
DECLARE
done
INT;
#取得商户数据
DECLARE
cur_partnerlist
CURSOR
FOR
SELECT
comp_id,
partner_no,
sc_pid
FROM
mmm_partner.anl_partner;
SET
n_mac_no
=
100000000;
SET
n_mac_addr
=
1000000000;
OPEN
cur_partnerlist;
REPEAT
FETCH
cur_partnerlist
INTO
v_partner_id,v_partner_no,v_sc_pid;
SET
v_mac_no
=
CONCAT('MAC',v_sc_pid,n_mac_no);
SET
n_mac_addr_str
=
CONCAT(SUBSTR(n_mac_addr,1,2),':',SUBSTR(n_mac_addr,3,2),':',SUBSTR(n_mac_addr,5,2),':',SUBSTR(n_mac_addr,7,2),':',SUBSTR(n_mac_addr,9,2));
SET
v_mac_addr
=
CONCAT('CC:',n_mac_addr_str);
SET
n_mac_no
=
n_mac_no
+
1;
SET
n_mac_addr
=
n_mac_addr
+
1;
#向t_machine_sc_config表中插入商户关联路由的数据
#insert
into
t_machine_sc_config(mac_no,
partner_no,
partner_id,
sc_pid,
mac_addr,
comp_id,
is_lock)
values('MAC2016000000001','44060430603381',1,4403,'C8:87:18:AB:79:66',1,1);
INSERT
INTO
t_machine_sc_config(mac_no,
partner_no,
partner_id,
sc_pid,
mac_addr,
comp_id,
is_lock)
VALUES(v_mac_no,v_partner_no,v_partner_id,v_sc_pid,v_mac_addr,1,1);
UNTIL
0
END
REPEAT;
CLOSE
cur_partnerlist;
END$$
DELIMITER
;
2.
更新商户表:
DELIMITER
$$
USE
`mmm_partner`$$
DROP
PROCEDURE
IF
EXISTS
`更新商户表`$$
CREATE
DEFINER=`root`@`%`
PROCEDURE
`更新商户表`()
BEGIN
DECLARE
v_partner_no
VARCHAR(32);
DECLARE
vpartner_no
VARCHAR(32);
DECLARE
v_partner_id
VARCHAR(32);
DECLARE
n
BIGINT;
DECLARE
partnerid_list
CURSOR
FOR
SELECT
comp_id
FROM
100msh_partner.anl_partner
WHERE
TRIM(partner_no)
=
'';
SET
vpartner_no
=
'2015415parno';
SET
n
=
10000000;
OPEN
partnerid_list;
REPEAT
FETCH
partnerid_list
INTO
v_partner_id;
SET
v_partner_no
=
CONCAT(vpartner_no,n);
SET
n
=
n
+
1;
UPDATE
mmm_partner.anl_partner
SET
partner_no
=
v_partner_no
WHERE
comp_id
=
v_partner_id;
UNTIL
0
END
REPEAT;
CLOSE
partnerid_list;
END$$
DELIMITER
;
希望本文所述对大家的mysql数据库程序设计有所帮助。

⑨ mysql 存储过程过程 循环游标

游标关闭条件

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

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

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;

热点内容
电脑怎么查卡配置 发布:2025-01-14 20:01:29 浏览:26
手机怎么控制服务器 发布:2025-01-14 19:58:46 浏览:306
php难招 发布:2025-01-14 19:06:07 浏览:489
sublime编译php 发布:2025-01-14 18:57:16 浏览:307
云计算服务器是什么 发布:2025-01-14 18:56:22 浏览:44
vip域名查询ftp 发布:2025-01-14 18:46:48 浏览:116
格式化linux 发布:2025-01-14 18:35:14 浏览:595
如何进入安卓原生市场 发布:2025-01-14 18:22:06 浏览:560
台式电脑找不到服务器 发布:2025-01-14 18:19:58 浏览:423
androidsdk网盘 发布:2025-01-14 18:17:43 浏览:82