Skip to content

Commit be4d3be

Browse files
pratyakshsharmapratyakshsharma
committed
Add tpcds refresh queries for sf1
1 parent c30b29c commit be4d3be

File tree

16 files changed

+829
-0
lines changed

16 files changed

+829
-0
lines changed

‎benchmarks/tpc-ds/ds_refresh.json‎

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
{
2+
"description": "Sequentially run the first refresh run for tpc-ds and then verify the results.",
3+
"query_files": [
4+
"queries/refresh/LF_CR.sql",
5+
"queries/refresh/LF_CS.sql",
6+
"queries/refresh/LF_SR.sql",
7+
"queries/refresh/LF_SS.sql",
8+
"queries/refresh/LF_WR.sql",
9+
"queries/refresh/LF_WS.sql",
10+
"queries/refresh/LF_I.sql",
11+
"queries/refresh/verify_LF_CR.sql",
12+
"queries/refresh/verify_LF_CS.sql",
13+
"queries/refresh/verify_LF_SR.sql",
14+
"queries/refresh/verify_LF_SS.sql",
15+
"queries/refresh/verify_LF_WR.sql",
16+
"queries/refresh/verify_LF_WS.sql",
17+
"queries/refresh/verify_LF_I.sql"
18+
]
19+
}

‎benchmarks/tpc-ds/queries/refresh/LF_CR.sql‎

Lines changed: 94 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,94 @@
1+
DROP VIEW IF EXISTS crv;
2+
3+
CREATE VIEW crv
4+
AS
5+
SELECT d_date_sk cr_return_date_sk,
6+
t_time_sk cr_return_time_sk,
7+
i_item_sk cr_item_sk,
8+
c1.c_customer_sk cr_refunded_customer_sk,
9+
c1.c_current_cdemo_sk cr_refunded_cdemo_sk,
10+
c1.c_current_hdemo_sk cr_refunded_hdemo_sk,
11+
c1.c_current_addr_sk cr_refunded_addr_sk,
12+
c2.c_customer_sk cr_returning_customer_sk,
13+
c2.c_current_cdemo_sk cr_returning_cdemo_sk,
14+
c2.c_current_hdemo_sk cr_returning_hdemo_sk,
15+
c2.c_current_addr_sk cr_returning_addr_sk,
16+
cc_call_center_sk cr_call_center_sk,
17+
cp_catalog_page_sk CR_CATALOG_PAGE_SK,
18+
sm_ship_mode_sk CR_SHIP_MODE_SK,
19+
w_warehouse_sk CR_WAREHOUSE_SK,
20+
r_reason_sk cr_reason_sk,
21+
cret_order_id cr_order_number,
22+
cret_return_qty cr_return_quantity,
23+
cret_return_amt cr_return_amount,
24+
cret_return_tax cr_return_tax,
25+
cret_return_amt + cret_return_tax AS cr_return_amt_inc_tax,
26+
cret_return_fee cr_fee,
27+
cret_return_ship_cost cr_return_ship_cost,
28+
cret_refunded_cash cr_refunded_cash,
29+
cret_reversed_charge cr_reversed_charge,
30+
cret_merchant_credit cr_merchant_credit,
31+
cret_return_amt + cret_return_tax + cret_return_fee - cret_refunded_cash-cret_reversed_charge-cret_merchant_credit
32+
cr_net_loss
33+
FROM s_catalog_returns_1
34+
LEFT OUTER JOIN date_dim
35+
ON ( CAST(cret_return_date AS DATE) = d_date )
36+
LEFT OUTER JOIN time_dim
37+
ON ( ( CAST(Substr(cret_return_time, 1, 2) AS INTEGER) *
38+
3600 +
39+
CAST(Substr(cret_return_time, 4
40+
,
41+
2) AS
42+
INTEGER) * 60 +
43+
CAST(Substr(cret_return_time, 7,
44+
2)
45+
AS
46+
INTEGER) ) = t_time )
47+
LEFT OUTER JOIN item
48+
ON ( cret_item_id = i_item_id )
49+
LEFT OUTER JOIN customer c1
50+
ON ( cret_return_customer_id = c1.c_customer_id )
51+
LEFT OUTER JOIN customer c2
52+
ON ( cret_refund_customer_id = c2.c_customer_id )
53+
LEFT OUTER JOIN reason
54+
ON ( cret_reason_id = r_reason_id )
55+
LEFT OUTER JOIN call_center
56+
ON ( cret_call_center_id = cc_call_center_id )
57+
LEFT OUTER JOIN catalog_page
58+
ON ( cret_catalog_page_id = cp_catalog_page_id )
59+
LEFT OUTER JOIN ship_mode
60+
ON ( cret_shipmode_id = sm_ship_mode_id )
61+
LEFT OUTER JOIN warehouse
62+
ON ( cret_warehouse_id = w_warehouse_id )
63+
WHERE i_rec_end_date IS NULL
64+
AND cc_rec_end_date IS NULL;
65+
66+
INSERT INTO catalog_returns
67+
SELECT cr_return_date_sk,
68+
cr_return_time_sk,
69+
cr_item_sk,
70+
cr_refunded_customer_sk,
71+
cr_refunded_cdemo_sk,
72+
cr_refunded_hdemo_sk,
73+
cr_refunded_addr_sk,
74+
cr_returning_customer_sk,
75+
cr_returning_cdemo_sk,
76+
cr_returning_hdemo_sk,
77+
cr_returning_addr_sk,
78+
cr_call_center_sk,
79+
cr_catalog_page_sk,
80+
cr_ship_mode_sk,
81+
cr_warehouse_sk,
82+
cr_reason_sk,
83+
cr_order_number,
84+
cr_return_quantity,
85+
cr_return_amount,
86+
cr_return_tax,
87+
cast(cr_return_amt_inc_tax as decimal(7,2)),
88+
cr_fee,
89+
cr_return_ship_cost,
90+
cr_refunded_cash,
91+
cr_reversed_charge,
92+
cr_merchant_credit,
93+
cast(cr_net_loss as decimal(7,2))
94+
FROM crv;

