MySQL 游标

在本教程中,您将学习如何在存储过程中使用MySQL 游标来遍历 SELECT 语句返回的结果集。

摘要:在本教程中,您将学习如何在存储过程中使用MySQL 游标来遍历 SELECT 语句返回的结果集。

MySQL游标介绍

要处理存储过程中的结果集,请使用游标。游标允许您迭代查询返回的一组行并单独处理每一行。

MySQL 游标具有只读(Read-only)、不可滚动(Non-scrollable)和敏感(Asensitive)三个特性。

  • 只读:不能通过游标更新底层表中的数据。
  • 不可滚动:您只能按照 SELECT 语句确定的顺序获取行。您不能以相反的顺序获取行。此外,您不能跳过行或跳转到结果集中的特定行。
  • 敏感(Asensitive):游标通常分为敏感游标(asensitive cursor)和不敏感游标(insensitive cursor)。敏感游标直接指向实际数据,而不敏感游标使用数据的临时副本。敏感游标由于不需要创建数据的临时副本,执行速度比不敏感游标更快;但是,其他连接对底层数据所做的更改可能会影响敏感游标正在使用的数据。MySQL 游标属于敏感游标(Asensitive)。

您可以在存储过程、存储函数和触发器中使用 MySQL 游标。

使用 MySQL 游标

首先,使用以下 DECLARE 语句声明一个游标:

DECLARE cursor_name CURSOR FOR SELECT_statement;

游标声明必须在任何变量声明之后。如果在变量声明之前声明游标,MySQL 将发出错误。游标必须始终与 SELECT 语句相关联。

接下来,使用该 OPEN 语句打开游标。该 OPEN 语句初始化游标的结果集,因此,您必须 OPEN 在从结果集中获取行之前调用该语句。

OPEN cursor_name;

然后,使用该 FETCH 语句检索游标指向的下一行,并将游标移动到结果集中的下一行。

FETCH cursor_name INTO variables list;

之后,在获取它之前检查是否有任何可用的行。

最后,使用以下 CLOSE 语句停用游标并释放与其关联的内存:

CLOSE cursor_name;

在不再使用游标时始终关闭游标是一种很好的做法。

使用 MySQL 游标时,您还必须声明一个 NOT FOUND 处理程序来处理游标找不到任何行的情况。

因为每次调用该 FETCH 语句时,游标都会尝试读取结果集中的下一行。当游标到达结果集的末尾时,将无法获取数据,并引发条件。处理程序用于处理这种情况。

要声明 NOT FOUND 处理程序,请使用以下语法:

DECLARE CONTINUE HANDLER FOR NOT FOUND SET finished = 1;

的 finished 是一个变量,以指示该光标已到达结果集的末尾。请注意,处理程序声明必须出现在存储过程中的变量和游标声明之后。

下图说明了 MySQL 游标的工作原理。

MySQL 光标步骤
MySQL 光标步骤

MySQL 游标实例

我们将开发一个存储过程, employees 用于在示例数据库的表中 创建所有员工的电子邮件列表。

首先,声明一些变量、一个用于循环员工电子邮件的游标和一个 NOT FOUND 处理程序:

`DECLARE finished INTEGER DEFAULT 0; DECLARE emailAddress varchar(100) DEFAULT “”;

-- declare cursor for employee email
DEClARE curEmail 
	CURSOR FOR 
		SELECT email FROM employees;

-- declare NOT FOUND handler
DECLARE CONTINUE HANDLER 
    FOR NOT FOUND SET finished = 1;` 

接下来,使用以下 OPEN 语句打开游标:

OPEN curEmail;

然后,迭代电子邮件列表,并连接所有电子邮件,其中每封电子邮件以分号 (;) 分隔:

getEmail: LOOP FETCH curEmail INTO emailAddress; IF finished = 1 THEN LEAVE getEmail; END IF; -- build email list SET emailList = CONCAT(emailAddress,";",emailList); END LOOP getEmail;

之后,在循环内部,我们使用 finished 变量来检查列表中是否有电子邮件以终止循环。

最后,使用以下 CLOSE 语句关闭游标:

CLOSE email_cursor;

该 createEmailList 存储过程如下:

DELIMITER $$
CREATE PROCEDURE createEmailList (
	INOUT emailList varchar(4000)
)
BEGIN
	DECLARE finished INTEGER DEFAULT 0;
	DECLARE emailAddress varchar(100) DEFAULT "";

	-- declare cursor for employee email
	DEClARE curEmail 
		CURSOR FOR 
			SELECT email FROM employees;

	-- declare NOT FOUND handler
	DECLARE CONTINUE HANDLER 
        FOR NOT FOUND SET finished = 1;

	OPEN curEmail;

	getEmail: LOOP
		FETCH curEmail INTO emailAddress;
		IF finished = 1 THEN 
			LEAVE getEmail;
		END IF;
		-- build email list
		SET emailList = CONCAT(emailAddress,";",emailList);
	END LOOP getEmail;
	CLOSE curEmail;

END$$
DELIMITER ;

您可以 createEmailList 使用以下脚本测试存储过程:

SET @emailList = ""; 
CALL createEmailList(@emailList); 
SELECT @emailList;

在本教程中,我们向您展示了如何使用 MySQL 游标来迭代结果集并相应地处理每一行。