Snowflake中仿照T-SQL实现事务回滚及日志插入的方法（无需存储过程）

Snowflake原生TRY/CATCH语法仅支持在存储过程中使用，无需存储过程的即席SQL脚本场景下，可通过内置系统变量+显式分支判断实现等效逻辑，具体实现如下：

前置准备 #

首先调整会话参数关闭自动提交，开启显式事务支持：

ALTER SESSION SET AUTOCOMMIT = FALSE;
-- 初始化错误标记变量
SET HAS_ERROR = FALSE;

等效TRY/CATCH事务代码 #

BEGIN TRANSACTION;

-- 执行事务内操作，每步后检查执行状态
DELETE FROM mytable;
IF (SQLCODE != 0) THEN
    SET HAS_ERROR = TRUE;
END IF;

IF ($HAS_ERROR = FALSE) THEN
    INSERT INTO mytable VALUES (5);
    IF (SQLCODE != 0) THEN
        SET HAS_ERROR = TRUE;
    END IF;
END IF;

IF ($HAS_ERROR = FALSE) THEN
    INSERT INTO mytable VALUES ('hello');
    IF (SQLCODE != 0) THEN
        SET HAS_ERROR = TRUE;
    END IF;
END IF;

-- 最终提交/回滚逻辑
IF ($HAS_ERROR = FALSE) THEN
    COMMIT;
ELSE
    ROLLBACK;
    -- 写入错误日志，可使用内置SQLERRM变量获取具体报错信息
    INSERT INTO LOGTABLE ("ERROR_CONTENT", "OCCUR_TIME") VALUES (:SQLERRM, CURRENT_TIMESTAMP);
    -- 主动抛出错误，等效于T-SQL的RAISERROR
    SELECT RAISE_ERROR('error', 1, 1);
END IF;

-- 按需恢复会话默认自动提交配置
ALTER SESSION SET AUTOCOMMIT = TRUE;

关键说明 #

• SQLCODE、SQLERRM均为Snowflake内置会话级变量，每次SQL执行后自动更新：SQLCODE返回0表示执行成功，非0表示执行失败；SQLERRM返回最后一次报错的详细文本
• 该方案全程无存储过程依赖，可直接在Snowflake工作表、SQL脚本工具中顺序执行
• 所有事务内操作均为原子性，任意一步出错都会触发全量回滚，和原T-SQL逻辑效果一致

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