Snowflake中Merge Into引用子查询结果出现语法错误问题排查

原问题分析 #

你遇到的syntax error line 19 at position 4 unexpected 'WHEN'首先是CTE语法错误，其次是Snowflake Merge不支持直接用子查询动态生成列定义。

原语句的两个核心问题 #

1. CTE末尾多余逗号：sql_prepare_merge AS (...)后面的逗号必须删除，CTE列表最后一项不能带逗号
2. Merge不支持动态子查询嵌入：Snowflake的SQL解析器在编译阶段需要明确知道UPDATE SET、INSERT的列信息，不能用(select update_columns from sql_prepare_merge)这种动态子查询直接替代静态列定义

分步解决方案 #

第一步：修正基础语法错误（解决即时报错） #

先删掉CTE后的逗号，修正后的静态语句示例（如果不需要动态列）：

WITH sql_prepare_merge AS (
    SELECT * FROM another_table
)
MERGE INTO bank_raw AS target
USING bank AS source
    ON source.id = target.id
WHEN MATCHED THEN
    UPDATE SET target.BANK_NAME = source.BANKNAME
WHEN NOT MATCHED THEN
    INSERT (ID, BANK_NAME)
    VALUES (source.id, source.BANKNAME);

第二步：实现动态列的Merge（满足你的原始需求） #

因为Snowflake不支持Merge语句内直接动态生成列，需要用动态SQL结合Snowflake Scripting来实现：

DECLARE
    v_insert_cols STRING;
    v_update_cols STRING;
    v_merge_sql STRING;
BEGIN
    -- 从准备表中获取列定义（确保仅返回一行，可加LIMIT 1）
    SELECT INSERT_COLUMNS, UPDATE_COLUMNS
    INTO v_insert_cols, v_update_cols
    FROM another_table
    LIMIT 1;

    -- 拼接完整的Merge语句
    v_merge_sql := 'MERGE INTO bank_raw AS target
        USING bank AS source
            ON source.id = target.id
        WHEN MATCHED THEN
            UPDATE SET ' || v_update_cols || '
        WHEN NOT MATCHED THEN
            INSERT (ID, ' || v_insert_cols || ')
            VALUES (source.id, source.' || REPLACE(v_insert_cols, ', ', ', source.') || ')';

    -- 执行动态生成的SQL
    EXECUTE IMMEDIATE v_merge_sql;
END;

关键说明：

• 用变量存储从another_table获取的列定义，再拼接成完整的Merge语句
• REPLACE函数用于给INSERT的VALUES部分的每个列自动加上source.前缀，适配多列场景
• 如果another_table有多行列定义，必须用LIMIT 1或过滤条件确保只取一组列规则

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