Snowflake中使用CTE结合While循环插入表的正确语法问询

以下是修正后的Snowflake存储过程代码，解决了原代码中的语法问题并优化了逻辑：

EXECUTE IMMEDIATE $$ 
DECLARE
  end_period INT DEFAULT 10;
  start_period INT DEFAULT 0;
BEGIN 
  -- 修正循环条件，避免无限循环（根据需求调整，此处假设需要遍历start_period从0到end_period初始值）
  WHILE (start_period < end_period) DO  
    WITH cte_example AS (
       SELECT 
          account_id, 
          SUM(sales) AS sales
       -- 避免使用关键字`TABLE`作为表名，替换为实际源表名称
       FROM source_table
       -- 根据需求调整过滤条件，原逻辑会重复插入历史数据，此处示例为仅处理当前period
       WHERE period = start_period
       GROUP BY account_id
    )
    INSERT INTO target_table (account_id, sales)
    SELECT account_id, sales
    FROM cte_example; -- 语句结尾添加分号

    -- 递增循环变量，避免无限循环
    start_period := start_period + 1;
  END WHILE;
END;
$$;

关键修正说明： #

• 变量引用：Snowflake存储过程中引用DECLARE定义的变量时，不需要添加$前缀，直接使用变量名即可。
• 表名规范：TABLE是SQL关键字，不能作为表名，替换为实际的源表名称（比如source_table）。
• 循环逻辑：原代码中start_period未做递增操作，会导致无限循环，必须在循环体内更新循环变量。同时原过滤条件period <= end_period会导致每次迭代重复插入之前所有period的数据，根据需求调整为period = start_period仅处理当前周期的数据（如果需要累积插入可保留原条件，但需注意重复数据问题）。
• 语句结尾：循环内的每个SQL语句必须以分号;结尾，确保语法正确。

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