Snowflake中为何无法结合row_number窗口函数执行DELETE去重？

核心原因 #

Snowflake不允许直接在DELETE语句里用ROW_NUMBER()这类窗口函数，主要有两个关键点：

• 执行逻辑不兼容：窗口函数是在查询的SELECT/QUALIFY阶段计算的，依赖全量数据集的分区排序；而DELETE属于数据修改操作，需要精准定位要删除的行。Snowflake的查询优化器不支持把窗口函数的动态计算结果直接作为DELETE的过滤条件，两者的执行流程不匹配。
• 无唯一标识导致行定位不确定：如果你的customer表没有主键或唯一键，仅靠ROW_NUMBER()生成的行号没法唯一锁定要删的行——行号是动态生成的，数据分布或排序规则的微小变化都可能让行号改变，Snowflake为了防止误删，拒绝这种非确定性的删除逻辑。

可行的去重方案 #

方案1：用CTE关联原表删除重复行 #

借助Snowflake的系统字段METADATA$ROW_ID（每个行的唯一内部标识），结合CTE里的窗口函数定位重复项，再关联原表执行删除：

DELETE FROM customer
USING (
    SELECT 
        firstname, lastname, age,
        METADATA$ROW_ID,
        ROW_NUMBER() OVER (PARTITION BY firstname, lastname, age ORDER BY METADATA$ROW_ID) AS rn
    FROM customer
) duplicate_rows
WHERE customer.METADATA$ROW_ID = duplicate_rows.METADATA$ROW_ID
AND duplicate_rows.rn > 1;

方案2：创建去重新表替换原表 #

如果表没有唯一键，这种方式更稳妥：先生成去重后的新表，再替换原表（可保留原表作为备份）：

-- 生成去重后的表
CREATE OR REPLACE TABLE customer_deduped AS
SELECT * FROM customer
QUALIFY ROW_NUMBER() OVER (PARTITION BY firstname, lastname, age ORDER BY METADATA$ROW_ID) = 1;

-- 替换原表（可选，按需操作）
ALTER TABLE customer RENAME TO customer_backup;
ALTER TABLE customer_deduped RENAME TO customer;

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