mysql之游标

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

创建游标： 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、创建存储过程

先声明一个游标，语法：

DECLARE v_1 VARCHAR(16)

DECLARE v_2 VARCHAR(16)

DECLARE c_XXX CURSOR FOR

SELECT c_1, c_2

FROM t_1

同时声明一个布尔型的变量FOUND，当循环的条件不成立时，结束循环用的。

DECLARE FOUND BOOLEAN DEFAULT TRUE

DECLARE CONTINUE HANDLER FOR NOT FOUND SET FOUND = FALSE

在使用游标的时候，要先打开游标，语法：OPEN c_XXX

使用的时候，要先打开游标，取出第一条数据，语法： FETCH c_XXX INTO v_1, v_2

然后才开始执行循环，语法：WHILE FOUND DO

执行需要执行的语句；

取下一条数据放到当前游标中，FETCH c_XXX INTO v_1, v_2

结束循环，语法：END WHILE

结束游标，语法：CLOSE c_cargo。有什么问题我们再沟通啊。不知道你具体要问题的是什么。

本文实例讲述了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数据库程序设计有所帮助。

---