无写入权限时，如何在Snowflake中编写遍历查询的存储过程？

由于无写入权限，无法借助临时表/永久表存储中间数据，我们可以通过**游标(CURSOR)**遍历QUERY1的结果，结合CTE执行QUERY2并逐步汇总数据，最终返回合并后的结果集。

核心实现逻辑 #

1. 用CTE定义QUERY1，获取待遍历的date和serial number集合；
2. 声明游标遍历QUERY1的每一行数据；
3. 将当前行的date和serial number作为参数传入QUERY2（支持嵌套CTE），获取对应详情；
4. 把每次QUERY2的结果逐步合并到临时结果集中；
5. 返回最终汇总的完整结果。

示例代码 #

CREATE OR REPLACE PROCEDURE get_aggregated_details()
RETURNS TABLE (
    report_date DATE,
    serial_num VARCHAR,
    detail_col1 INT,
    detail_col2 VARCHAR,
    total_amount NUMERIC
)
LANGUAGE SQL
AS
$$
DECLARE
    -- 基于QUERY1的CTE声明游标
    cur CURSOR FOR
        WITH query1 AS (
            -- 替换为你的QUERY1逻辑，获取目标date和serial number
            SELECT 
                transaction_date AS report_date,
                device_serial AS serial_num
            FROM source_table
            WHERE transaction_date >= DATEADD(month, -1, CURRENT_DATE())
        )
        SELECT report_date, serial_num FROM query1;
    rec RECORD;
    -- 用于存储单次QUERY2结果的变量
    temp_result RESULTSET;
    -- 存储最终汇总结果的变量
    final_result RESULTSET;
BEGIN
    -- 初始化空结果集，用于后续合并
    final_result := (SELECT * FROM VALUES (NULL::DATE, NULL::VARCHAR, NULL::INT, NULL::VARCHAR, NULL::NUMERIC) WHERE 1=0);
    
    -- 遍历QUERY1的每一行数据
    FOR rec IN cur DO
        -- 执行QUERY2，传入当前行的date和serial number作为过滤条件
        temp_result := (
            WITH query2 AS (
                -- 替换为你的QUERY2逻辑，实现详情查询与汇总
                SELECT
                    rec.report_date AS report_date,
                    rec.serial_num AS serial_num,
                    detail_col1,
                    detail_col2,
                    SUM(amount) AS total_amount
                FROM detail_table
                WHERE 
                    event_date = rec.report_date
                    AND device_serial = rec.serial_num
                GROUP BY rec.report_date, rec.serial_num, detail_col1, detail_col2
            )
            SELECT * FROM query2
        );
        
        -- 将当前QUERY2的结果合并到最终结果集
        final_result := (SELECT * FROM TABLE(final_result) UNION ALL SELECT * FROM TABLE(temp_result));
    END FOR;
    
    -- 返回汇总后的完整结果
    RETURN TABLE(final_result);
END;
$$;

关键说明 #

• 无写入依赖：全程仅使用查询操作，无需创建表或写入数据的权限；
• CTE兼容：QUERY1和QUERY2都可以用CTE组织复杂逻辑，适配你的权限限制；
• 结果合并：通过RESULTSET变量逐步累积QUERY2的结果，最终返回完整汇总表；
• 灵活适配：可根据实际需求修改QUERY1和QUERY2的逻辑，调整返回字段。

调用方式 #

CALL get_aggregated_details();

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