‎benchmarks/tpc-ds/queries/refresh/LF_CS.sql‎

Lines changed: 128 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,128 @@
1+
DROP VIEW IF EXISTS csv;
2+
3+
CREATE VIEW csv
4+
AS
5+
SELECT d1.d_date_sk cs_sold_date_sk,
6+
t_time_sk cs_sold_time_sk,
7+
d2.d_date_sk cs_ship_date_sk,
8+
c1.c_customer_sk
9+
cs_bill_customer_sk,
10+
c1.c_current_cdemo_sk cs_bill_cdemo_sk
11+
,
12+
c1.c_current_hdemo_sk
13+
cs_bill_hdemo_sk,
14+
c1.c_current_addr_sk cs_bill_addr_sk,
15+
c2.c_customer_sk
16+
cs_ship_customer_sk,
17+
c2.c_current_cdemo_sk cs_ship_cdemo_sk
18+
,
19+
c2.c_current_hdemo_sk
20+
cs_ship_hdemo_sk,
21+
c2.c_current_addr_sk cs_ship_addr_sk,
22+
cc_call_center_sk
23+
cs_call_center_sk,
24+
cp_catalog_page_sk
25+
cs_catalog_page_sk
26+
,
27+
sm_ship_mode_sk
28+
cs_ship_mode_sk,
29+
w_warehouse_sk cs_warehouse_sk,
30+
i_item_sk cs_item_sk,
31+
p_promo_sk cs_promo_sk,
32+
cord_order_id cs_order_number,
33+
clin_quantity cs_quantity,
34+
i_wholesale_cost
35+
cs_wholesale_cost,
36+
i_current_price cs_list_price,
37+
clin_sales_price cs_sales_price,
38+
( i_current_price-clin_sales_price ) * clin_quantity
39+
cs_ext_discount_amt,
40+
clin_sales_price * clin_quantity
41+
cs_ext_sales_price
42+
,
43+
i_wholesale_cost * clin_quantity
44+
cs_ext_wholesale_cost,
45+
i_current_price * clin_quantity
46+
CS_EXT_LIST_PRICE,
47+
i_current_price * cc_tax_percentage CS_EXT_TAX,
48+
clin_coupon_amt cs_coupon_amt,
49+
clin_ship_cost * clin_quantity CS_EXT_SHIP_COST
50+
,
51+
( clin_sales_price * clin_quantity ) - clin_coupon_amt
52+
cs_net_paid,
53+
( ( clin_sales_price * clin_quantity ) - clin_coupon_amt ) * ( 1 +
54+
cc_tax_percentage )
55+
cs_net_paid_inc_tax,
56+
( clin_sales_price * clin_quantity ) - clin_coupon_amt + (
57+
clin_ship_cost * clin_quantity )
58+
CS_NET_PAID_INC_SHIP,
59+
( clin_sales_price * clin_quantity ) - clin_coupon_amt + (
60+
clin_ship_cost * clin_quantity ) + i_current_price * cc_tax_percentage
61+
CS_NET_PAID_INC_SHIP_TAX,
62+
( ( clin_sales_price * clin_quantity ) - clin_coupon_amt ) - (
63+
clin_quantity * i_wholesale_cost ) cs_net_profit
64+
FROM s_catalog_order_1
65+
LEFT OUTER JOIN date_dim d1
66+
ON ( CAST(cord_order_date AS DATE) = d1.d_date )
67+
LEFT OUTER JOIN time_dim
68+
ON ( cord_order_time = t_time )
69+
LEFT OUTER JOIN customer c1
70+
ON ( cord_bill_customer_id = c1.c_customer_id )
71+
LEFT OUTER JOIN customer c2
72+
ON ( cord_ship_customer_id = c2.c_customer_id )
73+
LEFT OUTER JOIN call_center
74+
ON ( cord_call_center_id = cc_call_center_id
75+
AND cc_rec_end_date IS NULL )
76+
LEFT OUTER JOIN ship_mode
77+
ON ( cord_ship_mode_id = sm_ship_mode_id )
78+
JOIN s_catalog_order_lineitem_1
79+
ON ( cord_order_id = clin_order_id )
80+
LEFT OUTER JOIN date_dim d2
81+
ON ( CAST(clin_ship_date AS DATE) = d2.d_date )
82+
LEFT OUTER JOIN catalog_page
83+
ON ( clin_catalog_page_number = cp_catalog_page_number
84+
AND clin_catalog_number = cp_catalog_number )
85+
LEFT OUTER JOIN warehouse
86+
ON ( clin_warehouse_id = w_warehouse_id )
87+
LEFT OUTER JOIN item
88+
ON ( clin_item_id = i_item_id
89+
AND i_rec_end_date IS NULL )
90+
LEFT OUTER JOIN promotion
91+
ON ( clin_promotion_id = p_promo_id );
92+
93+
INSERT INTO catalog_sales
94+
SELECT cs_sold_date_sk,
95+
cs_sold_time_sk,
96+
cs_ship_date_sk,
97+
cs_bill_customer_sk,
98+
cs_bill_cdemo_sk,
99+
cs_bill_hdemo_sk,
100+
cs_bill_addr_sk,
101+
cs_ship_customer_sk,
102+
cs_ship_cdemo_sk,
103+
cs_ship_hdemo_sk,
104+
cs_ship_addr_sk,
105+
cs_call_center_sk,
106+
cs_catalog_page_sk,
107+
cs_ship_mode_sk,
108+
cs_warehouse_sk,
109+
cs_item_sk,
110+
cs_promo_sk,
111+
cs_order_number,
112+
cast(cs_quantity as integer),
113+
cs_wholesale_cost,
114+
cs_list_price,
115+
cs_sales_price,
116+
cast(cs_ext_discount_amt as decimal(7,2)),
117+
cast(cs_ext_sales_price as decimal(7,2)),
118+
cast(cs_ext_wholesale_cost as decimal(7,2)),
119+
cast(cs_ext_list_price as decimal(7,2)),
120+
cast(cs_ext_tax as decimal(7,2)),
121+
cs_coupon_amt,
122+
cast(cs_ext_ship_cost as decimal(7,2)),
123+
cast(cs_net_paid as decimal(7,2)),
124+
cast(cs_net_paid_inc_tax as decimal(7,2)),
125+
cast(cs_net_paid_inc_ship as decimal(7,2)),
126+
cast(cs_net_paid_inc_ship_tax as decimal(7,2)),
127+
cast(cs_net_profit as decimal(7,2))
128+
FROM csv;

