将SQL Server含OUTER APPLY和自定义函数的视图迁移至Snowflake

关键转换点 #

• OUTER APPLY 替换：Snowflake用LEFT JOIN LATERAL完全等价SQL Server的OUTER APPLY，直接替换语法即可。
• 自定义函数内嵌：把cfn_ConvertMaterialQuantity的逻辑直接写到查询里，不用创建UDF，避免额外资源消耗。

具体操作步骤 #

1. 拆解函数逻辑到查询中 #

把原函数cfn_ConvertMaterialQuantity的4个参数对应的计算逻辑，直接提取出来作为查询的一部分。比如原函数是做单位转换，就把转换公式直接写在SELECT或子查询里，不用调用函数。

举个实际例子，假设原函数逻辑是根据输入的数量、单位、转换系数、基准单位计算转换后数量，那直接把这段逻辑写到子查询：

-- 原函数调用逻辑转成内嵌计算
SELECT 
    CASE 
        WHEN input_unit = 'TON' THEN input_qty * conversion_factor
        WHEN input_unit = 'G' THEN input_qty / conversion_factor
        ELSE input_qty 
    END AS converted_qty

2. 替换OUTER APPLY为LEFT JOIN LATERAL #

原SQL Server视图写法：

SELECT 
    m.*,
    f.*
FROM material_main m
OUTER APPLY dbo.cfn_ConvertMaterialQuantity(m.qty, m.unit, m.conv_factor, m.base_unit) f

转成Snowflake兼容写法：

SELECT 
    m.*,
    f.converted_qty,
    f.other_calculated_field -- 原函数返回的其他字段
FROM material_main m
LEFT JOIN LATERAL (
    -- 直接写原函数的全部逻辑，用m表的字段作为输入参数
    SELECT 
        CASE 
            WHEN m.unit = 'TON' THEN m.qty * m.conv_factor
            WHEN m.unit = 'G' THEN m.qty / m.conv_factor
            ELSE m.qty 
        END AS converted_qty,
        -- 原函数中其他计算字段依次写出
        m.base_unit AS target_unit
    -- 如果原函数有条件判断，直接加在这里
    WHERE m.qty IS NOT NULL
) f ON TRUE

3. 用CTE重构的参数处理 #

如果想用CTE封装计算逻辑，直接把原函数的4个参数作为CTE的输入字段，在CTE内部完成计算：

WITH material_conversion AS (
    SELECT 
        m.id,
        -- 原函数的计算逻辑，直接使用m的4个字段
        CASE 
            WHEN m.unit = 'TON' THEN m.qty * m.conv_factor
            WHEN m.unit = 'G' THEN m.qty / m.conv_factor
            ELSE m.qty 
        END AS converted_qty,
        m.base_unit AS target_unit
    FROM material_main m
)
SELECT 
    m.*,
    mc.converted_qty,
    mc.target_unit
FROM material_main m
LEFT JOIN material_conversion mc ON m.id = mc.id

注意事项 #

• 务必复刻原函数的所有边界逻辑，比如空值处理、特殊单位的转换规则，避免数据不一致。
• 如果这段计算逻辑需要复用，优先用Snowflake视图封装，比UDF更高效。

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