Snowflake SQL脚本：将COPY INTO结果集存入审计表失败求助

开发者阿泽

2026-6-15

解决Snowflake存储过程中COPY INTO结果插入审计表的语法错误问题

问题分析

你的报错根源在于Snowflake的RESULTSET对象仅支持一次性消费，同时用它执行INSERT...SELECT和RETURN TABLE()会触发执行逻辑冲突，进而导致语法报错。直接对同一RESULTSET调用两次TABLE()也不符合Snowflake的执行规则。

解决办法

先将COPY INTO的结果转存到临时表，再通过临时表完成审计表插入和结果返回操作，规避RESULTSET的一次性消费限制。

修改后的代码示例：

DECLARE
    v_rs RESULTSET;
    v_temp_table STRING := 'TEMP_COPY_AUDIT_RESULTS';
BEGIN
    -- 执行COPY INTO命令获取结果集
    v_rs := (EXECUTE IMMEDIATE v_copy_into_cmd);
    
    -- 创建临时表存储结果集（已存在则替换）
    EXECUTE IMMEDIATE 'CREATE OR REPLACE TEMPORARY TABLE ' || v_temp_table || ' AS SELECT * FROM TABLE(?)' USING v_rs;
    
    -- 将结果插入审计表
    INSERT INTO yustage.events_engine_audit 
    (
        file_name,
        status,
        rows_parsed,
        rows_loaded,
        error_limit,
        errors_seen,
        first_error,
        first_error_line,
        first_error_character,
        first_error_column_name
    )
    SELECT 
        file_name,
        status,
        rows_parsed,
        rows_loaded,
        error_limit,
        errors_seen,
        first_error,
        first_error_line,
        first_error_character,
        first_error_column_name
    FROM IDENTIFIER(v_temp_table);
    
    -- 返回COPY INTO的结果
    RETURN TABLE(EXECUTE IMMEDIATE 'SELECT * FROM ' || v_temp_table);
END;