Snowflake存储过程STATEMENT_ERROR报错：无效标识符ID排查

核心报错原因 #

报错invalid identifier 'ID'及编译错误主要由以下问题导致：

• 语法结构错误：原代码中end if;后直接跟else，无匹配的IF分支，导致SQL编译逻辑混乱，编译器误将后续代码中的Id识别为无效标识符。
• JSON路径大小写不匹配：Snowflake的JSON属性名区分大小写，若data字段中实际存储的是小写id而非大写Id，parse_json(record.data):Id::varchar会因找不到对应属性触发类似错误。
• 表名不一致：代码混用public.leads_history_cdc和public.history_cdc，读取元数据与写入数据用不同表名，既破坏逻辑一致性，也可能引发编译/运行时异常。
• 冗余游标逻辑：用游标遍历临时表属于低效操作，批量SQL即可完成相同逻辑，且能减少出错概率。

修复后的完整代码 #

create or replace procedure public.proc_get_cdc()
returns varchar(16777216)
language sql
execute as owner
as 
$$
declare
    max_meta_created timestamp_ntz;
begin
    -- 创建临时表存储流数据，避免污染永久表空间
    create or replace temporary table public.streams_static as select * from public.dummy_streams;

    -- 统一读取目标表的最大元数据创建时间
    select max(meta_created) into max_meta_created from public.history_cdc;

    if (max_meta_created is null) then
        -- 首次执行：全量初始化插入
        insert into public.history_cdc(data, meta_created, meta_updated, meta_start, meta_expiry, meta_active_row, meta_operation) 
        select 
            parse_json(data), 
            meta_created, 
            meta_updated, 
            current_date, 
            '2049-12-31'::date, 
            true, 
            METADATA$ACTION 
        from public.streams_static;
    else
        -- 批量标记历史活跃数据失效
        update public.history_cdc h
        set 
            meta_expiry = s.meta_created,
            meta_operation = 'delete',
            meta_active_row = false,
            meta_updated = s.meta_created
        from public.streams_static s
        where parse_json(h.data):id::varchar = parse_json(s.data):id::varchar
            and h.meta_active_row = true;

        -- 批量插入新的活跃数据
        insert into public.history_cdc(data, meta_created, meta_updated, meta_active_row, meta_operation, meta_start, meta_expiry)
        select 
            parse_json(data), 
            current_date, 
            current_date, 
            true, 
            'insert', 
            current_date, 
            '2049-12-31'::date 
        from public.streams_static;
    end if;

    drop table public.streams_static;

    return 'CDC同步完成';
end;
$$;

关键修复说明 #

1. 修正IF-ELSE语法结构，确保分支逻辑合法
2. 统一所有表引用为public.history_cdc，消除表名不一致问题
3. 替换游标循环为批量SQL操作，大幅提升执行效率
4. 统一JSON属性名大小写（若实际为大写Id，请将代码中id改回Id）
5. 将临时表改为会话级临时表，避免影响其他会话
6. 给日期常量添加类型转换，避免隐式转换错误

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