如何在MySQL存储过程中捕获中止/终止/连接关闭事件？

架构老林

2026-5-8

如何捕获MySQL存储过程的外部强制终止并记录日志

首先得明确：你遇到的这类外部终止（kill操作、连接断开），MySQL是不会触发存储过程内部的EXIT HANDLER的。因为这种中断是直接终止了整个数据库线程，存储过程的执行上下文被直接销毁，根本没机会执行异常处理代码——这也是你试了各种错误码和SQLSTATE都没用的原因。

不过还是有几种可行的方案来实现你的日志记录需求，下面给你详细说：

1. 用PERFORMANCE_SCHEMA做进程监控

MySQL的performance_schema.threads表可以实时查看所有数据库线程的状态，你可以借助事件调度器定时检查存储过程对应的线程：

首先，确保performance_schema是开启的（默认大部分版本已经开启）
创建一个事件，每隔一段时间（比如5分钟）查询线程信息：

CREATE EVENT monitor_proc_status
ON SCHEDULE EVERY 5 MINUTE
DO
BEGIN
    -- 假设你的存储过程名为`maintain_large_table`
    DECLARE proc_thread_count INT;
    SELECT COUNT(*) INTO proc_thread_count
    FROM performance_schema.threads
    WHERE PROCESSLIST_INFO LIKE '%CALL maintain_large_table%' -- 匹配存储过程调用语句
      AND PROCESSLIST_STATE != 'Killed'; -- 排除已经标记为Killed的线程

    -- 如果之前存在运行中的线程，现在消失了，说明异常终止
    IF proc_thread_count = 0 THEN
        -- 检查最近是否有运行记录（可以维护一个状态表）
        INSERT INTO audit_log (proc_name, event_type, event_time, detail)
        VALUES ('maintain_large_table', '异常终止', NOW(), '线程已消失或被强制终止');
    END IF;
END;

这种方式可以直接监控到线程的存活状态，不过需要注意调整查询条件，确保准确匹配你的存储过程线程。

2. 给存储过程加心跳机制

在存储过程内部定期更新一个心跳表，记录当前的运行时间和进度，然后用另一个监控脚本或事件来检查心跳是否超时：

先创建心跳表：

CREATE TABLE proc_heartbeat (
    proc_name VARCHAR(100) PRIMARY KEY,
    last_heartbeat DATETIME NOT NULL DEFAULT NOW(),
    current_progress VARCHAR(255) COMMENT '当前处理步骤或进度'
);

在存储过程的关键节点（比如每处理完一批数据后）更新心跳：

-- 存储过程内部代码片段
WHILE ... DO
    -- 处理业务逻辑
    -- 更新心跳
    REPLACE INTO proc_heartbeat (proc_name, last_heartbeat, current_progress)
    VALUES ('maintain_large_table', NOW(), CONCAT('已处理', @row_count, '条数据'));
END WHILE;

然后创建监控事件，检查心跳是否超时：

CREATE EVENT check_proc_heartbeat
ON SCHEDULE EVERY 10 MINUTE
DO
BEGIN
    -- 假设存储过程最长运行时间不会超过30分钟，超过则判定为异常终止
    INSERT INTO audit_log (proc_name, event_type, event_time, detail)
    SELECT proc_name, '异常终止', NOW(), CONCAT('心跳超时，最后进度：', current_progress)
    FROM proc_heartbeat
    WHERE proc_name = 'maintain_large_table'
      AND last_heartbeat < DATE_SUB(NOW(), INTERVAL 30 MINUTE);

    -- 处理完后可以重置心跳（如果需要）
    DELETE FROM proc_heartbeat WHERE proc_name = 'maintain_large_table';
END;

这种方式的优势是能记录终止前的最后进度，方便排查问题。

3. 用外部脚本监控

如果MySQL内部的事件调度器不够灵活，你可以写一个shell/Python脚本，定时查询数据库进程列表，监控存储过程的运行状态：

比如shell脚本的大致逻辑：

#!/bin/bash
PROC_NAME="maintain_large_table"
LAST_RUN=$(mysql -u root -p'your_password' -e "SELECT COUNT(*) FROM information_schema.processlist WHERE info LIKE '%CALL $PROC_NAME%'" -N)

if [ $LAST_RUN -eq 0 ]; then
    # 检查是否最近有启动记录（可以从日志或状态表查）
    mysql -u root -p'your_password' -e "INSERT INTO audit_log (proc_name, event_type, event_time) VALUES ('$PROC_NAME', '异常终止', NOW())"
fi

然后把这个脚本加入系统定时任务（比如crontab），每隔一段时间执行一次。这种方式不受MySQL连接的影响，即使存储过程的连接断开，脚本依然能正常运行。

为什么你的HANDLER没用？

你提到的1317（Query execution was interrupted）这类错误，只有当存储过程内部执行的单个SQL语句被中断时才会触发。但如果是直接kill整个连接、网络断开导致连接终止，MySQL会直接销毁线程，不会执行存储过程里的任何后续代码——包括EXIT HANDLER。

总结一下：MySQL没有提供内部机制来捕获这种外部强制终止，必须借助外部监控或者心跳检测的方式来实现日志记录。

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

如何在MySQL存储过程中捕获中止/终止/连接关闭事件？

1. 用PERFORMANCE_SCHEMA做进程监控 #

2. 给存储过程加心跳机制 #

3. 用外部脚本监控 #

为什么你的HANDLER没用？ #

1. 用PERFORMANCE_SCHEMA做进程监控

2. 给存储过程加心跳机制

3. 用外部脚本监控

为什么你的HANDLER没用？