在数据库日常运行中，SQL语句执行异常是常见的问题，若无法快速获取异常对应的原始SQL和错误堆栈，会大幅增加排查难度。通过触发器可以在SQL执行的关键节点捕获异常信息，自动记录相关内容到指定表中。
实现原理说明
触发器的核心作用是在特定数据库操作（如INSERT、UPDATE、DELETE等）执行时自动触发预设逻辑。我们可以在触发器中嵌入异常捕获逻辑，当执行的SQL出现错误时，获取当前的SQL语句文本、错误码、错误描述以及调用堆栈信息，再将这些内容写入专门的异常记录表，后续可以直接查询该表获取异常详情。
准备工作：创建异常记录表
首先需要创建一个用于存储异常信息的表，用来保存捕获到的SQL语句、错误堆栈等内容，不同数据库的类型定义略有差异，以下是MySQL的示例：
-- 创建异常记录表
CREATE TABLE IF NOT EXISTS sql_exception_log (
id INT PRIMARY KEY AUTO_INCREMENT COMMENT '自增ID',
execute_sql TEXT COMMENT '执行的SQL语句',
error_code VARCHAR(50) COMMENT '错误码',
error_msg TEXT COMMENT '错误描述',
error_stack TEXT COMMENT '错误堆栈信息',
occur_time DATETIME DEFAULT CURRENT_TIMESTAMP COMMENT '异常发生时间'
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='SQL异常执行记录表';
触发器实现示例（MySQL）
MySQL的触发器本身不支持直接捕获异常，需要结合存储过程来实现，以下是完整的实现步骤：
1. 创建带异常捕获的存储过程
先创建一个存储过程，在存储过程中执行目标SQL，同时捕获可能出现的异常，将信息写入记录表：
DELIMITER //
CREATE PROCEDURE execute_sql_with_log(IN target_sql TEXT)
BEGIN
-- 声明异常捕获变量
DECLARE err_code VARCHAR(50) DEFAULT '';
DECLARE err_msg TEXT DEFAULT '';
DECLARE err_stack TEXT DEFAULT '';
-- 声明继续处理器，捕获所有异常
DECLARE CONTINUE HANDLER FOR SQLEXCEPTION
BEGIN
-- 获取错误码和错误信息
GET DIAGNOSTICS CONDITION 1
err_code = MYSQL_ERRNO,
err_msg = MESSAGE_TEXT;
-- 这里可以结合自定义逻辑获取堆栈信息，MySQL本身无直接获取堆栈的函数，可通过自定义变量记录调用链
SET err_stack = '存储过程execute_sql_with_log执行异常';
-- 将异常信息写入记录表
INSERT INTO sql_exception_log (execute_sql, error_code, error_msg, error_stack)
VALUES (target_sql, err_code, err_msg, err_stack);
END;
-- 执行传入的SQL语句
SET @sql = target_sql;
PREPARE stmt FROM @sql;
EXECUTE stmt;
DEALLOCATE PREPARE stmt;
END //
DELIMITER ;
2. 创建调用存储过程的触发器
针对需要监控的表创建触发器，在触发器执行时调用上述存储过程，传入当前操作的SQL逻辑：
-- 以user表为例，创建UPDATE操作的触发器
DELIMITER //
CREATE TRIGGER trg_user_update_log
BEFORE UPDATE ON user
FOR EACH ROW
BEGIN
-- 构造当前UPDATE操作的SQL语句
SET @current_sql = CONCAT('UPDATE user SET ',
'name = ''', NEW.name, ''', ',
'age = ', NEW.age, ' ',
'WHERE id = ', OLD.id);
-- 调用存储过程执行SQL并记录异常
CALL execute_sql_with_log(@current_sql);
END //
DELIMITER ;
其他数据库的实现差异
不同数据库的触发器语法和异常捕获能力不同，以下是常见数据库的差异说明：
| 数据库类型 | 异常捕获支持 | 实现要点 |
|---|---|---|
| Oracle | 原生支持EXCEPTION块捕获异常 | 可直接在触发器中使用EXCEPTION关键字捕获异常，通过SQLERRM获取错误信息，DBMS_UTILITY.FORMAT_ERROR_BACKTRACE获取错误堆栈 |
| PostgreSQL | 支持EXCEPTION块捕获异常 | 在PL/pgSQL语法的触发器中，使用BEGIN...EXCEPTION...END结构捕获异常，通过SQLSTATE和SQLERRM获取错误相关信息 |
| SQL Server | 支持TRY...CATCH结构 | 在触发器中嵌入TRY...CATCH块，捕获异常后通过ERROR_NUMBER()、ERROR_MESSAGE()等函数获取错误详情 |
注意事项
- 触发器会增加SQL执行的额外开销，建议只对核心业务表的关键操作设置异常捕获触发器，避免影响整体性能。
- 异常记录表需要定期清理历史数据，避免表数据量过大影响写入和查询效率。
- 部分数据库的错误堆栈获取需要开启对应的调试参数，使用前需要确认数据库的配置是否支持。
- 构造执行SQL时需要注意特殊字符的转义，避免出现SQL注入或者语法错误。
Oracle触发器示例参考
以下是Oracle数据库中直接通过触发器捕获异常的示例，无需额外存储过程：
-- 创建Oracle异常记录表
CREATE TABLE sql_exception_log (
id NUMBER PRIMARY KEY,
execute_sql CLOB,
error_code VARCHAR2(50),
error_msg CLOB,
error_stack CLOB,
occur_time DATE DEFAULT SYSDATE
);
-- 创建序列用于自增ID
CREATE SEQUENCE seq_exception_log_id START WITH 1 INCREMENT BY 1;
-- 创建触发器
CREATE OR REPLACE TRIGGER trg_user_update_log
BEFORE UPDATE ON user
FOR EACH ROW
DECLARE
v_sql CLOB;
v_err_code VARCHAR2(50);
v_err_msg CLOB;
v_err_stack CLOB;
BEGIN
-- 构造当前执行的SQL
v_sql := 'UPDATE user SET name = ''' || :NEW.name || ''', age = ' || :NEW.age || ' WHERE id = ' || :OLD.id;
-- 这里可以执行正常的业务逻辑，若出现异常则进入EXCEPTION块
-- 模拟可能出错的场景，实际使用时可去掉该部分
-- RAISE_APPLICATION_ERROR(-20001, '测试异常');
EXCEPTION
WHEN OTHERS THEN
v_err_code := SQLCODE;
v_err_msg := SQLERRM;
v_err_stack := DBMS_UTILITY.FORMAT_ERROR_BACKTRACE;
INSERT INTO sql_exception_log (id, execute_sql, error_code, error_msg, error_stack)
VALUES (seq_exception_log_id.NEXTVAL, v_sql, v_err_code, v_err_msg, v_err_stack);
END;
/