MySQL游标

时间:2019-11-20 08:52:30  来源:igfitidea点击:

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

MySQL游标简介

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

MySQL游标是只读的,不可滚动的并且不敏感。

  • 只读:您无法通过游标更新基础表中的数据。

  • 不可滚动:您只能按SELECT语句确定的顺序获取行。
    您不能以相反的顺序获取行。
    此外,您不能跳过行或跳到结果集中的特定行。

  • 非敏感游标:有两种游标:非敏感游标和非敏感游标。
    不敏感的游标指向实际数据,而不敏感的游标使用数据的临时副本。
    不敏感的游标比不敏感的游标执行得更快,因为它不必制作数据的临时副本。
    但是,对来自其他连接的数据所做的任何更改都会影响非敏感游标正在使用的数据,因此,如果不更新非敏感游标正在使用的数据,则将更加安全。
    MySQL游标不敏感。

您可以在存储过程,存储函数和触发器中使用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;

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

下图说明了MySQL游标的工作方式。

MySQL游标示例

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

首先,声明一些变量,用于遍历员工电子邮件的游标和一个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;

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

最后,使用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游标迭代结果集并相应地处理每一行。