Skip to content

Commit

Permalink
chore: add tpcds q64 (databendlabs#11655)
Browse files Browse the repository at this point in the history 
* add tpcds q64

* onlyif mysql
  • Loading branch information
@Dousir9
Dousir9 authored Jun 2, 2023
1 parent a9aee7f commit 5f7d315
Show file tree
Hide file tree
Showing 4 changed files with 131 additions and 14 deletions.
2 changes: 1 addition & 1 deletion docs/doc/13-sql-reference/20-system-tables/system-settings.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ SELECT * FROM system.settings;
| enable_bushy_join | 0 | 0 | SESSION | Enables generating a bushy join plan with the optimizer. | UInt64 |
| enable_cbo | 1 | 1 | SESSION | Enables cost-based optimization. | UInt64 |
| enable_distributed_eval_index | 1 | 1 | SESSION | Enables evaluated indexes to be created and maintained across multiple nodes. | UInt64 |
| enable_dphyp | 0 | 0 | SESSION | Enables dphyp join order algorithm. | UInt64 |
| enable_dphyp | 1 | 1 | SESSION | Enables dphyp join order algorithm. | UInt64 |
| enable_query_result_cache | 0 | 0 | SESSION | Enables caching query results to improve performance for identical queries. | UInt64 |
| enable_runtime_filter | 0 | 0 | SESSION | Enables runtime filter optimization for JOIN. | UInt64 |
| flight_client_timeout | 60 | 60 | SESSION | Sets the maximum time in seconds that a flight client request can be processed. | UInt64 |
Expand Down
2 changes: 1 addition & 1 deletion docs/doc/14-sql-commands/40-show/show-settings.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ SHOW SETTINGS;
| enable_bushy_join | 0 | 0 | SESSION | Enables generating a bushy join plan with the optimizer. | UInt64 |
| enable_cbo | 1 | 1 | SESSION | Enables cost-based optimization. | UInt64 |
| enable_distributed_eval_index | 1 | 1 | SESSION | Enables evaluated indexes to be created and maintained across multiple nodes. | UInt64 |
| enable_dphyp | 0 | 0 | SESSION | Enables dphyp join order algorithm. | UInt64 |
| enable_dphyp | 1 | 1 | SESSION | Enables dphyp join order algorithm. | UInt64 |
| enable_query_result_cache | 0 | 0 | SESSION | Enables caching query results to improve performance for identical queries. | UInt64 |
| enable_runtime_filter | 0 | 0 | SESSION | Enables runtime filter optimization for JOIN. | UInt64 |
| flight_client_timeout | 60 | 60 | SESSION | Sets the maximum time in seconds that a flight client request can be processed. | UInt64 |
Expand Down
129 changes: 129 additions & 0 deletions tests/sqllogictests/suites/tpcds/queries.test
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7195,6 +7195,135 @@ LIMIT 100;
11 370.06 176.6527
11 496.17 176.6527

# Q64
onlyif mysql
query I
WITH cs_ui AS
(SELECT cs_item_sk,
sum(cs_ext_list_price) AS sale,
sum(cr_refunded_cash+cr_reversed_charge+cr_store_credit) AS refund
FROM catalog_sales,
catalog_returns
WHERE cs_item_sk = cr_item_sk
AND cs_order_number = cr_order_number
GROUP BY cs_item_sk
HAVING sum(cs_ext_list_price)>2*sum(cr_refunded_cash+cr_reversed_charge+cr_store_credit)),
cross_sales AS
(SELECT i_product_name product_name,
i_item_sk item_sk,
s_store_name store_name,
s_zip store_zip,
ad1.ca_street_number b_street_number,
ad1.ca_street_name b_street_name,
ad1.ca_city b_city,
ad1.ca_zip b_zip,
ad2.ca_street_number c_street_number,
ad2.ca_street_name c_street_name,
ad2.ca_city c_city,
ad2.ca_zip c_zip,
d1.d_year AS syear,
d2.d_year AS fsyear,
d3.d_year s2year,
count(*) cnt,
sum(ss_wholesale_cost) s1,
sum(ss_list_price) s2,
sum(ss_coupon_amt) s3
FROM store_sales,
store_returns,
cs_ui,
date_dim d1,
date_dim d2,
date_dim d3,
store,
customer,
customer_demographics cd1,
customer_demographics cd2,
promotion,
household_demographics hd1,
household_demographics hd2,
customer_address ad1,
customer_address ad2,
income_band ib1,
income_band ib2,
item
WHERE ss_store_sk = s_store_sk
AND ss_sold_date_sk = d1.d_date_sk
AND ss_customer_sk = c_customer_sk
AND ss_cdemo_sk= cd1.cd_demo_sk
AND ss_hdemo_sk = hd1.hd_demo_sk
AND ss_addr_sk = ad1.ca_address_sk
AND ss_item_sk = i_item_sk
AND ss_item_sk = sr_item_sk
AND ss_ticket_number = sr_ticket_number
AND ss_item_sk = cs_ui.cs_item_sk
AND c_current_cdemo_sk = cd2.cd_demo_sk
AND c_current_hdemo_sk = hd2.hd_demo_sk
AND c_current_addr_sk = ad2.ca_address_sk
AND c_first_sales_date_sk = d2.d_date_sk
AND c_first_shipto_date_sk = d3.d_date_sk
AND ss_promo_sk = p_promo_sk
AND hd1.hd_income_band_sk = ib1.ib_income_band_sk
AND hd2.hd_income_band_sk = ib2.ib_income_band_sk
AND cd1.cd_marital_status <> cd2.cd_marital_status
AND i_color IN ('purple',
'burlywood',
'indian',
'spring',
'floral',
'medium')
AND i_current_price BETWEEN 64 AND 64 + 10
AND i_current_price BETWEEN 64 + 1 AND 64 + 15
GROUP BY i_product_name,
i_item_sk,
s_store_name,
s_zip,
ad1.ca_street_number,
ad1.ca_street_name,
ad1.ca_city,
ad1.ca_zip,
ad2.ca_street_number,
ad2.ca_street_name,
ad2.ca_city,
ad2.ca_zip,
d1.d_year,
d2.d_year,
d3.d_year)
SELECT cs1.product_name,
cs1.store_name,
cs1.store_zip,
cs1.b_street_number,
cs1.b_street_name,
cs1.b_city,
cs1.b_zip,
cs1.c_street_number,
cs1.c_street_name,
cs1.c_city,
cs1.c_zip,
cs1.syear cs1syear,
cs1.cnt cs1cnt,
cs1.s1 AS s11,
cs1.s2 AS s21,
cs1.s3 AS s31,
cs2.s1 AS s12,
cs2.s2 AS s22,
cs2.s3 AS s32,
cs2.syear,
cs2.cnt
FROM cross_sales cs1,
cross_sales cs2
WHERE cs1.item_sk=cs2.item_sk
AND cs1.syear = 1999
AND cs2.syear = 1999 + 1
AND cs2.cnt <= cs1.cnt
AND cs1.store_name = cs2.store_name
AND cs1.store_zip = cs2.store_zip
ORDER BY cs1.product_name,
cs1.store_name,
cs2.cnt,
cs1.s1,
cs2.s1;
----

# Q65
onlyif mysql
query I
Expand Down
12 changes: 0 additions & 12 deletions tests/sqllogictests/suites/tpcds/tpcds_q64.test
View file

This file was deleted.

0 comments on commit 5f7d315

Please sign in to comment.