使用SQL CASE语句实现多列非空值顺序填充的数据迁移转换

核心SQL代码 #

SELECT 
    ID,
    -- 填充col1：按优先级取第一个非空源列
    CASE
        WHEN source1 IS NOT NULL THEN source1
        WHEN source2 IS NOT NULL THEN source2
        WHEN source3 IS NOT NULL THEN source3
        WHEN source4 IS NOT NULL THEN source4
        ELSE NULL
    END AS col1,
    -- 填充col2：在col1取值的源列之后，找下一个非空值
    CASE
        WHEN col1 = source1 THEN
            CASE
                WHEN source2 IS NOT NULL THEN source2
                WHEN source3 IS NOT NULL THEN source3
                WHEN source4 IS NOT NULL THEN source4
                ELSE NULL
            END
        WHEN col1 = source2 THEN
            CASE
                WHEN source3 IS NOT NULL THEN source3
                WHEN source4 IS NOT NULL THEN source4
                ELSE NULL
            END
        WHEN col1 = source3 THEN source4
        ELSE NULL
    END AS col2,
    -- 填充col3：在col2取值的源列之后，找下一个非空值
    CASE
        WHEN col2 = source2 THEN
            CASE
                WHEN source3 IS NOT NULL THEN source3
                WHEN source4 IS NOT NULL THEN source4
                ELSE NULL
            END
        WHEN col2 = source3 THEN source4
        ELSE NULL
    END AS col3,
    -- 填充col4：仅当col3来自source3时，取source4的非空值
    CASE
        WHEN col3 = source3 THEN source4
        ELSE NULL
    END AS col4
FROM your_table_name;

逻辑说明 #

• col1：遵循source1 > source2 > source3 > source4的优先级，提取第一个非空值
• col2：基于col1的来源列，在后续优先级的源列中提取第一个非空值
• col3：基于col2的来源列，在后续优先级的源列中提取第一个非空值
• col4：仅当col3来自source3时，提取source4的非空值

源数据示例 #

预期结果 #

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