mysql 存储过程 循环

DELIMITER $$

CREATE PROCEDURE ProcessRecords()
BEGIN
    DECLARE done INT DEFAULT FALSE;
    DECLARE record_id INT;
    DECLARE cur CURSOR FOR SELECT id FROM records;
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;

    OPEN cur;

    read_loop: LOOP
        FETCH cur INTO record_id;
        IF done THEN
            LEAVE read_loop;
        END IF;
        -- 在这里处理每一行数据
        -- 例如：UPDATE records SET status = 'processed' WHERE id = record_id;
    END LOOP;

    CLOSE cur;
END$$

DELIMITER ;

解释说明：

1. DELIMITER $$：更改语句结束符为 $$，以便在存储过程中使用分号。
2. DECLARE done INT DEFAULT FALSE;：声明一个标志变量 done，用于判断循环是否结束。
3. DECLARE record_id INT;：声明一个变量 record_id，用于存储从游标中获取的每一条记录的 ID。
4. DECLARE cur CURSOR FOR SELECT id FROM records;：声明一个游标 cur，用于遍历 records 表中的所有记录。
5. DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;：当游标没有更多记录时，设置 done 为 TRUE。
6. OPEN cur;：打开游标。
7. read_loop: LOOP：开始一个名为 read_loop 的循环。
8. FETCH cur INTO record_id;：从游标中获取下一条记录的 ID 并存入 record_id 变量。
9. IF done THEN LEAVE read_loop; END IF;：如果 done 为 TRUE，则退出循环。
10. -- 在这里处理每一行数据：在循环体内可以添加对每一行数据的处理逻辑。
11. CLOSE cur;：关闭游标。
12. END$$：结束存储过程定义，并恢复默认的语句结束符。