1 题目

现有用户关注者列表记录表 t_user_follower，有两个字段，用户ID（user_id），关注者列表（follower_ids)，关注者列表中是关注用户的用户ID，数据样例如下：

请找出互相关注的用户。

2 建表语句

create table t_user_follower
(
user_id string comment '用户id',
follower_ids string comment '关注者列表'
);

-- 数据插入语句
insert into t_user_follower values
('0001','0002,0003'),
('0002','0001,0003'),
('0003','0004'),
('0004','0001,0002');

3 题解

第一步：把 follower_ids 炸裂，转换成多行

select
  user_id,
  follower_ids,
  follower_id
from t_user_follower
lateral view explode(split(follower_ids,',')) t as follower_id;

结果如下：

第二步：把 user_id 和 follower_id 进行 有序 拼接，从而把 0001 关注0002 和 0002 关注 0001 拼接成相同的字符串，使得两行有相同的内容，产生关联。

select
  user_id,
  follower_ids,
  if(user_id<follower_id,concat_ws(',',user_id,follower_id),concat_ws(',',follower_id,user_id)) as friend,
  follower_id
from t_user_follower
lateral view explode(split(follower_ids,',')) t as follower_id;

结果如下：

第三步：根据拼接字符串进行统计，并限定行数为 2，从而得到最终结果。

select
    friend
from
(select
  user_id,
  follower_ids,
  if(user_id<follower_id,concat_ws(',',user_id,follower_id),concat_ws(',',follower_id,user_id)) as friend,
  follower_id
from t_user_follower
lateral view explode(split(follower_ids,',')) t as follower_id)tt
group by friend
having count(*)=2;

结果如下：