hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix: enhance rewrite IN to EXISTS for set subquery

Browse Source
This commit is contained in:
PatZhuang 2024-10-12 04:41:10 +00:00 committed by ob-robot
parent ef9f85bd06
commit ace4a27795
2 changed files with 39 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/sql/rewrite/ob_transform_utils.cpp
View File

@ -16412,7 +16412,12 @@ int ObTransformUtils::check_stmt_can_trans_as_exists(ObSelectStmt *stmt,
match_index = has_index_matched; match_index = has_index_matched;
is_valid = (!need_match_index || has_index_matched) && is_valid; is_valid = (!need_match_index || has_index_matched) && is_valid;
} }
} else if (is_correlated) {
// If IN set subquery is already correlated, it can be beneficial
// to transform IN to EXISTS without introducing new correlated subquery
is_valid = true;
} else { } else {
// Otherwise, transform if one of set branches has a matching index
is_valid = true; is_valid = true;
for (int64_t i = 0; OB_SUCC(ret) && is_valid && i < stmt->get_set_query().count(); ++i) { for (int64_t i = 0; OB_SUCC(ret) && is_valid && i < stmt->get_set_query().count(); ++i) {
has_index_matched = false; has_index_matched = false;

52
tools/deploy/mysql_test/test_suite/subquery/r/mysql/subquery.result
View File

@ -736,36 +736,52 @@ Outputs & filters:
range_key([t1.c1]), range(MIN ; MAX)always true range_key([t1.c1]), range(MIN ; MAX)always true
explain select * from t1 where t1.c2 in (select avg(c1) from t2 where t2.c1 = t1.c1 union select count(1) from t3 where t3.c1 = t1.c1); explain select * from t1 where t1.c2 in (select avg(c1) from t2 where t2.c1 = t1.c1 union select count(1) from t3 where t3.c1 = t1.c1);
Query Plan Query Plan
=========================================================== ====================================================================
|ID|OPERATOR |NAME|EST.ROWS|EST.TIME(us)| |ID|OPERATOR |NAME |EST.ROWS|EST.TIME(us)|
----------------------------------------------------------- --------------------------------------------------------------------
|0 |SUBPLAN FILTER | |1 |75 | |0 |SUBPLAN FILTER | |1 |75 |
|1 |├─TABLE FULL SCAN |t1 |2 |3 | |1 |├─TABLE FULL SCAN |t1 |2 |3 |
|2 |└─MERGE UNION DISTINCT | |2 |36 | |2 |└─LIMIT | |1 |36 |
|3 | ├─SCALAR GROUP BY | |1 |18 | |3 | └─SUBPLAN SCAN |VIEW1|1 |36 |
|4 | │ └─DISTRIBUTED TABLE GET|t2 |1 |18 | |4 | └─LIMIT | |1 |36 |
|5 | └─SCALAR GROUP BY | |1 |18 | |5 | └─MERGE UNION DISTINCT | |1 |36 |
|6 | └─DISTRIBUTED TABLE GET|t3 |1 |18 | |6 | ├─LIMIT | |1 |18 |
=========================================================== |7 | │ └─SCALAR GROUP BY | |1 |18 |
|8 | │ └─DISTRIBUTED TABLE GET|t2 |1 |18 |
|9 | └─LIMIT | |1 |18 |
|10| └─SCALAR GROUP BY | |1 |18 |
|11| └─DISTRIBUTED TABLE GET|t3 |1 |18 |
====================================================================
Outputs & filters: Outputs & filters:
------------------------------------- -------------------------------------
0 - output([t1.c1], [t1.c2], [t1.c3]), filter([cast(t1.c2, DECIMAL(11, 0)) = ANY(subquery(1))]), rowset=16 0 - output([t1.c1], [t1.c2], [t1.c3]), filter([(T_OP_EXISTS, subquery(1))]), rowset=16
exec_params_([t1.c1(:0)]), onetime_exprs_(nil), init_plan_idxs_(nil), use_batch=false exec_params_([t1.c1(:0)], [cast(t1.c2, DECIMAL(11, 0))(:1)]), onetime_exprs_(nil), init_plan_idxs_(nil), use_batch=false
1 - output([t1.c1], [t1.c2], [t1.c3]), filter(nil), rowset=16 1 - output([t1.c1], [t1.c2], [t1.c3]), filter(nil), rowset=16
access([t1.c1], [t1.c2], [t1.c3]), partitions(p0) access([t1.c1], [t1.c2], [t1.c3]), partitions(p0)
is_index_back=false, is_global_index=false, is_index_back=false, is_global_index=false,
range_key([t1.c1]), range(MIN ; MAX)always true range_key([t1.c1]), range(MIN ; MAX)always true
2 - output([UNION([1])]), filter(nil), rowset=16 2 - output([1]), filter(nil), rowset=16
3 - output([cast(cast(T_FUN_SUM(t2.c1), DECIMAL(33, 0)) / cast(T_FUN_COUNT(t2.c1), DECIMAL(20, 0)), DECIMAL(15, 4))]), filter(nil), rowset=16 limit(1), offset(nil)
3 - output(nil), filter(nil), rowset=16
access(nil)
4 - output([UNION([1])]), filter(nil), rowset=16
limit(1), offset(nil)
5 - output([UNION([1])]), filter(nil), rowset=16
6 - output([cast(cast(T_FUN_SUM(t2.c1), DECIMAL(33, 0)) / cast(T_FUN_COUNT(t2.c1), DECIMAL(20, 0)), DECIMAL(15, 4))]), filter(nil), rowset=16
limit(1), offset(nil)
7 - output([cast(cast(T_FUN_SUM(t2.c1), DECIMAL(33, 0)) / cast(T_FUN_COUNT(t2.c1), DECIMAL(20, 0)), DECIMAL(15, 4))]), filter([cast(cast(T_FUN_SUM(t2.c1),
DECIMAL(33, 0)) / cast(T_FUN_COUNT(t2.c1), DECIMAL(20, 0)), DECIMAL(15, 4)) = :1]), rowset=16
group(nil), agg_func([T_FUN_SUM(t2.c1)], [T_FUN_COUNT(t2.c1)]) group(nil), agg_func([T_FUN_SUM(t2.c1)], [T_FUN_COUNT(t2.c1)])
4 - output([t2.c1]), filter(nil), rowset=16 8 - output([t2.c1]), filter(nil), rowset=16
access([t2.c1]), partitions(p0) access([t2.c1]), partitions(p0)
is_index_back=false, is_global_index=false, keep_ordering=true, is_index_back=false, is_global_index=false, keep_ordering=true,
range_key([t2.c1]), range(MIN ; MAX)always true, range_key([t2.c1]), range(MIN ; MAX)always true,
range_cond([t2.c1 = :0]) range_cond([t2.c1 = :0])
5 - output([cast(T_FUN_COUNT(*), DECIMAL(24, 4))]), filter(nil), rowset=16 9 - output([cast(T_FUN_COUNT(*), DECIMAL(24, 4))]), filter(nil), rowset=16
limit(1), offset(nil)
10 - output([cast(T_FUN_COUNT(*), DECIMAL(24, 4))]), filter([cast(T_FUN_COUNT(*), DECIMAL(24, 4)) = :1]), rowset=16
group(nil), agg_func([T_FUN_COUNT(*)]) group(nil), agg_func([T_FUN_COUNT(*)])
6 - output(nil), filter(nil), rowset=16 11 - output(nil), filter(nil), rowset=16
access(nil), partitions(p0) access(nil), partitions(p0)
is_index_back=false, is_global_index=false, keep_ordering=true, is_index_back=false, is_global_index=false, keep_ordering=true,
range_key([t3.c1]), range(MIN ; MAX)always true, range_key([t3.c1]), range(MIN ; MAX)always true,