Snowflake动态SQL：如何在多次执行间存储查询结果到变量

错误原因 #

你遇到的Invalid expression value (?SqlExecuteImmediateDynamic?) for assignment报错，核心问题是直接将EXECUTE IMMEDIATE返回的结果集赋值给了标量变量。Snowflake中EXECUTE IMMEDIATE返回的是RESULTSET类型，无法直接赋值给VARCHAR这类标量变量，必须先提取结果集中的单个数值。

修正后的存储过程 #

CREATE OR REPLACE PROCEDURE DB.SCHEMA.SP_DATA_COLUMN_VALUES(table_name varchar, column_name varchar, date_column varchar)
RETURNS TABLE()
LANGUAGE SQL
AS
$$
-- 统计指定时间范围内列的Top1000值及出现频率占比
  DECLARE
    res RESULTSET;
    sql_query VARCHAR;
    total_row_count NUMERIC; -- 改为数值类型，匹配count(*)结果
  BEGIN
    -- 用SELECT INTO直接将动态查询结果存入变量
    EXECUTE IMMEDIATE 'select count(*) from '|| table_name ||' where '|| date_column ||' > DATEADD(day, -365, getdate())'
    INTO total_row_count;

    -- 拼接第二个动态SQL，使用total_row_count计算占比
    sql_query := 'select '|| column_name ||', iff('|| total_row_count ||' = 0, 0.00, cast(count(*) as numeric(18,2))/'|| total_row_count ||'*100) PercentOfDataSet' ||
                 ' from '|| table_name ||' where '|| date_column ||'> DATEADD(day, -365, getdate())' ||
                 ' group by 1 order by 2 desc limit 1000;';
    res := (EXECUTE IMMEDIATE :sql_query);
    RETURN TABLE(res);
  END;
$$;

关键修改点 #

1. 变量类型调整：将total_row_count的类型从VARCHAR改为NUMERIC，匹配count(*)返回的数值类型，避免不必要的类型转换。
2. 结果赋值方式：使用EXECUTE IMMEDIATE ... INTO语法，直接将动态查询的单行单列结果存入标量变量，替代原来的直接赋值操作。
3. SQL拼接优化：保持原有逻辑不变，确保占比计算的精度和正确性。

执行效果 #

调用该存储过程后，会输出符合你期望的结果格式：

<column_name>, PercentOfDataSet
Value1, X.XX
Value2, X.XX
Value3, X.XX

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