调用存储过程30秒后自动删除失败，遇Error 1357问题求助

错误原因分析 #

错误代码1357的本质是MySQL禁止在存储程序（包括事件Event、存储过程、函数等）内部删除或修改其他存储程序。你之前尝试用Event删除存储过程，而Event本身属于存储程序范畴，因此触发了这个限制。

解决方案一：应用层(Node.js)延迟删除（推荐） #

利用Node.js的定时器，在存储过程调用完成后延迟30秒执行删除操作，完全避开MySQL的存储程序限制，逻辑简单可控。

修改你的代码如下：

module.exports.mainStoredProcedure = async(allQuerys, message) => {
    const spName = `SP_${nanoId}`;
    const mainCallForSP = `
    CREATE PROCEDURE ${spName}()
    BEGIN
       DECLARE errno VARCHAR(300);
       DECLARE text VARCHAR(300);
       DECLARE EXIT HANDLER FOR SQLEXCEPTION, SQLWARNING, NOT FOUND
       BEGIN
        GET CURRENT DIAGNOSTICS CONDITION 1 errno = MYSQL_ERRNO, text = MESSAGE_TEXT;
        SELECT text, errno;
        ROLLBACK;
       END;
       START TRANSACTION;
           ${allQuerys}
       COMMIT WORK;
    END;
    CALL ${spName}();
    CALL checkRules("${message.jobId}","${message.jobType}");
    `;

    let sqlResponse;
    try {
        sqlResponse = await sqlConnection(mainCallForSP);
    } catch (err) {
        if (err.code === "ER_SP_ALREADY_EXISTS") {
            await sleep(3000);
            sqlResponse = await sqlConnection(mainCallForSP);
        } else {
            throw err;
        }
    }

    // 延迟30秒删除存储过程
    setTimeout(async () => {
        try {
            await sqlConnection(`DROP PROCEDURE IF EXISTS ${spName};`);
            console.log(`存储过程 ${spName} 已成功删除`);
        } catch (deleteErr) {
            console.error(`删除存储过程 ${spName} 失败:`, deleteErr);
        }
    }, 30000);

    const result = JSON.parse(JSON.stringify(sqlResponse));
    return result;
};

方案优势 #

• 无需依赖MySQL Event功能，避免权限或配置问题
• 逻辑直接，在应用层即可完成存储过程生命周期管理
• 便于调试和错误处理

解决方案二：数据库层面任务表+常驻Event（适合脱离应用控制的场景） #

如果必须在数据库层面实现，可通过创建任务记录表+常驻定时Event的方式绕开限制：

1. 创建任务记录表

CREATE TABLE IF NOT EXISTS drop_sp_tasks (
    task_id VARCHAR(255) PRIMARY KEY,
    sp_name VARCHAR(255) NOT NULL,
    execute_at DATETIME NOT NULL
);

2. 创建常驻定时Event
   这个Event会每隔5秒扫描任务表，执行到期的存储过程删除操作：

CREATE EVENT IF NOT EXISTS drop_sp_scheduler
ON SCHEDULE EVERY 5 SECOND
DO
BEGIN
    DECLARE done INT DEFAULT FALSE;
    DECLARE target_sp VARCHAR(255);
    -- 声明游标读取到期任务
    DECLARE task_cursor CURSOR FOR 
        SELECT sp_name FROM drop_sp_tasks WHERE execute_at <= CURRENT_TIMESTAMP;
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;

    OPEN task_cursor;
    task_loop: LOOP
        FETCH task_cursor INTO target_sp;
        IF done THEN
            LEAVE task_loop;
        END IF;
        -- 动态执行删除语句
        SET @drop_stmt = CONCAT('DROP PROCEDURE IF EXISTS ', target_sp);
        PREPARE stmt FROM @drop_stmt;
        EXECUTE stmt;
        DEALLOCATE PREPARE stmt;
    END LOOP;
    -- 清理已完成的任务
    DELETE FROM drop_sp_tasks WHERE execute_at <= CURRENT_TIMESTAMP;
END;

注意：需要确保MySQL的Event调度器已开启，执行SET GLOBAL event_scheduler = ON;（需超级权限）

3. 修改应用代码，添加删除任务
   在存储过程调用完成后，向任务表插入一条30秒后执行的删除任务：

// 在获取sqlResponse之后添加
const taskId = nanoId; // 可复用之前的nanoId
const addTaskSql = `
INSERT INTO drop_sp_tasks (task_id, sp_name, execute_at) 
VALUES ("${taskId}", "${spName}", DATE_ADD(CURRENT_TIMESTAMP, INTERVAL 30 SECOND));
`;
await sqlConnection(addTaskSql);

方案注意事项 #

• 需确保Event调度器持续运行，否则任务不会执行
• 定期清理任务表，避免数据冗余
• 动态SQL需注意SQL注入风险（这里spName由应用生成，需确保不可控输入不会进入）

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