thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-14 02:12:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

add 03279_join_choose_build_table

Browse Source
This commit is contained in:
vdimir 2024-12-05 14:53:45 +00:00
parent e7177a5192
commit 9bea138293
No known key found for this signature in database
GPG Key ID: 6EE4CE2BEDC51862
2 changed files with 102 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tests/queries/0_stateless/03279_join_choose_build_table.reference Normal file
View File

@ -0,0 +1,5 @@
ok ok ok auto
ok ok ok auto
ok ok ok auto
ok ok ok auto

97
tests/queries/0_stateless/03279_join_choose_build_table.sql Normal file
View File

@ -0,0 +1,97 @@
DROP TABLE IF EXISTS products;
DROP TABLE IF EXISTS sales;
SET allow_experimental_analyzer = 1;
CREATE TABLE sales (
id Int32,
date Date,
amount Decimal(10, 2),
product_id Int32
) ENGINE = MergeTree ORDER BY id;
INSERT INTO sales SELECT number, '2024-05-05' + INTERVAL intDiv(number, 1000) DAY , (number + 1) % 100, number % 100_000 FROM numbers(1_000_000);
CREATE TABLE products (id Int32, name String) ENGINE = MergeTree ORDER BY id;
INSERT INTO products SELECT number, 'product ' || toString(number) FROM numbers(100_000);
SET query_plan_join_swap_table = 'auto';
SELECT * FROM products, sales
WHERE sales.product_id = products.id AND date = '2024-05-07'
SETTINGS log_comment = '03279_join_choose_build_table_no_idx' FORMAT Null;
SELECT * FROM sales, products
WHERE sales.product_id = products.id AND date = '2024-05-07'
SETTINGS log_comment = '03279_join_choose_build_table_no_idx' FORMAT Null;
SET mutations_sync = 2;
ALTER TABLE sales ADD INDEX date_idx date TYPE minmax GRANULARITY 1;
ALTER TABLE sales MATERIALIZE INDEX date_idx;
SELECT * FROM products, sales
WHERE sales.product_id = products.id AND date = '2024-05-07'
SETTINGS log_comment = '03279_join_choose_build_table_idx' FORMAT Null;
SELECT * FROM sales, products
WHERE sales.product_id = products.id AND date = '2024-05-07'
SETTINGS log_comment = '03279_join_choose_build_table_idx' FORMAT Null;
SYSTEM FLUSH LOGS;
-- condtitions are pushed down, but no filter by index applied
-- build table is as it's written in query
SELECT
if(ProfileEvents['JoinBuildTableRowCount'] BETWEEN 100 AND 2000, 'ok', 'fail: ' || toString(ProfileEvents['JoinBuildTableRowCount'])),
if(ProfileEvents['JoinProbeTableRowCount'] BETWEEN 90_000 AND 110_000, 'ok', 'fail: ' || toString(ProfileEvents['JoinProbeTableRowCount'])),
if(ProfileEvents['JoinResultRowCount'] == 1000, 'ok', 'fail: ' || toString(ProfileEvents['JoinResultRowCount'])),
Settings['query_plan_join_swap_table'],
FROM system.query_log
WHERE type = 'QueryFinish' AND event_date = today() AND query_kind = 'Select'
AND query like '%products, sales%'
AND log_comment = '03279_join_choose_build_table_no_idx'
ORDER BY event_time DESC
LIMIT 1;
SELECT
if(ProfileEvents['JoinBuildTableRowCount'] BETWEEN 90_000 AND 110_000, 'ok', 'fail: ' || toString(ProfileEvents['JoinBuildTableRowCount'])),
if(ProfileEvents['JoinProbeTableRowCount'] BETWEEN 100 AND 2000, 'ok', 'fail: ' || toString(ProfileEvents['JoinProbeTableRowCount'])),
if(ProfileEvents['JoinResultRowCount'] == 1000, 'ok', 'fail: ' || toString(ProfileEvents['JoinResultRowCount'])),
Settings['query_plan_join_swap_table'],
FROM system.query_log
WHERE type = 'QueryFinish' AND event_date = today() AND query_kind = 'Select'
AND query like '%sales, products%'
AND log_comment = '03279_join_choose_build_table_no_idx'
ORDER BY event_time DESC
LIMIT 1;
-- after adding index, optimizer can choose best table order
SELECT
if(ProfileEvents['JoinBuildTableRowCount'] BETWEEN 100 AND 2000, 'ok', 'fail: ' || toString(ProfileEvents['JoinBuildTableRowCount'])),
if(ProfileEvents['JoinProbeTableRowCount'] BETWEEN 90_000 AND 110_000, 'ok', 'fail: ' || toString(ProfileEvents['JoinProbeTableRowCount'])),
if(ProfileEvents['JoinResultRowCount'] == 1000, 'ok', 'fail: ' || toString(ProfileEvents['JoinResultRowCount'])),
Settings['query_plan_join_swap_table'],
FROM system.query_log
WHERE type = 'QueryFinish' AND event_date = today() AND query_kind = 'Select'
AND query like '%products, sales%'
AND log_comment = '03279_join_choose_build_table_idx'
ORDER BY event_time DESC
LIMIT 1;
SELECT
if(ProfileEvents['JoinBuildTableRowCount'] BETWEEN 100 AND 2000, 'ok', 'fail: ' || toString(ProfileEvents['JoinBuildTableRowCount'])),
if(ProfileEvents['JoinProbeTableRowCount'] BETWEEN 90_000 AND 110_000, 'ok', 'fail: ' || toString(ProfileEvents['JoinProbeTableRowCount'])),
if(ProfileEvents['JoinResultRowCount'] == 1000, 'ok', 'fail: ' || toString(ProfileEvents['JoinResultRowCount'])),
Settings['query_plan_join_swap_table'],
FROM system.query_log
WHERE type = 'QueryFinish' AND event_date = today() AND query_kind = 'Select'
AND query like '%sales, products%'
AND log_comment = '03279_join_choose_build_table_idx'
ORDER BY event_time DESC
LIMIT 1;
DROP TABLE IF EXISTS products;
DROP TABLE IF EXISTS sales;