sql算法：行列转换
最新回答
泽城美雪
2026-03-18 07:46:07
SQL中的行列转换是数据处理中的常见操作，主要包括列转行和行转列两种类型。以下是对这两种转换的详细解答：
列转行核心思路：将多行数据中的某一列值合并为一个字段，通常使用字符串连接函数实现。
示例数据：
-- 原始数据id1 id2 flag a b 2 a b 1 a b 3 c d 6 c d 8 c d 8-- 目标结果id1 id2 flaga b 2|1|3 c d 6|8实现步骤：
数据分组聚合：
-- 使用collect_set去重或collect_list保留所有值SELECT id1, id2, collect_set(flag) AS flag FROM rowline2 GROUP BY id1, id2;字符串连接：
-- 需要类型转换和字符串连接函数SELECT id1, id2, concat_ws('|', collect_set(CAST(flag AS STRING))) AS flagFROM rowline2 GROUP BY id1, id2;
关键函数：
- collect_set()：聚合列值并去重
- collect_list()：聚合所有列值（不去重）
- concat_ws()：用指定分隔符连接字符串
核心思路：将行数据转换为列显示，通常使用条件聚合函数实现。
示例数据：
-- 原始数据id course 1 java 1 hadoop 1 hive 1 hbase 2 java 2 hive 2 spark 2 flink 3 java 3 hadoop 3 hive 3 kafka-- 目标结果id java hadoop hive hbase spark flink kafka 1 1 1 1 1 0 0 0 2 1 0 1 0 1 1 0 3 1 1 1 0 0 0 1实现方法：
SELECT id, SUM(CASE WHEN course='java' THEN 1 ELSE 0 END) AS java, SUM(CASE WHEN course='hadoop' THEN 1 ELSE 0 END) AS hadoop, SUM(CASE WHEN course='hive' THEN 1 ELSE 0 END) AS hive, SUM(CASE WHEN course='hbase' THEN 1 ELSE 0 END) AS hbase, SUM(CASE WHEN course='spark' THEN 1 ELSE 0 END) AS spark, SUM(CASE WHEN course='flink' THEN 1 ELSE 0 END) AS flink, SUM(CASE WHEN course='kafka' THEN 1 ELSE 0 END) AS kafkaFROM rowline1GROUP BY id;关键技术：
- CASE WHEN条件判断
- 聚合函数（SUM/MAX等）
- GROUP BY分组
列转行时：
注意数据类型转换（如int转string）
选择合适的聚合函数（去重/不去重）
分隔符选择要避免与数据冲突
行转列时：
需要预先知道所有可能的列值
对于动态列名的情况，可能需要使用动态SQL
考虑使用PIVOT操作（某些数据库支持）
这两种转换在实际应用中非常常见，特别是在数据报表生成和数据透视场景中。掌握这些技术可以大大提高数据处理的灵活性。
热门标签
