This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new c3edf7a3b84 branch-4.0: [fix](mtmv) Fix sync materialized view use
wrong check method when in the same regression test database #58245 (#58405)
c3edf7a3b84 is described below
commit c3edf7a3b849b11c8a65c5263f26957eedd34cd8
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Nov 28 13:28:48 2025 +0800
branch-4.0: [fix](mtmv) Fix sync materialized view use wrong check method
when in the same regression test database #58245 (#58405)
Cherry-picked from #58245
Co-authored-by: seawinde <[email protected]>
---
.../suites/nereids_syntax_p0/advance_mv.groovy | 46 ++++------------------
.../mv/newMv/aggHaveDupBase.groovy | 9 ++---
.../nereids_syntax_p0/mv/newMv/case_ignore.groovy | 7 ++--
.../mv/newMv/dup_gb_mv_abs.groovy | 5 ++-
.../mv/newMv/dup_gb_mv_plus.groovy | 6 ++-
.../nereids_syntax_p0/mv/newMv/dup_mv_abs.groovy | 5 ++-
.../nereids_syntax_p0/mv/newMv/dup_mv_bin.groovy | 5 ++-
.../mv/newMv/dup_mv_bm_hash.groovy | 6 ++-
.../nereids_syntax_p0/mv/newMv/dup_mv_plus.groovy | 5 ++-
.../nereids_syntax_p0/mv/newMv/dup_mv_year.groovy | 4 +-
.../nereids_syntax_p0/mv/newMv/multi_slot1.groovy | 5 ++-
.../nereids_syntax_p0/mv/newMv/multi_slot2.groovy | 5 ++-
.../nereids_syntax_p0/mv/newMv/multi_slot3.groovy | 6 +--
.../nereids_syntax_p0/mv/newMv/multi_slot4.groovy | 6 +--
.../nereids_syntax_p0/mv/newMv/multi_slot5.groovy | 6 +--
.../nereids_syntax_p0/mv/newMv/multi_slot6.groovy | 6 ++-
.../nereids_syntax_p0/mv/newMv/mv_with_view.groovy | 5 ++-
.../nereids_syntax_p0/mv/newMv/rollback1.groovy | 6 +--
.../nereids_syntax_p0/mv/newMv/single_slot.groovy | 6 +--
.../mv/newMv/sum_devide_count.groovy | 6 +--
.../nereids_syntax_p0/mv/newMv/unique_mv.groovy | 4 +-
.../nereids_syntax_p0/mv/ut/MVMultiUsage.groovy | 1 +
.../suites/nereids_syntax_p0/mv/ut/MVWithAs.groovy | 6 +--
.../nereids_syntax_p0/mv/ut/aggMVCalcAggFun.groovy | 6 +--
.../nereids_syntax_p0/mv/ut/aggOnAggMV1.groovy | 6 +--
.../nereids_syntax_p0/mv/ut/aggOnAggMV10.groovy | 2 +
.../nereids_syntax_p0/mv/ut/aggOnAggMV11.groovy | 6 +--
.../nereids_syntax_p0/mv/ut/aggOnAggMV2.groovy | 6 +--
.../nereids_syntax_p0/mv/ut/aggOnAggMV3.groovy | 6 +--
.../nereids_syntax_p0/mv/ut/aggOnAggMV5.groovy | 5 ++-
.../nereids_syntax_p0/mv/ut/aggOnAggMV6.groovy | 6 +--
.../nereids_syntax_p0/mv/ut/aggOnAggMV7.groovy | 6 +--
.../nereids_syntax_p0/mv/ut/bitmapUnionIn.groovy | 6 +--
.../nereids_syntax_p0/mv/ut/distinctQuery.groovy | 6 ++-
.../nereids_syntax_p0/mv/ut/incMVReInSub.groovy | 6 +--
.../nereids_syntax_p0/mv/ut/incRewriteCD.groovy | 7 ++--
.../mv/ut/joinOnCalcToJoin.groovy | 8 ++--
.../mv/ut/joinOnLeftPToJoin.groovy | 9 +++--
.../suites/nereids_syntax_p0/mv/ut/onStar.groovy | 6 +--
.../nereids_syntax_p0/mv/ut/onlyGroupBy.groovy | 5 ++-
.../nereids_syntax_p0/mv/ut/orderByOnPView.groovy | 6 +--
.../nereids_syntax_p0/mv/ut/projectMV1.groovy | 6 +--
.../nereids_syntax_p0/mv/ut/projectMV2.groovy | 6 +--
.../nereids_syntax_p0/mv/ut/projectMV3.groovy | 5 ++-
.../nereids_syntax_p0/mv/ut/projectMV4.groovy | 6 +--
.../suites/nereids_syntax_p0/mv/ut/subQuery.groovy | 6 +--
.../suites/nereids_syntax_p0/mv/ut/unionDis.groovy | 6 +--
47 files changed, 151 insertions(+), 158 deletions(-)
diff --git a/regression-test/suites/nereids_syntax_p0/advance_mv.groovy
b/regression-test/suites/nereids_syntax_p0/advance_mv.groovy
index 311be65c22c..09f7490bf4c 100644
--- a/regression-test/suites/nereids_syntax_p0/advance_mv.groovy
+++ b/regression-test/suites/nereids_syntax_p0/advance_mv.groovy
@@ -21,10 +21,9 @@ suite("advance_mv") {
def tbName2 = "test_advance_mv_dup_table"
def tbName3 = "schema_change_dup_mv_regression_test"
- def getJobState = { tableName ->
- def jobStateResult = sql """ SHOW ALTER TABLE MATERIALIZED VIEW WHERE
TableName='${tableName}' ORDER BY CreateTime DESC LIMIT 1; """
- return jobStateResult[0][8]
- }
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
+
sql "DROP TABLE IF EXISTS ${tbName1} FORCE"
sql """
CREATE TABLE IF NOT EXISTS ${tbName1}(
@@ -93,7 +92,7 @@ suite("advance_mv") {
sql "analyze table ${tbName3} with sync;"
sql """set enable_stats=false;"""
- createMV("CREATE materialized VIEW mv1 AS SELECT k1 as a1, sum(v2) as a2
FROM ${tbName1} GROUP BY k1;")
+ create_sync_mv(db, tbName1, "mv1", "SELECT k1 as a1, sum(v2) as a2 FROM
${tbName1} GROUP BY k1;")
explain {
sql("select k1, sum(v2) from ${tbName1} group by k1 order by k1;")
@@ -107,7 +106,7 @@ suite("advance_mv") {
}
order_qt_select_star "select k1 from ${tbName1} order by k1;"
- createMV("CREATE materialized VIEW mv2 AS SELECT abs(k1)+k2+1 as a4,
sum(abs(k2+2)+k3+3) as a3 FROM ${tbName2} GROUP BY a4;")
+ create_sync_mv(db, tbName2, "mv2", "SELECT abs(k1)+k2+1 as a4,
sum(abs(k2+2)+k3+3) as a3 FROM ${tbName2} GROUP BY a4;")
explain {
sql("SELECT abs(k1)+k2+1 tmp, sum(abs(k2+2)+k3+3) FROM ${tbName2}
GROUP BY tmp;")
@@ -120,22 +119,8 @@ suite("advance_mv") {
}
order_qt_select_star "SELECT abs(k1)+k2+1 tmp, sum(abs(k2+2)+k3+3) FROM
${tbName2} GROUP BY tmp;"
- sql "CREATE materialized VIEW mv3 AS SELECT abs(k1)+k2+1 as a5,
abs(k2+2)+k3+3 as a6 FROM ${tbName2};"
- int max_try_secs2 = 60
- while (max_try_secs2--) {
- String res = getJobState(tbName2)
- if (res == "FINISHED" || res == "CANCELLED") {
- assertEquals("FINISHED", res)
- sleep(3000)
- break
- } else {
- Thread.sleep(2000)
- if (max_try_secs2 < 1) {
- println "test timeout," + "state:" + res
- assertEquals("FINISHED",res)
- }
- }
- }
+ create_sync_mv(db, tbName2, "mv3", "SELECT abs(k1)+k2+1 as a5,
abs(k2+2)+k3+3 as a6 FROM ${tbName2};")
+
explain {
sql("SELECT abs(k1)+k2+1 tmp, abs(k2+2)+k3+3 FROM ${tbName2};")
contains "(mv3)"
@@ -148,23 +133,8 @@ suite("advance_mv") {
contains "(mv3)"
}
+ create_sync_mv(db, tbName3, "mv4", "select date as b1, user_id as b2, city
as b3, sum(age) from ${tbName3} group by date, user_id, city;")
- sql "create materialized view mv4 as select date as b1, user_id as b2,
city as b3, sum(age) from ${tbName3} group by date, user_id, city;"
- int max_try_secs3 = 60
- while (max_try_secs3--) {
- String res = getJobState(tbName3)
- if (res == "FINISHED" || res == "CANCELLED") {
- assertEquals("FINISHED", res)
- sleep(3000)
- break
- } else {
- Thread.sleep(2000)
- if (max_try_secs2 < 1) {
- println "test timeout," + "state:" + res
- assertEquals("FINISHED",res)
- }
- }
- }
explain {
sql("select sum(age) from ${tbName3};")
contains "(mv4)"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/aggHaveDupBase.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/aggHaveDupBase.groovy
index d9aebf427dc..6bfa5b81aae 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/aggHaveDupBase.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/aggHaveDupBase.groovy
@@ -19,14 +19,12 @@ import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("aggHaveDupBase") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
def tbName1 = "agg_have_dup_base"
- def getJobState = { tableName ->
- def jobStateResult = sql """ SHOW ALTER TABLE MATERIALIZED VIEW WHERE
TableName='${tableName}' ORDER BY CreateTime DESC LIMIT 1; """
- return jobStateResult[0][8]
- }
sql """ DROP TABLE IF EXISTS agg_have_dup_base; """
sql """
create table agg_have_dup_base(
@@ -46,8 +44,7 @@ suite ("aggHaveDupBase") {
sql "insert into agg_have_dup_base select 3,-3,null,'c';"
sql "insert into agg_have_dup_base select 3,-3,null,'c';"
- createMV( "create materialized view k12s3m as select k1 as
a1,sum(k2),max(k2) from agg_have_dup_base group by k1;")
-
+ create_sync_mv(db, "agg_have_dup_base", "k12s3m", "select k1 as
a1,sum(k2),max(k2) from agg_have_dup_base group by k1;")
sql "insert into agg_have_dup_base select -4,-4,-4,'d';"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/case_ignore.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/case_ignore.groovy
index 63b11a64d52..f5055b63e29 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/case_ignore.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/case_ignore.groovy
@@ -18,6 +18,9 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("case_ignore") {
+
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
sql """ DROP TABLE IF EXISTS case_ignore; """
@@ -38,9 +41,7 @@ suite ("case_ignore") {
sql "insert into case_ignore select 2,2,2,'b';"
sql "insert into case_ignore select 3,-3,null,'c';"
-
- createMV ("create materialized view k12a as select K1 as a1,abs(K2) from
case_ignore;")
- sleep(3000)
+ create_sync_mv(db, "case_ignore", "k12a", "select K1 as a1,abs(K2) from
case_ignore;")
sql "insert into case_ignore select -4,-4,-4,'d';"
sql "SET experimental_enable_nereids_planner=true"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_gb_mv_abs.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_gb_mv_abs.groovy
index f9c729b4d6b..36f7219bac7 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_gb_mv_abs.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_gb_mv_abs.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("dup_gb_mv_abs") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
sql """ DROP TABLE IF EXISTS dup_gb_mv_abs; """
@@ -38,8 +40,7 @@ suite ("dup_gb_mv_abs") {
sql "insert into dup_gb_mv_abs select 2,2,2,'b';"
sql "insert into dup_gb_mv_abs select 3,-3,null,'c';"
- createMV ("create materialized view k12sa as select k1 as a1,sum(abs(k2))
from dup_gb_mv_abs group by k1;")
- sleep(3000)
+ create_sync_mv(db, "dup_gb_mv_abs", "k12sa", "select k1 as a1,sum(abs(k2))
from dup_gb_mv_abs group by k1;")
sql "insert into dup_gb_mv_abs select -4,-4,-4,'d';"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_gb_mv_plus.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_gb_mv_plus.groovy
index 7dd41182d50..3e22a1787c8 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_gb_mv_plus.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_gb_mv_plus.groovy
@@ -18,6 +18,9 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("dup_gb_mv_plus") {
+
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
sql """ DROP TABLE IF EXISTS dup_gb_mv_plus; """
@@ -38,8 +41,7 @@ suite ("dup_gb_mv_plus") {
sql "insert into dup_gb_mv_plus select 2,2,2,'b';"
sql "insert into dup_gb_mv_plus select 3,-3,null,'c';"
- createMV( "create materialized view k12sp as select k1 as a1,sum(k2+1)
from dup_gb_mv_plus group by k1;")
- sleep(3000)
+ create_sync_mv(db, "dup_gb_mv_plus", "k12sp", "select k1 as a1,sum(k2+1)
from dup_gb_mv_plus group by k1;")
sql "insert into dup_gb_mv_plus select -4,-4,-4,'d';"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_abs.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_abs.groovy
index 66acaedd684..bb32b2dca82 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_abs.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_abs.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("dup_mv_abs") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
sql """ DROP TABLE IF EXISTS dup_mv_abs; """
@@ -37,8 +39,7 @@ suite ("dup_mv_abs") {
sql "insert into dup_mv_abs select 2,2,2,'b';"
sql "insert into dup_mv_abs select 3,-3,null,'c';"
- createMV ("create materialized view k12a as select k1 as a1,abs(k2) from
dup_mv_abs;")
- sleep(3000)
+ create_sync_mv(db, "dup_mv_abs", "k12a", "select k1 as a1,abs(k2) from
dup_mv_abs;")
sql "insert into dup_mv_abs select -4,-4,-4,'d';"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_bin.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_bin.groovy
index 2348bc7dea6..3be57a5cb66 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_bin.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_bin.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("dup_mv_bin") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
sql """ DROP TABLE IF EXISTS dup_mv_bin; """
@@ -38,8 +40,7 @@ suite ("dup_mv_bin") {
sql "insert into dup_mv_bin select 2,2,2,'b';"
sql "insert into dup_mv_bin select 3,-3,null,'c';"
- createMV( "create materialized view k12b as select k1 as a1,bin(k2) from
dup_mv_bin;")
- sleep(3000)
+ create_sync_mv(db, "dup_mv_bin", "k12b", "select k1 as a1,bin(k2) from
dup_mv_bin;")
sql "insert into dup_mv_bin select -4,-4,-4,'d';"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_bm_hash.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_bm_hash.groovy
index 77245ca102f..5863532ef35 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_bm_hash.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_bm_hash.groovy
@@ -16,6 +16,8 @@
// under the License.
suite ("dup_mv_bm_hash") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
sql """ DROP TABLE IF EXISTS dup_mv_bm_hash; """
@@ -35,7 +37,7 @@ suite ("dup_mv_bm_hash") {
sql "insert into dup_mv_bm_hash select 2,2,'b';"
sql "insert into dup_mv_bm_hash select 3,3,'c';"
- createMV( "create materialized view dup_mv_bm_hash_mv1 as select k1 as
a1,bitmap_union(to_bitmap(k2)) as a2 from dup_mv_bm_hash group by k1;")
+ create_sync_mv(db, "dup_mv_bm_hash", "dup_mv_bm_hash_mv1", "select k1 as
a1,bitmap_union(to_bitmap(k2)) as a2 from dup_mv_bm_hash group by k1;")
sql "SET experimental_enable_nereids_planner=true"
sql "SET enable_fallback_to_original_planner=false"
@@ -51,7 +53,7 @@ suite ("dup_mv_bm_hash") {
sql """set enable_stats=true;"""
mv_rewrite_success("select bitmap_union_count(to_bitmap(k2)) from
dup_mv_bm_hash group by k1 order by k1;", "dup_mv_bm_hash_mv1")
- createMV("create materialized view dup_mv_bm_hash_mv2 as select k1 as
a3,bitmap_union(bitmap_hash(k3)) as a4 from dup_mv_bm_hash group by k1;")
+ create_sync_mv(db, "dup_mv_bm_hash", "dup_mv_bm_hash_mv2", "select k1 as
a3,bitmap_union(bitmap_hash(k3)) as a4 from dup_mv_bm_hash group by k1;")
sql "insert into dup_mv_bm_hash select 2,2,'bb';"
sql "insert into dup_mv_bm_hash select 3,3,'c';"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_plus.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_plus.groovy
index 15b6acfd22c..035db5aea54 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_plus.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_plus.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("dup_mv_plus") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
sql """ DROP TABLE IF EXISTS dup_mv_plus; """
@@ -38,8 +40,7 @@ suite ("dup_mv_plus") {
sql "insert into dup_mv_plus select 2,2,2,'b';"
sql "insert into dup_mv_plus select 3,-3,null,'c';"
- createMV ("create materialized view k12p as select k1 as a1,k2+1 from
dup_mv_plus;")
- sleep(3000)
+ create_sync_mv(db, "dup_mv_plus", "k12p", "select k1 as a1,k2+1 from
dup_mv_plus;")
sql "insert into dup_mv_plus select -4,-4,-4,'d';"
sql "SET experimental_enable_nereids_planner=true"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_year.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_year.groovy
index f0f8e48b79c..2890a14703e 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_year.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/dup_mv_year.groovy
@@ -16,6 +16,8 @@
// under the License.
suite ("dup_mv_year") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
sql """ DROP TABLE IF EXISTS dup_mv_year; """
@@ -51,7 +53,7 @@ suite ("dup_mv_year") {
sql """set enable_stats=true;"""
mv_rewrite_success("select k1,year(k2) from dup_mv_year order by k1;",
"k12y")
- createMV "create materialized view k13y as select k1 as a3,year(k3) as a4
from dup_mv_year;"
+ create_sync_mv(db, "dup_mv_year", "k13y", "select k1 as a3,year(k3) as a4
from dup_mv_year;")
sql "insert into dup_mv_year select 4,'2033-12-31','2033-12-31 01:02:03';"
Thread.sleep(1000)
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot1.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot1.groovy
index 1544f96cf10..7e6c048fb93 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot1.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot1.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("multi_slot1") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
sql """ DROP TABLE IF EXISTS multi_slot1; """
@@ -38,8 +40,7 @@ suite ("multi_slot1") {
sql "insert into multi_slot1 select 2,2,2,'b';"
sql "insert into multi_slot1 select 3,-3,null,'c';"
- createMV ("create materialized view k1a2p2ap3p as select abs(k1)+k2+1 as
a1,abs(k2+2)+k3+3 as a2 from multi_slot1;")
- sleep(3000)
+ create_sync_mv(db, "multi_slot1", "k1a2p2ap3p", "select abs(k1)+k2+1 as
a1,abs(k2+2)+k3+3 as a2 from multi_slot1;")
sql "insert into multi_slot1 select -4,-4,-4,'d';"
sql "SET experimental_enable_nereids_planner=true"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot2.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot2.groovy
index f1649262eaf..7c6564ec402 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot2.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot2.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("multi_slot2") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
sql """ DROP TABLE IF EXISTS multi_slot2; """
@@ -46,9 +48,8 @@ suite ("multi_slot2") {
}
assertTrue(createFail);
- createMV ("create materialized view k1a2p2ap3ps as select abs(k1)+k2+1 as
a3,sum(abs(k2+2)+k3+3) as a4 from multi_slot2 group by abs(k1)+k2+1;")
+ create_sync_mv(db, "multi_slot2", "k1a2p2ap3ps", "select abs(k1)+k2+1 as
a3,sum(abs(k2+2)+k3+3) as a4 from multi_slot2 group by abs(k1)+k2+1;")
- sleep(3000)
sql "insert into multi_slot2 select -4,-4,-4,'d';"
sql "SET experimental_enable_nereids_planner=true"
sql "SET enable_fallback_to_original_planner=false"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot3.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot3.groovy
index d862fe717e0..e9264d3f009 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot3.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot3.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("multi_slot3") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
sql """ DROP TABLE IF EXISTS multi_slot3; """
@@ -38,9 +40,7 @@ suite ("multi_slot3") {
sql "insert into multi_slot3 select 2,2,2,'b';"
sql "insert into multi_slot3 select 3,-3,null,'c';"
- createMV ("create materialized view k1p2ap3p as select k1+1,abs(k2+2)+k3+3
from multi_slot3;")
-
- sleep(3000)
+ create_sync_mv(db, "multi_slot3", "k1p2ap3p", "select k1+1,abs(k2+2)+k3+3
from multi_slot3;")
sql "insert into multi_slot3 select -4,-4,-4,'d';"
sql "SET experimental_enable_nereids_planner=true"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot4.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot4.groovy
index 0d5fbf99d68..55e875086b5 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot4.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot4.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("multi_slot4") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
sql """ DROP TABLE IF EXISTS multi_slot4; """
@@ -45,9 +47,7 @@ suite ("multi_slot4") {
sql "insert into multi_slot4 select 3,-3,null,'c';"
sql "insert into multi_slot4 select 3,-3,null,'c';"
- createMV ("create materialized view k1p2ap3ps as select
k1+1,sum(abs(k2+2)+k3+3) from multi_slot4 group by k1+1;")
-
- sleep(3000)
+ create_sync_mv(db, "multi_slot4", "k1p2ap3ps", "select
k1+1,sum(abs(k2+2)+k3+3) from multi_slot4 group by k1+1;")
sql "insert into multi_slot4 select -4,-4,-4,'d';"
sql "insert into multi_slot4 select -4,-4,-4,'d';"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot5.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot5.groovy
index 200dae0884c..1716c84ae3a 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot5.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot5.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("multi_slot5") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
sql """ DROP TABLE IF EXISTS multi_slot5; """
@@ -38,9 +40,7 @@ suite ("multi_slot5") {
sql "insert into multi_slot5 select 2,2,2,'b';"
sql "insert into multi_slot5 select 3,-3,null,'c';"
- createMV ("create materialized view k123p as select k1 as a1,k2+k3 from
multi_slot5;")
-
- sleep(3000)
+ create_sync_mv(db, "multi_slot5", "k123p", "select k1 as a1,k2+k3 from
multi_slot5;")
sql "insert into multi_slot5 select -4,-4,-4,'d';"
sql "insert into multi_slot5 select 3,-3,null,'c';"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot6.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot6.groovy
index f625b6d5b4f..370ec37e49e 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot6.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/multi_slot6.groovy
@@ -16,6 +16,8 @@
// under the License.
suite ("multi_slot6") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql """ DROP TABLE IF EXISTS multi_slot6; """
@@ -36,9 +38,9 @@ suite ("multi_slot6") {
sql "insert into multi_slot6 select 2,2,2,'b';"
sql "insert into multi_slot6 select 3,-3,null,'c';"
- createMV ("create materialized view k1a2p2ap3p as select
abs(k1)+k2+1,abs(k2+2)+k3+3 from multi_slot6;")
+ create_sync_mv(db, "multi_slot6", "k1a2p2ap3p", "select
abs(k1)+k2+1,abs(k2+2)+k3+3 from multi_slot6;")
- createMV("create materialized view k1a2p2ap3ps as select abs(k1)+k2+1 as
a1,sum(abs(k2+2)+k3+3) as a2 from multi_slot6 group by abs(k1)+k2+1;")
+ create_sync_mv(db, "multi_slot6", "k1a2p2ap3ps", "select abs(k1)+k2+1 as
a3,sum(abs(k2+2)+k3+3) as a4 from multi_slot6 group by abs(k1)+k2+1;")
sql "insert into multi_slot6 select -4,-4,-4,'d';"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/mv_with_view.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/mv_with_view.groovy
index 46abc3efb5b..a9957b1db1d 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/mv_with_view.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/mv_with_view.groovy
@@ -18,7 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("mv_with_view") {
-
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
sql """ DROP TABLE IF EXISTS d_table; """
@@ -38,7 +39,7 @@ suite ("mv_with_view") {
sql """insert into d_table select 1,1,1,'a';"""
sql """insert into d_table select 2,2,2,'b';"""
- createMV("create materialized view k312 as select k3 as a1,k1 as a2,k2 as
a3 from d_table;")
+ create_sync_mv(db, "d_table", "k312", "select k3 as a1,k1 as a2,k2 as a3
from d_table;")
sql """insert into d_table select 3,-3,null,'c';"""
diff --git a/regression-test/suites/nereids_syntax_p0/mv/newMv/rollback1.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/rollback1.groovy
index 67f72a22758..f9a4437336a 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/rollback1.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/rollback1.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("rollback1") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO, so set NOT_IN_RBO
explicitly
sql "set pre_materialized_view_rewrite_strategy = NOT_IN_RBO"
sql """ DROP TABLE IF EXISTS rollback1; """
@@ -38,9 +40,7 @@ suite ("rollback1") {
sql "insert into rollback1 select 2,2,2,'b';"
sql "insert into rollback1 select 3,-3,null,'c';"
- createMV("create materialized view k123p as select k1 as a1,k2+k3 from
rollback1;")
-
- sleep(3000)
+ create_sync_mv(db, "rollback1", "k123p_2", "select k1 as a1,k2+k3 from
rollback1;")
sql "insert into rollback1 select -4,-4,-4,'d';"
sql "SET experimental_enable_nereids_planner=true"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/single_slot.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/single_slot.groovy
index 5d8c7b7c788..2605b79179b 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/single_slot.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/single_slot.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("single_slot") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql """ DROP TABLE IF EXISTS single_slot; """
@@ -38,9 +40,7 @@ suite ("single_slot") {
sql "insert into single_slot select 1,3,2,'b';"
sql "insert into single_slot select 2,5,null,'c';"
- createMV("create materialized view k1ap2spa as select
abs(k1)+1,sum(abs(k2+1)) from single_slot group by abs(k1)+1;")
-
- sleep(3000)
+ create_sync_mv(db, "single_slot", "k1ap2spa", "select abs(k1)+1
t,sum(abs(k2+1)) from single_slot group by abs(k1)+1;")
sql "insert into single_slot select 2,-4,-4,'d';"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/newMv/sum_devide_count.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/sum_devide_count.groovy
index 6ea5c823887..9011129fd0e 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/sum_devide_count.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/sum_devide_count.groovy
@@ -16,6 +16,8 @@
// under the License.
suite ("sum_devide_count") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql """ DROP TABLE IF EXISTS sum_devide_count; """
@@ -48,9 +50,7 @@ suite ("sum_devide_count") {
sql "SET experimental_enable_nereids_planner=true"
sql "SET enable_fallback_to_original_planner=false"
- createMV ("create materialized view kavg as select k1 as a1,k4 as
a2,sum(k2),count(k2) from sum_devide_count group by k1,k4;")
-
- sleep(3000)
+ create_sync_mv(db, "sum_devide_count", "kavg", "select k1 as a1,k4 as
a2,sum(k2),count(k2) from sum_devide_count group by k1,k4;")
sql "insert into sum_devide_count select -4,-4,-4,'d';"
sql "insert into sum_devide_count select -4,-4,-4,'d';"
diff --git a/regression-test/suites/nereids_syntax_p0/mv/newMv/unique_mv.groovy
b/regression-test/suites/nereids_syntax_p0/mv/newMv/unique_mv.groovy
index ef3f1eb314f..24a09eca2ee 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/newMv/unique_mv.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/newMv/unique_mv.groovy
@@ -16,6 +16,8 @@
// under the License.
suite ("unique_mv") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql """set enable_nereids_planner=true;"""
@@ -40,7 +42,7 @@ suite ("unique_mv") {
);
"""
- createMV("""create materialized view mv_1 as select call_uuid as a1,org_id
as a2,call_time as a3,id as a4,campaign_id as a5,aa as a6 from c5816_t""")
+ create_sync_mv(db, "c5816_t", "mv_1", "select call_uuid as a1,org_id as
a2,call_time as a3,id as a4,campaign_id as a5,aa as a6 from c5816_t;")
sql """insert into c5816_t values (1,2,"2023-11-20
00:00:00",4,"adc",12);"""
sql "analyze table c5816_t with sync;"
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/MVMultiUsage.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/MVMultiUsage.groovy
index 547884a0f0f..d1cd9e09168 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/MVMultiUsage.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/MVMultiUsage.groovy
@@ -18,6 +18,7 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("MVMultiUsage") {
+
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/MVWithAs.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/MVWithAs.groovy
index 0c33c88526f..ba7252171af 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/MVWithAs.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/MVWithAs.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("MVWithAs") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -40,9 +42,7 @@ suite ("MVWithAs") {
sql """insert into MVWithAs values("2020-01-02",2,"b",2);"""
sql """insert into MVWithAs values("2020-01-02",2,"b",2);"""
- createMV("create materialized view MVWithAs_mv as select user_id as a1,
count(tag_id) from MVWithAs group by user_id;")
-
- sleep(3000)
+ create_sync_mv(db, "MVWithAs", "MVWithAs_mv", "select user_id as a1,
count(tag_id) from MVWithAs group by user_id;")
sql """insert into MVWithAs values("2020-01-01",1,"a",1);"""
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/ut/aggMVCalcAggFun.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/aggMVCalcAggFun.groovy
index 5103cfd1a89..ceed9da6fb1 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/aggMVCalcAggFun.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/aggMVCalcAggFun.groovy
@@ -19,6 +19,8 @@ import org.codehaus.groovy.runtime.IOGroovyMethods
// testAggregateMVCalcAggFunctionQuery
suite ("aggMVCalcAggFun") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -40,9 +42,7 @@ suite ("aggMVCalcAggFun") {
sql """insert into aggMVCalcAggFun values("2020-01-02",2,"b",2,2,2);"""
sql """insert into aggMVCalcAggFun values("2020-01-03",3,"c",3,3,3);"""
- createMV("create materialized view aggMVCalcAggFunMv as select deptno as
a1, empid as a2, sum(salary) from aggMVCalcAggFun group by empid, deptno;")
-
- sleep(3000)
+ create_sync_mv(db, "aggMVCalcAggFun", "aggMVCalcAggFunMv", "select deptno
as a1, empid as a2, sum(salary) from aggMVCalcAggFun group by empid, deptno;")
sql """insert into aggMVCalcAggFun values("2020-01-01",1,"a",1,1,1);"""
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV1.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV1.groovy
index eb4358d94b8..52f895f6732 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV1.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV1.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("aggOnAggMV1") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -46,9 +48,7 @@ suite ("aggOnAggMV1") {
sql """insert into aggOnAggMV1 values("2020-01-03",3,"c",3,3,3);"""
- createMV("create materialized view aggOnAggMV1_mv as select deptno as a1,
sum(salary), max(commission) from aggOnAggMV1 group by deptno ;")
-
- sleep(3000)
+ create_sync_mv(db, "aggOnAggMV1", "aggOnAggMV1_mv", "select deptno as a1,
sum(salary), max(commission) from aggOnAggMV1 group by deptno;")
sql """insert into aggOnAggMV1 values("2020-01-01",1,"a",1,1,1);"""
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV10.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV10.groovy
index daad18b034f..2475c626d58 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV10.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV10.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("aggOnAggMV10") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV11.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV11.groovy
index d275af4ecee..9c8cd3abdea 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV11.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV11.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("aggOnAggMV11") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -43,9 +45,7 @@ suite ("aggOnAggMV11") {
sql """insert into aggOnAggMV11 values("2020-01-03",3,"c",3,3,3);"""
sql """insert into aggOnAggMV11 values("2020-01-03",3,"c",3,3,3);"""
- createMV("create materialized view aggOnAggMV11_mv as select deptno as a1,
count(salary) from aggOnAggMV11 group by deptno;")
-
- sleep(3000)
+ create_sync_mv(db, "aggOnAggMV11", "aggOnAggMV11_mv", "select deptno as
a1, count(salary) from aggOnAggMV11 group by deptno;")
sql """insert into aggOnAggMV11 values("2020-01-01",1,"a",1,1,1);"""
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV2.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV2.groovy
index cec0d1d88dd..1dc125cac88 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV2.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV2.groovy
@@ -16,6 +16,8 @@
// under the License.
suite ("aggOnAggMV2") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -48,9 +50,7 @@ suite ("aggOnAggMV2") {
}
order_qt_select_emps_mv "select deptno, sum(salary) from aggOnAggMV2 group
by deptno order by deptno;"
- createMV("create materialized view aggOnAggMV2_mv as select deptno as x1,
sum(salary) from aggOnAggMV2 group by deptno ;")
-
- sleep(3000)
+ create_sync_mv(db, "aggOnAggMV2", "aggOnAggMV2_mv", "select deptno as x1,
sum(salary) from aggOnAggMV2 group by deptno ;")
sql "analyze table aggOnAggMV2 with sync;"
sql """alter table aggOnAggMV2 modify column time_col set stats
('row_count'='8');"""
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV3.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV3.groovy
index db6cfc7a079..154528d8541 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV3.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV3.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("aggOnAggMV3") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -46,9 +48,7 @@ suite ("aggOnAggMV3") {
- createMV("create materialized view aggOnAggMV3_mv as select deptno as a1,
commission as a2, sum(salary) from aggOnAggMV3 group by deptno, commission ;")
-
- sleep(3000)
+ create_sync_mv(db, "aggOnAggMV3", "aggOnAggMV3_mv", "select deptno as a1,
commission as a2, sum(salary) from aggOnAggMV3 group by deptno, commission ;")
sql "analyze table aggOnAggMV3 with sync;"
sql """alter table aggOnAggMV3 modify column time_col set stats
('row_count'='8');"""
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV5.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV5.groovy
index d39285cd50c..3fdf5a84c67 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV5.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV5.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("aggOnAggMV5") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -44,8 +46,7 @@ suite ("aggOnAggMV5") {
sql """insert into aggOnAggMV5 values("2020-01-03",3,"c",3,3,3);"""
sql """insert into aggOnAggMV5 values("2020-01-03",3,"c",3,3,3);"""
- createMV("create materialized view aggOnAggMV5_mv as select deptno as a1,
commission as a2, sum(salary) from aggOnAggMV5 group by deptno, commission;")
-
+ create_sync_mv(db, "aggOnAggMV5", "aggOnAggMV5_mv", "select deptno as a1,
commission as a2, sum(salary) from aggOnAggMV5 group by deptno, commission ;")
sql """insert into aggOnAggMV5 values("2020-01-01",1,"a",1,1,1);"""
sql "analyze table aggOnAggMV5 with sync;"
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV6.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV6.groovy
index 7024def3e01..ce63fefa237 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV6.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV6.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("aggOnAggMV6") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -42,9 +44,7 @@ suite ("aggOnAggMV6") {
sql """insert into aggOnAggMV6 values("2020-01-03",3,"c",3,3,3);"""
sql """insert into aggOnAggMV6 values("2020-01-03",3,"c",3,3,3);"""
- createMV("create materialized view aggOnAggMV6_mv as select deptno as a1,
commission as a2, sum(salary) from aggOnAggMV6 group by deptno, commission;")
-
- sleep(3000)
+ create_sync_mv(db, "aggOnAggMV6", "aggOnAggMV6_mv", "select deptno as a1,
commission as a2, sum(salary) from aggOnAggMV6 group by deptno, commission ;")
sql """insert into aggOnAggMV6 values("2020-01-01",1,"a",1,1,1);"""
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV7.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV7.groovy
index 463bfcf2f1d..9974e3b18c4 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV7.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/aggOnAggMV7.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("aggOnAggMV7") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -42,9 +44,7 @@ suite ("aggOnAggMV7") {
sql """insert into aggOnAggMV7 values("2020-01-03",3,"c",3,3,3);"""
sql """insert into aggOnAggMV7 values("2020-01-03",3,"c",3,3,3);"""
- createMV("create materialized view aggOnAggMV7_mv as select deptno as a1,
commission as a2, sum(salary) from aggOnAggMV7 group by deptno, commission;")
-
- sleep(3000)
+ create_sync_mv(db, "aggOnAggMV7", "aggOnAggMV7_mv", "select deptno as a1,
commission as a2, sum(salary) from aggOnAggMV7 group by deptno, commission ;")
sql """insert into aggOnAggMV7 values("2020-01-01",1,"a",1,1,1);"""
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/ut/bitmapUnionIn.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/bitmapUnionIn.groovy
index 740cf857890..cc023b00b26 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/bitmapUnionIn.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/bitmapUnionIn.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("bitmapUnionIn") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -36,9 +38,7 @@ suite ("bitmapUnionIn") {
sql """insert into bitmapUnionIn values("2020-01-01",1,"a",1);"""
sql """insert into bitmapUnionIn values("2020-01-02",2,"b",2);"""
- createMV("create materialized view bitmapUnionIn_mv as select user_id as
a1, bitmap_union(to_bitmap(tag_id)) from bitmapUnionIn group by user_id;")
-
- sleep(3000)
+ create_sync_mv(db, "bitmapUnionIn", "bitmapUnionIn_mv", "select user_id as
a1, bitmap_union(to_bitmap(tag_id)) from bitmapUnionIn group by user_id;")
sql """insert into bitmapUnionIn values("2020-01-01",1,"a",2);"""
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/ut/distinctQuery.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/distinctQuery.groovy
index 4162a31a586..8b757bfa4a6 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/distinctQuery.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/distinctQuery.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("distinctQuery") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -44,9 +46,9 @@ suite ("distinctQuery") {
sql """insert into distinctQuery values("2020-01-01",1,"a",1,1,1);"""
sql """insert into distinctQuery values("2020-01-01",2,"a",1,1,1);"""
- createMV("create materialized view distinctQuery_mv as select deptno as
a1, count(salary) as a2 from distinctQuery group by deptno;")
+ create_sync_mv(db, "distinctQuery", "distinctQuery_mv", "select deptno as
a1, count(salary) as a2 from distinctQuery group by deptno;")
- createMV("create materialized view distinctQuery_mv2 as select empid as
a3, deptno as a4, count(salary) as a5 from distinctQuery group by empid,
deptno;")
+ create_sync_mv(db, "distinctQuery", "distinctQuery_mv2", "select empid as
a3, deptno as a4, count(distinct empid) as a5 from distinctQuery group by
empid, deptno;")
sql "analyze table distinctQuery with sync;"
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/incMVReInSub.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/incMVReInSub.groovy
index 291ad015b3f..efa0fdba068 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/incMVReInSub.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/incMVReInSub.groovy
@@ -19,6 +19,8 @@ import org.codehaus.groovy.runtime.IOGroovyMethods
// nereids_testIncorrectMVRewriteInSubquery
suite ("incMVReInSub") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -37,9 +39,7 @@ suite ("incMVReInSub") {
sql """insert into incMVReInSub values("2020-01-01",1,"a",1);"""
sql """insert into incMVReInSub values("2020-01-02",2,"b",2);"""
- createMV("create materialized view incMVReInSub_mv as select user_id as
a1, bitmap_union(to_bitmap(tag_id)) from incMVReInSub group by user_id;")
-
- sleep(3000)
+ create_sync_mv(db, "incMVReInSub", "incMVReInSub_mv", "select user_id as
a1, bitmap_union(to_bitmap(tag_id)) from incMVReInSub group by user_id;")
sql """insert into incMVReInSub values("2020-01-01",1,"a",2);"""
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/incRewriteCD.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/incRewriteCD.groovy
index 9dcbc080d0d..8e0502a2fe5 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/incRewriteCD.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/incRewriteCD.groovy
@@ -19,6 +19,8 @@ import org.codehaus.groovy.runtime.IOGroovyMethods
// nereids_testIncorrectRewriteCountDistinct
suite ("incRewriteCD") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -37,10 +39,7 @@ suite ("incRewriteCD") {
sql """insert into incRewriteCD values("2020-01-01",1,"a",1);"""
sql """insert into incRewriteCD values("2020-01-02",2,"b",2);"""
- createMV("create materialized view incRewriteCD_mv as select user_id as
a1, bitmap_union(to_bitmap(tag_id)) from incRewriteCD group by user_id;")
-
- sleep(3000)
-
+ create_sync_mv(db, "incRewriteCD", "incRewriteCD_mv", "select user_id as
a1, bitmap_union(to_bitmap(tag_id)) from incRewriteCD group by user_id;")
sql """insert into incRewriteCD values("2020-01-01",1,"a",2);"""
sql "analyze table incRewriteCD with sync;"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/ut/joinOnCalcToJoin.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/joinOnCalcToJoin.groovy
index fa5ebe9c99d..074e757b9fa 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/joinOnCalcToJoin.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/joinOnCalcToJoin.groovy
@@ -17,6 +17,8 @@
// nereids_testJoinOnLeftProjectToJoin
suite ("joinOnCalcToJoin") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -53,11 +55,9 @@ suite ("joinOnCalcToJoin") {
sql """insert into joinOnCalcToJoin_1 values("2020-01-03",3,"c",3);"""
sql """insert into joinOnCalcToJoin_1 values("2020-01-02",2,"b",1);"""
+ create_sync_mv(db, "joinOnCalcToJoin", "joinOnLeftPToJoin_mv", "select
empid as a1, deptno as a2 from joinOnCalcToJoin ;")
- createMV("create materialized view joinOnLeftPToJoin_mv as select empid as
a1, deptno as a2 from joinOnCalcToJoin;")
- sleep(3000)
- createMV("create materialized view joinOnLeftPToJoin_1_mv as select deptno
as a3, cost as a4 from joinOnCalcToJoin_1;")
- sleep(3000)
+ create_sync_mv(db, "joinOnCalcToJoin_1", "joinOnLeftPToJoin_1_mv", "select
deptno as a3, cost as a4 from joinOnCalcToJoin_1 ;")
sql "analyze table joinOnCalcToJoin with sync;"
sql "analyze table joinOnCalcToJoin_1 with sync;"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/ut/joinOnLeftPToJoin.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/joinOnLeftPToJoin.groovy
index fcc4010835b..7b88fd38308 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/joinOnLeftPToJoin.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/joinOnLeftPToJoin.groovy
@@ -17,6 +17,8 @@
// nereids_testJoinOnLeftProjectToJoin
suite ("joinOnLeftPToJoin") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -54,10 +56,9 @@ suite ("joinOnLeftPToJoin") {
sql """insert into joinOnLeftPToJoin_1 values("2020-01-03",3,"c",3);"""
sql """insert into joinOnLeftPToJoin_1 values("2020-01-02",2,"b",1);"""
- createMV("create materialized view joinOnLeftPToJoin_mv as select deptno
as a1, sum(salary) as a2, sum(commission) as a3 from joinOnLeftPToJoin group by
deptno;")
- sleep(3000)
- createMV("create materialized view joinOnLeftPToJoin_1_mv as select deptno
as a4, max(cost) as a5 from joinOnLeftPToJoin_1 group by deptno;")
- sleep(3000)
+ create_sync_mv(db, "joinOnLeftPToJoin", "joinOnLeftPToJoin_mv", "select
deptno as a1, sum(salary) as a2, sum(commission) as a3 from joinOnLeftPToJoin
group by deptno;")
+
+ create_sync_mv(db, "joinOnLeftPToJoin_1", "joinOnLeftPToJoin_1_mv",
"select deptno as a4, max(cost) as a5 from joinOnLeftPToJoin_1 group by
deptno;")
sql "analyze table joinOnLeftPToJoin with sync;"
sql "analyze table joinOnLeftPToJoin_1 with sync;"
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/onStar.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/onStar.groovy
index e5ccfd2a65d..53aec3b65b8 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/onStar.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/onStar.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("onStar") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -38,9 +40,7 @@ suite ("onStar") {
sql """insert into onStar values("2020-01-01",1,"a",1,1,1);"""
sql """insert into onStar values("2020-01-02",2,"b",2,2,2);"""
- createMV("create materialized view onStar_mv as select time_col as a1,
deptno as a7,empid as a2, name as a3, salary as a4, commission as a5 from
onStar order by time_col, deptno, empid;")
-
- sleep(3000)
+ create_sync_mv(db, "onStar", "onStar_mv", "select time_col as a1, deptno
as a7,empid as a2, name as a3, salary as a4, commission as a5 from onStar order
by time_col, deptno, empid;")
sql """insert into onStar values("2020-01-01",1,"a",1,1,1);"""
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/onlyGroupBy.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/onlyGroupBy.groovy
index 8a76c924a87..ff1e8b37468 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/onlyGroupBy.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/onlyGroupBy.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("onlyGroupBy") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -46,8 +48,7 @@ suite ("onlyGroupBy") {
sql """insert into onlyGroupBy values("2020-01-03",3,"c",3,3,3);"""
sql """insert into onlyGroupBy values("2020-01-03",3,"c",3,3,3);"""
- createMV("create materialized view onlyGroupBy_mv as select deptno as a1,
count(salary) from onlyGroupBy group by deptno;")
-
+ create_sync_mv(db, "onlyGroupBy", "onlyGroupBy_mv", "select deptno as a1,
count(salary) from onlyGroupBy group by deptno;")
sql """insert into onlyGroupBy values("2020-01-01",1,"a",1,1,1);"""
sql "analyze table onlyGroupBy with sync;"
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/ut/orderByOnPView.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/orderByOnPView.groovy
index cbde3767894..12269dad8b1 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/orderByOnPView.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/orderByOnPView.groovy
@@ -19,6 +19,8 @@ import org.codehaus.groovy.runtime.IOGroovyMethods
// nereids_testOrderByQueryOnProjectView
suite ("orderByOnPView") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -40,9 +42,7 @@ suite ("orderByOnPView") {
sql """insert into orderByOnPView values("2020-01-02",2,"b",2,2,2);"""
sql """insert into orderByOnPView values("2020-01-03",3,"c",3,3,3);"""
- createMV("create materialized view orderByOnPView_mv as select deptno as
a1, empid as a2 from orderByOnPView;")
-
- sleep(3000)
+ create_sync_mv(db, "orderByOnPView", "orderByOnPView_mv", "select deptno
as a1, empid as a2 from orderByOnPView;")
sql """insert into orderByOnPView values("2020-01-01",1,"a",1,1,1);"""
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV1.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV1.groovy
index 3d323d09f79..e31f29b422b 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV1.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV1.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("projectMV1") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -41,9 +43,7 @@ suite ("projectMV1") {
sql """insert into projectMV1 values("2020-01-01",1,"a",1,1,1);"""
sql """insert into projectMV1 values("2020-01-02",2,"b",2,2,2);"""
- createMV("create materialized view projectMV1_mv as select deptno as a1,
empid as a2 from projectMV1 order by deptno;")
-
- sleep(3000)
+ create_sync_mv(db, "projectMV1", "projectMV1_mv", "select deptno as a1,
empid as a2 from projectMV1 order by deptno;")
sql """insert into projectMV1 values("2020-01-01",1,"a",1,1,1);"""
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV2.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV2.groovy
index 3b21783c2ce..853bd3b1776 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV2.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV2.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("projectMV2") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
// this mv rewrite would not be rewritten in RBO phase, so set TRY_IN_RBO
explicitly to make case stable
sql "set pre_materialized_view_rewrite_strategy = TRY_IN_RBO"
sql "SET experimental_enable_nereids_planner=true"
@@ -39,9 +41,7 @@ suite ("projectMV2") {
sql """insert into projectMV2 values("2020-01-01",1,"a",1,1,1);"""
sql """insert into projectMV2 values("2020-01-02",2,"b",2,2,2);"""
- createMV("create materialized view projectMV2_mv as select deptno as a1,
empid as a2 from projectMV2 order by deptno;")
-
- sleep(3000)
+ create_sync_mv(db, "projectMV2", "projectMV2_mv", "select deptno as a1,
empid as a2 from projectMV2 order by deptno;")
sql """insert into projectMV2 values("2020-01-01",1,"a",1,1,1);"""
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV3.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV3.groovy
index 19dad39f7d2..c6a8f1c8331 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV3.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV3.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("projectMV3") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
sql "SET experimental_enable_nereids_planner=true"
sql "SET enable_fallback_to_original_planner=false"
sql """ DROP TABLE IF EXISTS projectMV3; """
@@ -42,8 +44,7 @@ suite ("projectMV3") {
def result = "null"
createMV("create materialized view projectMV3_mv as select deptno as a1,
empid as a2, name as a3 from projectMV3 order by deptno;")
-
- sleep(3000)
+ create_sync_mv(db, "projectMV3", "projectMV3_mv", "select deptno as a1,
empid as a2, name as a3 from projectMV3 order by deptno;")
sql """insert into projectMV3 values("2020-01-01",1,"a",1,1,1);"""
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV4.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV4.groovy
index f26a9137540..18766e43d2c 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV4.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/projectMV4.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("projectMV4") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
sql "SET experimental_enable_nereids_planner=true"
sql "SET enable_fallback_to_original_planner=false"
sql """ DROP TABLE IF EXISTS projectMV4; """
@@ -41,9 +43,7 @@ suite ("projectMV4") {
def result = "null"
- createMV("create materialized view projectMV4_mv as select name as a1,
deptno as a2, salary as a3 from projectMV4;")
-
- sleep(3000)
+ create_sync_mv(db, "projectMV4", "projectMV4_mv", "select name as a1,
deptno as a2, salary as a3 from projectMV4;")
sql """insert into projectMV4 values("2020-01-01",1,"a",1,1,1);"""
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/subQuery.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/subQuery.groovy
index 46be4f0bdf2..693b9b81d44 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/subQuery.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/subQuery.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("subQuery") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
sql "SET experimental_enable_nereids_planner=true"
sql "SET enable_fallback_to_original_planner=false"
sql """ DROP TABLE IF EXISTS subQuery; """
@@ -39,9 +41,7 @@ suite ("subQuery") {
sql """insert into subQuery values("2020-01-02",2,"b",2,2,2);"""
sql """insert into subQuery values("2020-01-03",3,"c",3,3,3);"""
- createMV("create materialized view subQuery_mv as select deptno as a1,
empid as a2 from subQuery;")
-
- sleep(3000)
+ create_sync_mv(db, "subQuery", "subQuery_mv", "select deptno as a1, empid
as a2 from subQuery order by deptno;")
sql """insert into subQuery values("2020-01-01",1,"a",1,1,1);"""
diff --git a/regression-test/suites/nereids_syntax_p0/mv/ut/unionDis.groovy
b/regression-test/suites/nereids_syntax_p0/mv/ut/unionDis.groovy
index 1d4d3b3a3be..4272e056a64 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/ut/unionDis.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/ut/unionDis.groovy
@@ -18,6 +18,8 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite ("unionDis") {
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
sql "SET experimental_enable_nereids_planner=true"
sql "SET enable_fallback_to_original_planner=false"
sql """ DROP TABLE IF EXISTS unionDis; """
@@ -39,9 +41,7 @@ suite ("unionDis") {
sql """insert into unionDis values("2020-01-02",2,"b",2,2,2);"""
sql """insert into unionDis values("2020-01-03",3,"c",3,3,3);"""
- createMV("create materialized view unionDis_mv as select empid as a1,
deptno as a2 from unionDis order by empid, deptno;")
-
- sleep(3000)
+ create_sync_mv(db, "unionDis", "unionDis_mv", "select empid as a1, deptno
as a2 from unionDis order by empid, deptno;")
sql """insert into unionDis values("2020-01-01",1,"a",1,1,1);"""
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
