This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 1562d0e644a [test](mtmv)Add column name case sensitive test (#33538)
1562d0e644a is described below
commit 1562d0e644a13e50caae11b3d2f29cb169792da8
Author: zfr95 <[email protected]>
AuthorDate: Sat Apr 13 19:08:20 2024 +0800
[test](mtmv)Add column name case sensitive test (#33538)
---
.../mv/dimension/dimension_1.groovy | 222 +++++++++++----------
1 file changed, 112 insertions(+), 110 deletions(-)
diff --git
a/regression-test/suites/nereids_rules_p0/mv/dimension/dimension_1.groovy
b/regression-test/suites/nereids_rules_p0/mv/dimension/dimension_1.groovy
index 50689b2733d..192f991647c 100644
--- a/regression-test/suites/nereids_rules_p0/mv/dimension/dimension_1.groovy
+++ b/regression-test/suites/nereids_rules_p0/mv/dimension/dimension_1.groovy
@@ -135,7 +135,7 @@ suite("partition_mv_rewrite_dimension_1") {
"""
}
- def create_mv_all = { mv_name, mv_sql ->
+ def create_mv = { mv_name, mv_sql ->
sql """DROP MATERIALIZED VIEW IF EXISTS ${mv_name};"""
sql """DROP TABLE IF EXISTS ${mv_name}"""
sql"""
@@ -168,9 +168,9 @@ suite("partition_mv_rewrite_dimension_1") {
// join direction
def mv_name_1 = "mv_join_1"
def join_direction_mv_1 = """
- select l_shipdate, o_orderdate, l_partkey, l_suppkey
- from lineitem_1
- left join orders_1
+ select l_Shipdate, o_Orderdate, l_partkey, l_suppkey
+ from lineitem_1
+ left join orders_1
on lineitem_1.l_orderkey = orders_1.o_orderkey
"""
@@ -179,16 +179,16 @@ suite("partition_mv_rewrite_dimension_1") {
waitingMTMVTaskFinished(job_name_1)
def join_direction_sql_1 = """
- select l_shipdate
- from lineitem_1
- left join orders_1
+ select L_SHIPDATE
+ from lineitem_1
+ left join orders_1
on lineitem_1.l_orderkey = orders_1.o_orderkey
"""
def join_direction_sql_2 = """
- select l_shipdate
- from orders_1
- left join lineitem_1
- on orders_1.o_orderkey = lineitem_1.l_orderkey
+ select L_SHIPDATE
+ from orders_1
+ left join lineitem_1
+ on orders_1.o_orderkey = lineitem_1.L_ORDERKEY
"""
explain {
sql("${join_direction_sql_1}")
@@ -204,9 +204,9 @@ suite("partition_mv_rewrite_dimension_1") {
def mv_name_2 = "mv_join_2"
def join_direction_mv_2 = """
- select l_shipdate, o_orderdate, l_partkey, l_suppkey
- from lineitem_1
- inner join orders_1
+ select L_SHIPDATE, O_orderdate, l_partkey, l_suppkey
+ from lineitem_1
+ inner join orders_1
on lineitem_1.l_orderkey = orders_1.o_orderkey
"""
@@ -215,15 +215,15 @@ suite("partition_mv_rewrite_dimension_1") {
waitingMTMVTaskFinished(job_name_2)
def join_direction_sql_3 = """
- select l_shipdate
- from lineitem_1
- inner join orders_1
+ select l_shipdaTe
+ from lineitem_1
+ inner join orders_1
on lineitem_1.l_orderkey = orders_1.o_orderkey
"""
def join_direction_sql_4 = """
- select l_shipdate
- from orders_1
- inner join lineitem_1
+ select L_shipdate
+ from orders_1
+ inner join lineitem_1
on orders_1.o_orderkey = lineitem_1.l_orderkey
"""
explain {
@@ -240,44 +240,44 @@ suite("partition_mv_rewrite_dimension_1") {
// join filter position
def join_filter_stmt_1 = """
- select l_shipdate, o_orderdate, l_partkey, l_suppkey, o_orderkey
- from lineitem_1
- left join orders_1
+ select L_SHIPDATE, o_orderdate, l_partkey, l_suppkey, O_orderkey
+ from lineitem_1
+ left join orders_1
on lineitem_1.l_orderkey = orders_1.o_orderkey"""
def join_filter_stmt_2 = """
- select l_shipdate, o_orderdate, l_partkey, l_suppkey, o_orderkey
- from (select * from lineitem_1 where l_shipdate = '2023-10-17' ) t1
- left join orders_1
+ select l_shipdate, o_orderdate, L_partkey, l_suppkey, O_ORDERKEY
+ from (select * from lineitem_1 where l_shipdate = '2023-10-17' ) t1
+ left join orders_1
on t1.l_orderkey = orders_1.o_orderkey"""
def join_filter_stmt_3 = """
- select l_shipdate, o_orderdate, l_partkey, l_suppkey, o_orderkey
- from lineitem_1
- left join (select * from orders_1 where o_orderdate = '2023-10-17' ) t2
+ select l_shipdate, o_orderdate, l_Partkey, l_suppkey, o_orderkey
+ from lineitem_1
+ left join (select * from orders_1 where o_orderdate = '2023-10-17' )
t2
on lineitem_1.l_orderkey = t2.o_orderkey"""
def join_filter_stmt_4 = """
- select l_shipdate, o_orderdate, l_partkey, l_suppkey, o_orderkey
- from lineitem_1
- left join orders_1
- on lineitem_1.l_orderkey = orders_1.o_orderkey
+ select l_shipdate, o_orderdate, l_parTkey, l_suppkey, o_orderkey
+ from lineitem_1
+ left join orders_1
+ on lineitem_1.l_orderkey = orders_1.o_orderkey
where l_shipdate = '2023-10-17' and o_orderdate = '2023-10-17'"""
def join_filter_stmt_5 = """
- select l_shipdate, o_orderdate, l_partkey, l_suppkey, o_orderkey
- from lineitem_1
- left join orders_1
- on lineitem_1.l_orderkey = orders_1.o_orderkey
+ select l_shipdate, o_orderdate, l_partkeY, l_suppkey, o_orderkey
+ from lineitem_1
+ left join orders_1
+ on lineitem_1.l_orderkey = orders_1.o_orderkey
where l_shipdate = '2023-10-17'"""
def join_filter_stmt_6 = """
- select l_shipdate, o_orderdate, l_partkey, l_suppkey, o_orderkey
- from lineitem_1
- left join orders_1
- on lineitem_1.l_orderkey = orders_1.o_orderkey
+ select l_shipdatE, o_orderdate, l_partkey, l_suppkey, o_orderkey
+ from lineitem_1
+ left join orders_1
+ on lineitem_1.l_orderkey = orders_1.o_orderkey
where o_orderdate = '2023-10-17'"""
def join_filter_stmt_7 = """
- select l_shipdate, o_orderdate, l_partkey, l_suppkey, o_orderkey
- from lineitem_1
- left join orders_1
- on lineitem_1.l_orderkey = orders_1.o_orderkey
- where orders_1.o_orderkey=1"""
+ select l_shipdate, o_orderdate, l_partkey, l_suppkey, o_orderkeY
+ from lineitem_1
+ left join orders_1
+ on lineitem_1.l_orderkey = orders_1.o_orderkey
+ where orders_1.O_ORDERKEY=1"""
def mv_list = [
join_filter_stmt_1, join_filter_stmt_2, join_filter_stmt_3,
join_filter_stmt_4,
@@ -351,7 +351,6 @@ suite("partition_mv_rewrite_dimension_1") {
notContains "${join_filter_mv}(${join_filter_mv})"
}
}
-
}
} else if (i == 4) {
for (int j = 0; j < mv_list.size(); j++) {
@@ -410,14 +409,17 @@ suite("partition_mv_rewrite_dimension_1") {
select l_shipdate, o_orderdate, l_partkey, l_suppkey
from lineitem_1
left join orders_1
- on lineitem_1.l_orderkey = orders_1.o_orderkey"""
+ on lineitem_1.L_ORDERKEY = orders_1.o_orderkey"""
def join_type_stmt_2 = """
select l_shipdate, o_orderdate, l_partkey, l_suppkey
from lineitem_1
inner join orders_1
on lineitem_1.l_orderkey = orders_1.o_orderkey"""
+
+ // Todo: right/cross/full/semi/anti join
+ // Currently, only left join and inner join are supported.
def join_type_stmt_3 = """
- select l_shipdate, o_orderdate, l_partkey, l_suppkey
+ select l_shipdate, o_orderdatE, l_partkey, l_suppkey
from lineitem_1
right join orders_1
on lineitem_1.l_orderkey = orders_1.o_orderkey"""
@@ -426,39 +428,39 @@ suite("partition_mv_rewrite_dimension_1") {
// from lineitem_1
// cross join orders_1"""
def join_type_stmt_5 = """
- select l_shipdate, o_orderdate, l_partkey, l_suppkey
+ select l_shipdate, o_orderdate, L_partkey, l_suppkey
from lineitem_1
full join orders_1
on lineitem_1.l_orderkey = orders_1.o_orderkey"""
def join_type_stmt_6 = """
- select l_shipdate, l_partkey, l_suppkey, l_linenumber
+ select l_shipdate, l_partkey, l_suppkey, l_Shipmode, l_orderkey
from lineitem_1
left semi join orders_1
- on lineitem_1.l_orderkey = orders_1.o_orderkey"""
+ on lineitem_1.L_ORDERKEY = orders_1.o_orderkey"""
def join_type_stmt_7 = """
- select o_orderdate, o_orderkey, o_custkey, o_orderstatus
+ select o_orderkey, o_custkey, o_Orderdate, o_clerk, o_totalprice
from lineitem_1
right semi join orders_1
on lineitem_1.l_orderkey = orders_1.o_orderkey"""
def join_type_stmt_8 = """
- select l_shipdate, l_partkey, l_suppkey, l_linenumber
+ select l_shipdate, l_partkey, l_suppkeY, l_shipmode, l_orderkey
from lineitem_1
left anti join orders_1
- on lineitem_1.l_orderkey = orders_1.o_orderkey"""
+ on lineitem_1.l_orderkey = orders_1.o_orderkeY"""
def join_type_stmt_9 = """
- select o_orderdate, o_orderkey, o_custkey, o_orderstatus
+ select o_orderkey, o_custkeY, o_orderdate, o_clerk, o_totalprice
from lineitem_1
right anti join orders_1
- on lineitem_1.l_orderkey = orders_1.o_orderkey"""
- def join_type_stmt_list = [join_type_stmt_1, join_type_stmt_2,
join_type_stmt_3, join_type_stmt_5,
- join_type_stmt_6, join_type_stmt_7,
join_type_stmt_8, join_type_stmt_9]
+ on lineitem_1.L_ORDERKEY = orders_1.o_orderkey"""
+ def join_type_stmt_list = [join_type_stmt_1, join_type_stmt_2,
join_type_stmt_3,
+ join_type_stmt_5, join_type_stmt_6,
join_type_stmt_7, join_type_stmt_8, join_type_stmt_9]
for (int i = 0; i < join_type_stmt_list.size(); i++) {
logger.info("i:" + i)
String join_type_mv = """join_type_mv_${i}"""
- if (i == 2 || i == 5 || i == 7) {
+ if (i in [2, 5, 7]) {
create_mv_orders(join_type_mv, join_type_stmt_list[i])
} else if (i == 3) {
- create_mv_all(join_type_mv, join_type_stmt_list[i])
+ create_mv(join_type_mv, join_type_stmt_list[i])
} else {
create_mv_lineitem(join_type_mv, join_type_stmt_list[i])
}
@@ -494,24 +496,24 @@ suite("partition_mv_rewrite_dimension_1") {
PROPERTIES ('replication_num' = '1')
AS
select
- sum(o_totalprice) as sum_total,
- max(o_totalprice) as max_total,
- min(o_totalprice) as min_total,
- count(*) as count_all,
- bitmap_union(to_bitmap(case when o_shippriority > 1 and o_orderkey
IN (1, 3) then o_custkey else null end)) cnt_1,
- bitmap_union(to_bitmap(case when o_shippriority > 2 and o_orderkey
IN (2) then o_custkey else null end)) as cnt_2
+ sum(O_TOTALPRICE) as sum_total,
+ max(o_totalprice) as max_total,
+ min(o_totalprice) as min_total,
+ count(*) as count_all,
+ bitmap_union(to_bitmap(case when o_shippriority > 1 and o_orderkey
IN (1, 3) then o_custkey else null end)) cnt_1,
+ bitmap_union(to_bitmap(case when o_shippriority > 2 and o_orderkey
IN (2) then o_custkey else null end)) as cnt_2
from orders_1
"""
def agg_job_name_1 = getJobName(db, agg_mv_name_1)
waitingMTMVTaskFinished(agg_job_name_1)
- def agg_sql_1 = """select
- count(distinct case when o_shippriority > 1 and o_orderkey IN (1, 3)
then o_custkey else null end) as cnt_1,
- count(distinct case when O_SHIPPRIORITY > 2 and o_orderkey IN (2) then
o_custkey else null end) as cnt_2,
- sum(o_totalprice),
- max(o_totalprice),
- min(o_totalprice),
- count(*)
+ def agg_sql_1 = """select
+ count(distinct case when o_shippriority > 1 and o_orderkey IN (1, 3)
then o_custkey else null end) as cnt_1,
+ count(distinct case when O_SHIPPRIORITY > 2 and o_orderkey IN (2) then
o_custkey else null end) as cnt_2,
+ sum(O_totalprice),
+ max(o_totalprice),
+ min(o_totalprice),
+ count(*)
from orders_1
"""
explain {
@@ -524,23 +526,23 @@ suite("partition_mv_rewrite_dimension_1") {
// agg + with group by + without agg function
def agg_mv_name_2 = "agg_mv_name_2"
def agg_mv_stmt_2 = """
- select o_orderdate, o_shippriority, o_comment
- from orders_1
- group by
- o_orderdate,
- o_shippriority,
- o_comment
+ select o_orderdatE, O_SHIPPRIORITY, o_comment
+ from orders_1
+ group by
+ o_orderdate,
+ o_shippriority,
+ o_comment
"""
create_mv_orders(agg_mv_name_2, agg_mv_stmt_2)
def agg_job_name_2 = getJobName(db, agg_mv_name_2)
waitingMTMVTaskFinished(agg_job_name_2)
sql """analyze table ${agg_mv_name_2} with sync;"""
- def agg_sql_2 = """select o_shippriority, o_comment
- from orders_1
- group by
- o_shippriority,
- o_comment
+ def agg_sql_2 = """select O_shippriority, o_commenT
+ from orders_1
+ group by
+ o_shippriority,
+ o_comment
"""
def agg_sql_explain_2 = sql """explain ${agg_sql_2};"""
def mv_index_1 =
agg_sql_explain_2.toString().indexOf("MaterializedViewRewriteFail:")
@@ -551,35 +553,35 @@ suite("partition_mv_rewrite_dimension_1") {
// agg + with group by + with agg function
def agg_mv_name_3 = "agg_mv_name_3"
def agg_mv_stmt_3 = """
- select o_orderdate, o_shippriority, o_comment,
- sum(o_totalprice) as sum_total,
- max(o_totalprice) as max_total,
- min(o_totalprice) as min_total,
- count(*) as count_all,
- bitmap_union(to_bitmap(case when o_shippriority > 1 and o_orderkey
IN (1, 3) then o_custkey else null end)) cnt_1,
- bitmap_union(to_bitmap(case when o_shippriority > 2 and o_orderkey
IN (2) then o_custkey else null end)) as cnt_2
- from orders_1
- group by
- o_orderdate,
- o_shippriority,
- o_comment
+ select o_orderdatE, o_shippriority, o_comment,
+ sum(o_totalprice) as sum_total,
+ max(o_totalpricE) as max_total,
+ min(o_totalprice) as min_total,
+ count(*) as count_all,
+ bitmap_union(to_bitmap(case when o_shippriority > 1 and o_orderkey
IN (1, 3) then o_custkey else null end)) cnt_1,
+ bitmap_union(to_bitmap(case when o_shippriority > 2 and o_orderkey
IN (2) then o_custkey else null end)) as cnt_2
+ from orders_1
+ group by
+ o_orderdatE,
+ o_shippriority,
+ o_comment
"""
create_mv_orders(agg_mv_name_3, agg_mv_stmt_3)
def agg_job_name_3 = getJobName(db, agg_mv_name_3)
waitingMTMVTaskFinished(agg_job_name_3)
sql """analyze table ${agg_mv_name_3} with sync;"""
- def agg_sql_3 = """select o_shippriority, o_comment,
+ def agg_sql_3 = """select o_shipprioritY, o_comment,
count(distinct case when o_shippriority > 1 and o_orderkey IN (1,
3) then o_custkey else null end) as cnt_1,
- count(distinct case when O_SHIPPRIORITY > 2 and o_orderkey IN (2)
then o_custkey else null end) as cnt_2,
- sum(o_totalprice),
- max(o_totalprice),
- min(o_totalprice),
- count(*)
- from orders_1
- group by
- o_shippriority,
- o_comment
+ count(distinct case when O_SHIPPRIORITY > 2 and o_orderkey IN (2)
then o_custkey else null end) as cnt_2,
+ sum(o_totalprice),
+ max(o_totalprice),
+ min(o_totalprice),
+ count(*)
+ from orders_1
+ group by
+ o_shippriority,
+ o_commenT
"""
def agg_sql_explain_3 = sql """explain ${agg_sql_3};"""
def mv_index_2 =
agg_sql_explain_3.toString().indexOf("MaterializedViewRewriteFail:")
@@ -616,7 +618,7 @@ suite("partition_mv_rewrite_dimension_1") {
// view partital rewriting
def view_partition_mv_name_1 = "view_partition_mv_name_1"
def view_partition_mv_stmt_1 = """
- select l_shipdate, l_partkey, l_orderkey from lineitem_1 group by
l_shipdate, l_partkey, l_orderkey"""
+ select l_shipdatE, l_partkey, l_orderkey from lineitem_1 group by
l_shipdate, l_partkey, l_orderkeY"""
create_mv_lineitem(view_partition_mv_name_1, view_partition_mv_stmt_1)
def view_partition_job_name_1 = getJobName(db, view_partition_mv_name_1)
waitingMTMVTaskFinished(view_partition_job_name_1)
@@ -661,7 +663,7 @@ suite("partition_mv_rewrite_dimension_1") {
// predicate compensate
def predicate_mv_name_1 = "predicate_mv_name_1"
def predicate_mv_stmt_1 = """
- select l_shipdate, o_orderdate, l_partkey
+ select l_shipdatE, o_orderdate, l_partkey
from lineitem_1
left join orders_1
on lineitem_1.l_orderkey = orders_1.o_orderkey
@@ -672,7 +674,7 @@ suite("partition_mv_rewrite_dimension_1") {
waitingMTMVTaskFinished(predicate_job_name_1)
def predicate_sql_1 = """
- select l_shipdate, o_orderdate, l_partkey
+ select l_shipdate, o_orderdate, l_partkeY
from lineitem_1
left join orders_1
on lineitem_1.l_orderkey = orders_1.o_orderkey
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
