forked from yuananf/tpcds-presto
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathq54.sql
61 lines (61 loc) · 1.43 KB
/
q54.sql
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
WITH my_customers AS (
SELECT DISTINCT
c_customer_sk,
c_current_addr_sk
FROM
(SELECT
cs_sold_date_sk sold_date_sk,
cs_bill_customer_sk customer_sk,
cs_item_sk item_sk
FROM catalog_sales
UNION ALL
SELECT
ws_sold_date_sk sold_date_sk,
ws_bill_customer_sk customer_sk,
ws_item_sk item_sk
FROM web_sales
) cs_or_ws_sales,
item,
date_dim,
customer
WHERE sold_date_sk = d_date_sk
AND item_sk = i_item_sk
AND i_category = 'Women'
AND i_class = 'maternity'
AND c_customer_sk = cs_or_ws_sales.customer_sk
AND d_moy = 12
AND d_year = 1998
)
, my_revenue AS (
SELECT
c_customer_sk,
sum(ss_ext_sales_price) AS revenue
FROM my_customers,
store_sales,
customer_address,
store,
date_dim
WHERE c_current_addr_sk = ca_address_sk
AND ca_county = s_county
AND ca_state = s_state
AND ss_sold_date_sk = d_date_sk
AND c_customer_sk = ss_customer_sk
AND d_month_seq BETWEEN (SELECT DISTINCT d_month_seq + 1
FROM date_dim
WHERE d_year = 1998 AND d_moy = 12)
AND (SELECT DISTINCT d_month_seq + 3
FROM date_dim
WHERE d_year = 1998 AND d_moy = 12)
GROUP BY c_customer_sk
)
, segments AS
(SELECT cast((revenue / 50) AS INTEGER) AS segment
FROM my_revenue)
SELECT
segment,
count(*) AS num_customers,
segment * 50 AS segment_base
FROM segments
GROUP BY segment
ORDER BY segment, num_customers
LIMIT 100;