【mysql】多指标历史累计去重问题

多指标累计去重问题

1.数据准备

create table db.sku_store_info as
select '1' as product_key, '2018-01-01' as time_id, '001' as store_key
UNION ALL
select '1' as product_key, '2018-01-01' as time_id, '002' as store_key
UNION ALL
select '1' as product_key, '2018-01-01' as time_id, '001' as store_key
UNION ALL
select '1' as product_key, '2018-01-02' as time_id, '004' as store_key
UNION ALL
select '1' as product_key, '2018-01-02' as time_id, '002' as store_key
UNION ALL
select '1' as product_key, '2018-01-02' as time_id, '003' as store_key
UNION ALL
select '1' as product_key, '2018-01-02' as time_id, '002' as store_key
UNION ALL
select '1' as product_key, '2018-01-02' as time_id, '004' as store_key
UNION ALL
select '1' as product_key, '2018-01-03' as time_id, '005' as store_key
UNION ALL
select '1' as product_key, '2018-01-03' as time_id, '003' as store_key
UNION ALL
select '1' as product_key, '2018-01-03' as time_id, '001' as store_key
UNION ALL
select '1' as product_key, '2018-01-03' as time_id, '005' as store_key
UNION ALL
select '1' as product_key, '2018-02-03' as time_id, '005' as store_key
UNION ALL
select '1' as product_key, '2018-02-04' as time_id, '005' as store_key
UNION ALL
select '1' as product_key, '2018-02-05' as time_id, '009' as store_key
UNION ALL
select '2' as product_key, '2018-01-03' as time_id, '005' as store_key
UNION ALL
select '2' as product_key, '2018-02-03' as time_id, '001' as store_key
UNION ALL
select '2' as product_key, '2019-01-03' as time_id, '006' as store_key
UNION ALL
select '2' as product_key, '2020-01-03' as time_id, '005' as store_key
;

2.编写sql

I.当天累计

with tmp_table as (
    select product_key as product_key
         , time_id     as date_id
         , store_key   as store_key
    from ads_sense_rep.sku_store_info
    group by product_key, time_id, store_key
)
select product_key as            product_key
     , date_id     as            date_id
     , store_key   as            store_key
     , count(distinct store_key) over(partition by product_key, date_id) as user_cnt_act
from tmp_table
;

II.历史累计

with tmp_table as (
    select product_key as product_key
         , time_id     as date_id
         , store_key   as store_key
    from ads_sense_rep.sku_store_info
    group by product_key, time_id, store_key
)
   , tmp_total_table as (
    select product_key as            product_key
         , date_id     as            date_id
         , store_key   as            store_key
         , count(distinct store_key) over(partition by product_key,date_id) as user_cnt_act
     , count(distinct store_key) over(partition by product_key order by date_id asc rows between unbounded preceding AND current row) as tmp_day_user_cnt_act_total
    from tmp_table
)
select product_key                     as product_key
     , date_id                         as date_id
     , max(user_cnt_act)               as user_cnt_act
     , max(tmp_day_user_cnt_act_total) as user_cnt_act_total
from tmp_total_table
group by product_key, date_id
;