Snowflake动态SQL变量超限问题及SQL循环查询实现需求

一、解决变量长度超限错误 #

你的错误根源是Snowflake会话变量（通过SET定义）存在256字节的存储限制，拼接后的SQL_MAIN长度超过了这个阈值。修复方法是改用存储过程内的本地变量（用LET定义），这类变量无长度限制。

修改后的完整存储过程代码：

CREATE OR REPLACE PROCEDURE populate_n_1()
RETURNS INT
LANGUAGE SQL
AS
$$
DECLARE
    d_max_row INT;
    counter INT := 1;
    v_G VARCHAR;
    v_G1 VARCHAR;
    v_P VARCHAR;
    sql_main VARCHAR;
BEGIN
    -- 初始化创建目标表（避免重复创建）
    sql_main := 'CREATE TABLE IF NOT EXISTS N_1 (
                    "DATE" VARCHAR,
                    "COUNT" INT,
                    "GROUP" VARCHAR
                )';
    EXECUTE IMMEDIATE sql_main;

    -- 获取table2总行数
    SELECT COUNT(*) INTO d_max_row FROM table2;

    WHILE counter <= d_max_row DO
        v_G := counter::VARCHAR;
        v_G1 := v_G;
        SELECT "txtstr" INTO v_P FROM table2 WHERE "grouping" = v_G;

        -- 拼接INSERT语句并执行
        sql_main := 'INSERT INTO N_1 ("DATE", "COUNT", "GROUP")
                    SELECT a1.YEARMONTH as "DATE",
                    COUNT(a1.RECORD_NUM) AS "COUNT",
                    ''' || v_G1 || ''' AS "GROUP"
                    FROM table1 a1
                    WHERE ' || v_P || ' GROUP BY YEARMONTH';
        
        EXECUTE IMMEDIATE sql_main;
        counter := counter + 1;
    END WHILE;

    RETURN counter;
END;
$$;

-- 调用存储过程执行逻辑
CALL populate_n_1();

二、纯SQL实现遍历查询（无需存储过程/JavaScript） #

可以通过动态生成所有查询语句并一次性执行的方式实现，核心用LISTAGG拼接所有INSERT语句，再通过EXECUTE IMMEDIATE执行：

步骤1：创建目标表（如果不存在） #

CREATE TABLE IF NOT EXISTS N_1 (
    "DATE" VARCHAR,
    "COUNT" INT,
    "GROUP" VARCHAR
);

步骤2：生成并执行动态SQL #

DECLARE
    combined_sql VARCHAR;
BEGIN
    -- 拼接table2每条记录对应的INSERT语句
    SELECT LISTAGG(
        'INSERT INTO N_1 ("DATE", "COUNT", "GROUP")
         SELECT a1.YEARMONTH as "DATE",
                COUNT(a1.RECORD_NUM) AS "COUNT",
                ''' || "grouping"::VARCHAR || ''' AS "GROUP"
         FROM table1 a1
         WHERE ' || "txtstr" || ' GROUP BY YEARMONTH;',
        ' '
    ) INTO combined_sql
    FROM table2;

    -- 执行拼接后的完整SQL
    EXECUTE IMMEDIATE combined_sql;
END;

注：若table2行数极多，拼接后的SQL可能过长，可按分组分批生成执行。

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