基于SELECT语句的带LOOP的MySQL Event实现需求及代码求助

原代码核心问题 #

• 游标声明必须放在代码块最开头，不能嵌套在循环内
• 无法直接在游标中拼接动态表名，必须用动态SQL实现
• 缺少游标遍历结束的处理逻辑（未定义NOT FOUND处理器）
• 需求表名与代码表名不匹配（需求是companies，代码用了organizations）

最终实现代码 #

-- 确保事件调度器已开启（若未开启）
SET GLOBAL event_scheduler = ON;

-- 创建每小时执行的事件
CREATE EVENT IF NOT EXISTS sync_company_data
ON SCHEDULE EVERY 1 HOUR
STARTS CURRENT_TIMESTAMP
DO
BEGIN
    -- 声明变量与结束处理器
    DECLARE done INT DEFAULT 0;
    DECLARE _company_id INT; -- 根据实际字段类型调整，若为字符串需改为VARCHAR
    
    -- 游标：获取所有company_id
    DECLARE cur_companies CURSOR FOR 
        SELECT company_id FROM companies;
    
    -- 标记游标遍历结束
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1;

    -- 开启游标循环处理每个公司
    OPEN cur_companies;
    company_loop: LOOP
        FETCH cur_companies INTO _company_id;
        IF done = 1 THEN
            LEAVE company_loop;
        END IF;

        -- 动态拼接SQL：从对应表取数据并插入resulttable
        SET @sql = CONCAT(
            'INSERT INTO resulttable (id, fid) ',
            'SELECT ', _company_id, ', fid ',
            'FROM table_', _company_id, ' ',
            'WHERE 1=1' -- 替换为你的实际筛选条件
        );
        
        -- 执行动态SQL
        PREPARE stmt FROM @sql;
        EXECUTE stmt;
        DEALLOCATE PREPARE stmt;

    END LOOP company_loop;
    CLOSE cur_companies;
END;

关键说明 #

1. 动态SQL处理：通过CONCAT拼接表名与查询逻辑，解决不同company对应不同表的问题；若company_id是字符串类型，拼接时需给_company_id加单引号
2. 游标结束控制：通过DECLARE CONTINUE HANDLER FOR NOT FOUND标记循环结束条件，避免死循环
3. 事件调度规则：EVERY 1 HOUR指定每小时执行一次，STARTS CURRENT_TIMESTAMP表示从当前时间开始生效
4. 类型适配：_company_id的类型需与companies.company_id的实际类型完全匹配

内容的提问来源于stack exchange，提问作者renevdkooi