‎benchmarks/tpc-ds/queries/refresh/LF_I.sql‎

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
DROP VIEW IF EXISTS iv;
2+
3+
CREATE VIEW iv
4+
AS
5+
SELECT d_date_sk inv_date_sk,
6+
i_item_sk inv_item_sk,
7+
w_warehouse_sk inv_warehouse_sk,
8+
invn_qty_on_hand inv_quantity_on_hand
9+
FROM s_inventory_1
10+
LEFT OUTER JOIN warehouse
11+
ON ( invn_warehouse_id = w_warehouse_id )
12+
LEFT OUTER JOIN item
13+
ON ( invn_item_id = i_item_id
14+
AND i_rec_end_date IS NULL )
15+
LEFT OUTER JOIN date_dim
16+
ON ( cast(d_date as varchar) = invn_date );
17+
18+
INSERT INTO inventory
19+
SELECT inv_date_sk,
20+
inv_item_sk,
21+
inv_warehouse_sk,
22+
inv_quantity_on_hand
23+
FROM iv;

‎benchmarks/tpc-ds/queries/refresh/LF_SR.sql‎

Lines changed: 74 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,74 @@
1+
DROP VIEW IF EXISTS srv;
2+
3+
CREATE VIEW srv
4+
AS
5+
SELECT d_date_sk sr_returned_date_sk,
6+
t_time_sk sr_return_time_sk,
7+
i_item_sk sr_item_sk,
8+
c_customer_sk sr_customer_sk,
9+
c_current_cdemo_sk sr_cdemo_sk,
10+
c_current_hdemo_sk sr_hdemo_sk,
11+
c_current_addr_sk sr_addr_sk,
12+
s_store_sk sr_store_sk,
13+
r_reason_sk sr_reason_sk,
14+
sret_ticket_number sr_ticket_number,
15+
sret_return_qty sr_return_quantity,
16+
sret_return_amt sr_return_amt,
17+
sret_return_tax sr_return_tax,
18+
sret_return_amt + sret_return_tax sr_return_amt_inc_tax,
19+
sret_return_fee sr_fee,
20+
sret_return_ship_cost sr_return_ship_cost,
21+
sret_refunded_cash sr_refunded_cash,
22+
sret_reversed_charge sr_reversed_charge,
23+
sret_store_credit sr_store_credit,
24+
sret_return_amt + sret_return_tax
25+
+ sret_return_fee
26+
- sret_refunded_cash-sret_reversed_charge-sret_store_credit
27+
sr_net_loss
28+
FROM s_store_returns_1
29+
LEFT OUTER JOIN date_dim
30+
ON ( CAST(sret_return_date AS DATE) = d_date )
31+
LEFT OUTER JOIN time_dim
32+
ON ( ( CAST(Substr(sret_return_time, 1, 2) AS INTEGER) *
33+
3600 +
34+
CAST(Substr(sret_return_time, 4
35+
,
36+
2) AS
37+
INTEGER) * 60 +
38+
CAST(Substr(sret_return_time, 7,
39+
2)
40+
AS
41+
INTEGER) ) = t_time )
42+
LEFT OUTER JOIN item
43+
ON ( sret_item_id = i_item_id )
44+
LEFT OUTER JOIN customer
45+
ON ( sret_customer_id = c_customer_id )
46+
LEFT OUTER JOIN store
47+
ON ( sret_store_id = s_store_id )
48+
LEFT OUTER JOIN reason
49+
ON ( sret_reason_id = r_reason_id )
50+
WHERE i_rec_end_date IS NULL
51+
AND s_rec_end_date IS NULL;
52+
53+
INSERT INTO store_returns
54+
SELECT sr_returned_date_sk,
55+
sr_return_time_sk,
56+
sr_item_sk,
57+
sr_customer_sk,
58+
sr_cdemo_sk,
59+
sr_hdemo_sk,
60+
sr_addr_sk,
61+
sr_store_sk,
62+
sr_reason_sk,
63+
cast(sr_ticket_number as bigint),
64+
sr_return_quantity,
65+
sr_return_amt,
66+
sr_return_tax,
67+
cast(sr_return_amt_inc_tax as decimal(7,2)),
68+
sr_fee,
69+
sr_return_ship_cost,
70+
sr_refunded_cash,
71+
sr_reversed_charge,
72+
sr_store_credit,
73+
cast(sr_net_loss as decimal(7,2))
74+
FROM srv;

0 commit comments

Comments
 (0)