如何更新Snowflake的VARIANT列值？OBJECT_AGG报错求解决方案

测试数据准备 #

先创建测试表并插入样例数据，模拟你的场景：

CREATE OR REPLACE TABLE driver_info (
    driver_id INT,
    LANGUAGES VARIANT
);

INSERT INTO driver_info VALUES
(1, {'primary':'eng', 'secondary':'sp'}),
(2, {'primary':'un', 'secondary':'eng'}),
(3, ['eng', 'sp', 'un']);

针对对象类型VARIANT的转换（使用OBJECT_AGG的正确方式） #

如果你的LANGUAGES是键值对结构的VARIANT对象，正确的做法是先通过FLATTEN拆解对象的键值，替换值后再用OBJECT_AGG重新聚合：

SELECT 
    driver_id,
    OBJECT_AGG(f.key, 
        CASE f.value
            WHEN 'eng' THEN 'english'
            WHEN 'sp' THEN 'spanish'
            WHEN 'un' THEN 'unknown'
            ELSE f.value  -- 保留未匹配的原始值
        END
    ) AS LANGUAGES
FROM driver_info,
LATERAL FLATTEN(input => LANGUAGES, mode => 'OBJECT') f
GROUP BY driver_id;

报错原因分析

你之前使用OBJECT_AGG报错，大概率是以下原因：

• 未通过FLATTEN拆解VARIANT对象，直接对整个VARIANT列使用OBJECT_AGG
• FLATTEN时指定了错误的mode（比如处理对象时用了ARRAY模式）
• GROUP BY子句遗漏了driver_id，导致聚合逻辑错误

针对数组类型VARIANT的转换 #

如果你的LANGUAGES是数组结构的VARIANT，使用ARRAY_AGG结合FLATTEN实现转换：

SELECT 
    driver_id,
    ARRAY_AGG(
        CASE f.value
            WHEN 'eng' THEN 'english'
            WHEN 'sp' THEN 'spanish'
            WHEN 'un' THEN 'unknown'
            ELSE f.value
        END
    ) AS LANGUAGES
FROM driver_info,
LATERAL FLATTEN(input => LANGUAGES, mode => 'ARRAY') f
GROUP BY driver_id;

验证结果 #

执行上述SQL后，转换后的LANGUAGES列会符合预期：

• driver_id=1 的结果：{"primary": "english", "secondary": "spanish"}
• driver_id=2 的结果：{"primary": "unknown", "secondary": "english"}
• driver_id=3 的结果：["english", "spanish", "unknown"]

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