mirror of
https://github.com/hanzoai/datastore.git
synced 2026-09-26 13:55:07 +00:00
114 lines
3.4 KiB
SQL
114 lines
3.4 KiB
SQL
WITH
|
|
ss AS
|
|
(
|
|
SELECT
|
|
s_store_sk,
|
|
sum(ss_ext_sales_price) AS sales,
|
|
sum(ss_net_profit) AS profit
|
|
FROM store_sales, date_dim, store
|
|
WHERE (ss_sold_date_sk = d_date_sk)
|
|
AND ((d_date >= CAST('2000-08-23', 'date')) AND (d_date <= (CAST('2000-08-23', 'date') + INTERVAL 30 DAY)))
|
|
AND (ss_store_sk = s_store_sk)
|
|
GROUP BY s_store_sk
|
|
),
|
|
sr AS
|
|
(
|
|
SELECT
|
|
s_store_sk,
|
|
sum(sr_return_amt) AS returns,
|
|
sum(sr_net_loss) AS profit_loss
|
|
FROM store_returns, date_dim, store
|
|
WHERE (sr_returned_date_sk = d_date_sk)
|
|
AND ((d_date >= CAST('2000-08-23', 'date')) AND (d_date <= (CAST('2000-08-23', 'date') + INTERVAL 30 DAY)))
|
|
AND (sr_store_sk = s_store_sk)
|
|
GROUP BY s_store_sk
|
|
),
|
|
cs AS
|
|
(
|
|
SELECT
|
|
cs_call_center_sk,
|
|
sum(cs_ext_sales_price) AS sales,
|
|
sum(cs_net_profit) AS profit
|
|
FROM catalog_sales, date_dim
|
|
WHERE (cs_sold_date_sk = d_date_sk)
|
|
AND ((d_date >= CAST('2000-08-23', 'date')) AND (d_date <= (CAST('2000-08-23', 'date') + INTERVAL 30 DAY)))
|
|
GROUP BY cs_call_center_sk
|
|
),
|
|
cr AS
|
|
(
|
|
SELECT
|
|
cr_call_center_sk,
|
|
sum(cr_return_amount) AS returns,
|
|
sum(cr_net_loss) AS profit_loss
|
|
FROM catalog_returns, date_dim
|
|
WHERE (cr_returned_date_sk = d_date_sk)
|
|
AND ((d_date >= CAST('2000-08-23', 'date')) AND (d_date <= (CAST('2000-08-23', 'date') + INTERVAL 30 DAY)))
|
|
GROUP BY cr_call_center_sk
|
|
),
|
|
ws AS
|
|
(
|
|
SELECT
|
|
wp_web_page_sk,
|
|
sum(ws_ext_sales_price) AS sales,
|
|
sum(ws_net_profit) AS profit
|
|
FROM web_sales, date_dim, web_page
|
|
WHERE (ws_sold_date_sk = d_date_sk)
|
|
AND ((d_date >= CAST('2000-08-23', 'date')) AND (d_date <= (CAST('2000-08-23', 'date') + INTERVAL 30 DAY)))
|
|
AND (ws_web_page_sk = wp_web_page_sk)
|
|
GROUP BY wp_web_page_sk
|
|
),
|
|
wr AS
|
|
(
|
|
SELECT
|
|
wp_web_page_sk,
|
|
sum(wr_return_amt) AS returns,
|
|
sum(wr_net_loss) AS profit_loss
|
|
FROM web_returns, date_dim, web_page
|
|
WHERE (wr_returned_date_sk = d_date_sk)
|
|
AND ((d_date >= CAST('2000-08-23', 'date')) AND (d_date <= (CAST('2000-08-23', 'date') + INTERVAL 30 DAY)))
|
|
AND (wr_web_page_sk = wp_web_page_sk)
|
|
GROUP BY wp_web_page_sk
|
|
)
|
|
SELECT
|
|
channel,
|
|
id,
|
|
sum(sales) AS sales,
|
|
sum(returns) AS returns,
|
|
sum(profit) AS profit
|
|
FROM
|
|
(
|
|
SELECT
|
|
'store channel' AS channel,
|
|
ss.s_store_sk AS id,
|
|
sales,
|
|
coalesce(returns, 0) AS returns,
|
|
profit - coalesce(profit_loss, 0) AS profit
|
|
FROM ss
|
|
LEFT JOIN sr ON ss.s_store_sk = sr.s_store_sk
|
|
UNION ALL
|
|
SELECT
|
|
'catalog channel' AS channel,
|
|
cs_call_center_sk AS id,
|
|
sales,
|
|
returns,
|
|
profit - profit_loss AS profit
|
|
FROM cs, cr
|
|
UNION ALL
|
|
SELECT
|
|
'web channel' AS channel,
|
|
ws.wp_web_page_sk AS id,
|
|
sales,
|
|
coalesce(returns, 0) AS returns,
|
|
profit - coalesce(profit_loss, 0) AS profit
|
|
FROM ws
|
|
LEFT JOIN wr ON ws.wp_web_page_sk = wr.wp_web_page_sk
|
|
) AS x
|
|
GROUP BY
|
|
channel,
|
|
id
|
|
WITH ROLLUP
|
|
ORDER BY
|
|
channel,
|
|
id
|
|
LIMIT 100;
|