Snowflake中INSERT ALL语句WHEN子句执行逻辑与去重插入问题

1. WHEN子句是否会为每行添加虚拟字段后再执行批量加载 #

是的。Snowflake执行INSERT ALL时的处理逻辑如下：

• 首先执行末尾的SELECT语句，拿到所有待处理的源行数据集
• 逐行扫描源数据集，对每一行执行所有WHEN条件的评估，将布尔类型的判定结果作为临时虚拟字段附加到该行上
• 所有条件评估完成后，批量执行匹配到的INSERT操作，不需要逐行提交请求

2. 给定INSERT ALL语句的WHEN评估逻辑、NOT IN写法报错原因 #

评估逻辑 #

你使用的语句：

INSERT ALL
WHEN (SELECT COUNT(*) FROM DEST WHERE DEST.ID = NEW_ID) = 0 THEN
INSERT INTO DEST (ID) VALUES (NEW_ID)
SELECT NEW_ID FROM SRC

Snowflake会对SRC返回的每个NEW_ID，逐行执行WHEN后的标量子查询，统计该ID在DEST表的出现次数，将次数是否为0的布尔结果作为判定依据。

NOT IN写法报错原因 #

这是Snowflake INSERT ALL的语法限制：WHEN子句仅支持标量表达式的等值/不等值比较，不支持直接使用IN/NOT IN这类集合运算作为顶层判定条件。

关于虚拟列的额外确认 #

你的理解正确，Snowflake确实会先为所有源行生成存储WHEN判定结果的布尔临时虚拟列，筛选出判定为true的行后统一批量插入，不会逐行触发插入操作。 #

扩展建议：你的需求是插入不存在的新记录，更推荐使用MERGE语句实现，语法更简洁，执行效率也更高，参考写法：

MERGE INTO DEST d
USING SRC s ON d.ID = s.NEW_ID
WHEN NOT MATCHED THEN INSERT (ID) VALUES (s.NEW_ID);

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