-- 1. 对用户数据进行分组,按照活跃日期进行排序(去重:防止有一天有多次活跃记录)
SELECT
user_id
, active_date
, ROW_NUMBER() OVER(PARTITION BY user_id ORDER BY active_date) AS rn
FROM user_active_info
GROUP BY user_id , active_date
;
user_id
active_date
rn
10001
2023-02-01
1
10001
2023-02-03
2
10001
2023-02-04
3
10001
2023-02-05
4
10002
2023-02-02
1
10002
2023-02-03
2
10002
2023-02-04
3
10002
2023-02-05
4
10002
2023-02-07
5
…
…
…
-- 2. 使用活跃日期和排序rn进行差值计算,得到的日期如果是相等的,就说明活跃日期是连续的
SELECT
user_id
, active_date
, rn
, DATE_SUB(active_date,rn) AS sub_date
FROM (
SELECT
user_id
, active_date
, ROW_NUMBER() OVER(PARTITION BY user_id ORDER BY active_date) AS rn
FROM user_active_info
GROUP BY user_id , active_date
) a
;
user_id
active_date
rn
sub_date
10001
2023-02-01
1
2023-01-31
10001
2023-02-03
2
2023-02-01
10001
2023-02-04
3
2023-02-01
10001
2023-02-05
4
2023-02-01
10002
2023-02-02
1
2023-02-01
10002
2023-02-03
2
2023-02-01
10002
2023-02-04
3
2023-02-01
10002
2023-02-05
4
2023-02-01
10002
2023-02-07
5
2023-02-02
…
…
…
…
-- 3. 按照user_id和sub_date 进行分组求和,筛选出连续登陆天数大于3天的用户
SELECT
user_id
, MIN(active_date) AS begin_date
, MAX(active_date) AS end_date
, COUNT (1) AS login_duration
FROM (
SELECT
user_id
, active_date
, rn
, DATE_SUB(active_date,rn) AS sub_date
FROM (
SELECT
user_id
, active_date
, ROW_NUMBER() OVER(PARTITION BY user_id ORDER BY active_date) AS rn
FROM user_active_info
GROUP BY user_id , active_date
) a
) b
GROUP BY user_id , sub_date
HAVING login_duration >= 3
;
-- 1. 将active_date 上抬2行,不存在默认为'0'(计算连续活跃3天以上的, 上抬2行,n天上抬n-1行)(去重:防止有一天有多次活跃记录)
SELECT
user_id
, active_date
, lead(active_date , 2 , 0) OVER(PARTITION BY user_id ORDER BY active_date) AS lead_active_date
FROM user_active_info
GROUP BY user_id , active_date
user_id
active_date
lead_active_date
10001
2023-02-01
2023-02-04
10001
2023-02-03
2023-02-05
10001
2023-02-04
0
10001
2023-02-05
0
10002
2023-02-02
2023-02-04
10002
2023-02-03
2023-02-05
10002
2023-02-04
2023-02-07
10002
2023-02-05
0
10002
2023-02-07
0
…
…
…
-- 2. 过滤筛选出, lead_active_date 与 active_date 差值为2的, 差值2 -> 连续活跃了3天
SELECT
user_id , active_date , lead_active_date
FROM (
SELECT
user_id
, active_date
, lead(active_date , 2 , 0) OVER(PARTITION BY user_id ORDER BY active_date) AS lead_active_date
FROM user_active_info
GROUP BY user_id , active_date
) a
WHERE lead_active_date != '0'
AND DATEDIFF(lead_active_date , active_date) = 2
user_id
active_date
lead_active_date
10001
2023-02-03
2023-02-05
10002
2023-02-02
2023-02-04
10002
2023-02-03
2023-02-05
…
…
…
-- 3. user_id 去重, 得到连续活跃天数>=3天的用户
SELECT
user_id
FROM (
SELECT
user_id , active_date , lead_active_date
FROM (
SELECT
user_id
, active_date
, lead(active_date , 2 , 0) OVER(PARTITION BY user_id ORDER BY active_date) AS lead_active_date
FROM user_active_info
GROUP BY user_id , active_date
) a
WHERE lead_active_date != '0'
AND DATEDIFF(lead_active_date , active_date) = 2
) b
GROUP BY user_id