Snowflake SQL UDF如何传入列表实现多个输入参数批量处理

方案1：修改UDF支持数组类型入参 #

• 你可以调整drill_top_down的入参定义，将需要批量传入的参数类型改为Snowflake原生支持的ARRAY类型，其余固定参数可以保持原有类型。
• 调整后的UDF内部可以通过FLATTEN函数遍历输入的数组元素，执行原有遍历逻辑后，将所有输入对应的结果合并返回，注意要在返回字段中新增原始输入值的字段，方便区分不同条目对应的结果。
• 调用示例：

select *
from table(drill_top_down(ARRAY_CONSTRUCT('12345','67890','abcde'),'XXX')) 
order by input_id, depth, path;

• 该方案单次调用即可完成所有逻辑，适合高频批量查询场景，性能优于多次单条调用。

方案2：无需修改UDF，使用LATERAL JOIN批量调用（更推荐） #

• 如果你不想改动现有UDF的稳定逻辑，可以直接用LATERAL JOIN关联输入条目列表实现批量调用，侵入性最低。
• 调用示例：

select t.input_id, udf_res.*
from (
    -- 此处可替换为从业务表读取需要传入的条目，也可以手动构造数组
    select value as input_id 
    from table(flatten(input => array_construct('12345','67890','abcde')))
) t,
lateral table(drill_top_down(t.input_id, 'XXX')) udf_res
order by t.input_id, depth, path;

• 该方案完全兼容现有UDF逻辑，输入条目可以直接对接其他业务表的字段，不需要手动拼接参数，适配性更强，更适合大多数场景使用。

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