MySQL 游标



MySQL 游标

MySQL 游标是一个指针,用于迭代表的记录。它们用于存储程序(如过程和函数)中,并具有以下特性:

  • 只读 - 游标只允许读取数据;不能对其进行修改。

  • 不可滚动 - 游标只能单向移动记录,从上到下。

  • 敏感 - 游标对表中所做的更改敏感。对表所做的任何修改都将反映在游标中。

以下四个操作用于在 MySQL 中管理游标

  • 声明游标

  • 打开游标

  • 获取游标

  • 关闭游标

现在让我们详细了解每个操作。

声明游标

DECLARE 语句用于在 MySQL 中声明游标。声明后,它将与 SELECT 语句关联,以从表中检索记录。

以下是声明游标的语法:

DECLARE cursor_name CURSOR FOR select_statement;

打开游标

OPEN 语句用于在声明游标后初始化游标以检索数据。

以下是打开游标的语法:

OPEN cursor_name;

获取游标

FETCH 语句用于检索游标指向的记录。检索后,游标将移动到下一条记录。

以下是获取游标的语法:

FETCH cursor_name INTO variable_list;

关闭游标

CLOSE 语句用于在检索所有记录后释放与游标关联的内存。

以下是关闭游标的语法:

CLOSE cursor_name;

示例

在此示例中,我们将看到如何在存储过程中管理游标。

假设使用 CREATE TABLE 语句创建了两个表 CUSTOMERS 和 BACKUP。CUSTOMERS 表保存 ID、姓名、年龄、地址和工资等信息,如下所示:

CREATE TABLE CUSTOMERS (
   ID INT NOT NULL,
   NAME VARCHAR (20) NOT NULL,
   AGE INT NOT NULL,
   ADDRESS CHAR (25),
   SALARY DECIMAL (18, 2),
   PRIMARY KEY (ID)
);

现在,我们正在创建 BACKUP 表,其结构与 CUSTOMERS 表相同,用于存储 CUSTOMERS 表记录的副本:

CREATE TABLE BACKUP (
   ID INT NOT NULL,
   NAME VARCHAR (20) NOT NULL,
   AGE INT NOT NULL,
   ADDRESS CHAR (25),
   SALARY DECIMAL (18, 2)
);

现在让我们使用 INSERT 语句将一些记录插入到 CUSTOMERS 表中,如下所示:

INSERT INTO CUSTOMERS VALUES 
(1, 'Ramesh', 32, 'Ahmedabad', 2000.00 ),
(2, 'Khilan', 25, 'Delhi', 1500.00 ),
(3, 'Kaushik', 23, 'Kota', 2000.00 ),
(4, 'Chaitali', 25, 'Mumbai', 6500.00 ),
(5, 'Hardik', 27, 'Bhopal', 8500.00 ),
(6, 'Komal', 22, 'Hyderabad', 4500.00 ),
(7, 'Muffy', 24, 'Indore', 10000.00 );

以下 SQL 查询在 CUSTOMERS 表上创建一个游标:

DECLARE MY_CURSOR CURSOR FOR SELECT * FROM CUSTOMERS;

现在,我们正在创建一个名为 ExampleProc 的存储过程来管理从声明到关闭的游标:

DELIMITER //
CREATE PROCEDURE ExampleProc()
   BEGIN
      -- Variable declarations
      DECLARE done INT DEFAULT 0;
      DECLARE cust_id, cust_age INTEGER;
      DECLARE cust_name VARCHAR(20);
      DECLARE cust_address CHAR(25);
	  DECLARE cust_salary DECIMAL(18,2);
	  
	  -- Cursor declaration
      DECLARE cur CURSOR FOR SELECT * FROM CUSTOMERS;
	  
	  -- Handler for no more records
      DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1;
	  
	  -- Open the cursor
      OPEN cur;
	  
      -- Loop to fetch and insert records
      label: LOOP
      FETCH cur INTO cust_id, cust_name, cust_age, cust_address, cust_salary;
      INSERT INTO backup VALUES(cust_id, cust_name, cust_age, cust_address, cust_salary);
      IF done = 1 THEN LEAVE label;
      END IF;
      END LOOP;
	  
	  -- Close the cursor
      CLOSE cur;
   END//
DELIMITER ;

输出

最后,如果我们使用 CALL ExampleProc(); 调用该过程并检查 BACKUP 表的内容,它将包含与 CUSTOMERS 相同的记录:

SELECT * FROM BACKUP;

获得的 BACKUP 表如下:

ID 姓名 年龄 地址 工资
1 Ramesh 32 Ahmedabad 2000.00
2 Khilan 25 Delhi 1500.00
3 Kaushik 23 Kota 2000.00
4 Chaitali 25 Mumbai 6500.00
5 Hardik 27 Bhopal 8500.00
6 Komal 22 Hyderabad 4500.00
7 Muffy 24 Indore 10000.00
7 Muffy 24 Indore 10000.00
广告