在Snowflake中实现行转列（Pivot）：处理200+列需求

你需要将Avro加载的Key-Value结构表转置为宽表，其中Key列的200+不同值作为新表的列名，对应Value作为列值，以下是两种实现方案：

1. 静态Pivot（适用于少量固定列） #

如果列名固定且数量少，可以直接手动指定列：

SELECT *
FROM (
    SELECT key, value
    FROM your_source_table -- 替换为你的源表名
)
PIVOT (
    MAX(value) FOR key IN ('column1', 'column2', 'column3') -- 手动列出所有key值
) AS pivoted_result;

2. 动态Pivot（推荐，适用于200+列） #

由于Key列有200多个不同值，手动编写列名效率极低，可通过动态生成SQL实现自动转置：

步骤1：生成Pivot列列表 #

先查询所有唯一的Key值，拼接成Pivot所需的格式：

SELECT LISTAGG(DISTINCT '''' || key || ''' AS ' || key, ', ') WITHIN GROUP (ORDER BY key) AS pivot_columns
FROM your_source_table;

步骤2：执行动态Pivot语句 #

利用Snowflake的变量和EXECUTE IMMEDIATE执行自动生成的SQL：

-- 存储生成的列列表到变量
SET pivot_cols = (
    SELECT LISTAGG(DISTINCT '''' || key || ''' AS ' || key, ', ') WITHIN GROUP (ORDER BY key)
    FROM your_source_table
);

-- 执行动态Pivot
EXECUTE IMMEDIATE '
SELECT *
FROM (
    SELECT key, value
    FROM your_source_table
)
PIVOT (
    MAX(value) FOR key IN (' || $pivot_cols || ')
) AS final_pivoted_table';

注意事项 #

• 聚合函数选择：如果同一个Key对应多个Value，根据业务需求选择MAX/MIN/STRING_AGG等聚合函数，确保结果符合预期。
• 特殊字符处理：如果Key包含空格、特殊符号，需调整列名转义逻辑，例如：''' || key || ''' AS "' || key || '"。

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