大数据hive09-hivesql进行数据行转列

一、需求背景

image.png

需要把星座和血型一样的人归类到一起，如下：

image.png

二、建表

create table dw.person_info(
name string, 
constellation string, 
blood_type string) 
row format delimited fields terminated by "\t";

三、插入数据

insert into dw.person_info(name,constellation,blood_type) values('孙悟空','白羊座','A');
insert into dw.person_info(name,constellation,blood_type) values('大海','射手座','A');
insert into dw.person_info(name,constellation,blood_type) values('宋宋','白羊座','B');
insert into dw.person_info(name,constellation,blood_type) values('猪八戒','白羊座','A');
insert into dw.person_info(name,constellation,blood_type) values('凤姐','射手座','A');

四、按需求查询数据

select
    t1.base,
    concat_ws('|', collect_set(t1.name)) name
from
    (select
        name,
        concat(constellation, ",", blood_type) base
    from
        person_info) t1
group by
    t1.base;

五、输出结果

image.png

六、总结

（1）CONCAT(string A/col, string B/col…)：返回输入字符串连接后的结果，支持任意个输入字符串;

（2）CONCAT_WS(separator, str1, str2,...)：它是一个特殊形式的 CONCAT()。第一个参数剩余参数间的分隔符。分隔符可以是与剩余参数一样的字符串。如果分隔符是 NULL，返回值也将为 NULL。这个函数会跳过分隔符参数后的任何NULL和空字符串。分隔符将被加到被连接的字符串之间;

（3）COLLECT_SET(col)：函数只接受基本数据类型，它的主要作用是将某字段的值进行去重汇总，产生array类型字段。