Snowflake存储过程调用报错求助：Processing aborted due to error

你的问题出在直接将字符串参数作为PARTITION BY的列名使用。Snowflake的SQL存储过程在预编译阶段会把:part_value解析成字符串字面量（比如你传入的'city'），而不是识别为表的列名，这就导致了内部执行错误。单独执行SELECT语句时你是直接写死了city作为分区列，所以能正常运行，但存储过程里用变量的方式不符合静态SQL的规则。

修正后的存储过程代码 #

create or replace procedure get_net_profit_based_on_partition_value(part_value varchar)
returns table (branch_id integer, city varchar, net_profit float, net_profit_part float )
language sql
as
declare
    res resultset;
    sql_stmt varchar;
begin
    -- 动态构建SQL语句，将参数作为列名插入到PARTITION BY子句中
    sql_stmt := 'select branch_id, city, net_profit, 
                  100 * ratio_to_report(net_profit) over (partition by ' || part_value || ') as net_profit_part 
                  from store_sales 
                  order by city';
    -- 执行动态SQL并获取结果集
    res := (execute immediate sql_stmt);
    return table(res);
end;

关键改动说明 #

• 使用动态SQL：通过字符串拼接生成完整的查询语句，确保PARTITION BY后面跟着的是实际的列名，而不是字符串字面量。
• 用EXECUTE IMMEDIATE执行动态构建的SQL，将结果赋值给resultset变量后返回。

调用这个修正后的存储过程，传入'city'参数就能正常返回结果了：

call get_net_profit_based_on_partition_value('city');

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