@@ -126,12 +126,9 @@ suite("test_analyze_mv") {
126
126
"replication_num" = "1"
127
127
)
128
128
"""
129
- sql """ create materialized view mv1 as select key1 from mvTestDup;"""
130
- wait_mv_finish(" test_analyze_mv" , " mvTestDup" )
131
- sql """ create materialized view mv2 as select key2 from mvTestDup;"""
132
- wait_mv_finish(" test_analyze_mv" , " mvTestDup" )
133
- sql """ create materialized view mv3 as select key1, key2, sum(value1), max(value2), min(value3) from mvTestDup group by key1, key2;"""
134
- wait_mv_finish(" test_analyze_mv" , " mvTestDup" )
129
+ createMV(" create materialized view mv1 as select key1 from mvTestDup;" )
130
+ createMV(" create materialized view mv2 as select key2 from mvTestDup;" )
131
+ createMV(" create materialized view mv3 as select key1, key2, sum(value1), max(value2), min(value3) from mvTestDup group by key1, key2;" )
135
132
sql """ insert into mvTestDup values (1, 2, 3, 4, 5), (1, 2, 3, 4, 5), (10, 20, 30, 40, 50), (10, 20, 30, 40, 50), (100, 200, 300, 400, 500), (1001, 2001, 3001, 4001, 5001);"""
136
133
137
134
sql """ analyze table mvTestDup with sync;"""
@@ -236,12 +233,9 @@ suite("test_analyze_mv") {
236
233
);
237
234
"""
238
235
239
- sql """ create materialized view mv1 as select key2 from mvTestAgg;"""
240
- wait_mv_finish(" test_analyze_mv" , " mvTestAgg" )
241
- sql """ create materialized view mv3 as select key1, key2, sum(value1), max(value2), min(value3) from mvTestAgg group by key1, key2;"""
242
- wait_mv_finish(" test_analyze_mv" , " mvTestAgg" )
243
- sql """ create materialized view mv6 as select key1, sum(value1) from mvTestAgg group by key1;"""
244
- wait_mv_finish(" test_analyze_mv" , " mvTestAgg" )
236
+ createMV(" create materialized view mv1 as select key2 from mvTestAgg;" )
237
+ createMV(" create materialized view mv3 as select key1, key2, sum(value1), max(value2), min(value3) from mvTestAgg group by key1, key2;" )
238
+ createMV(" create materialized view mv6 as select key1, sum(value1) from mvTestAgg group by key1;" )
245
239
sql """ alter table mvTestAgg ADD ROLLUP rollup1(key1, value1)"""
246
240
wait_mv_finish(" test_analyze_mv" , " mvTestAgg" )
247
241
sql """ insert into mvTestAgg values (1, 2, 3, 4, 5), (1, 2, 3, 4, 5), (1, 11, 22, 33, 44), (10, 20, 30, 40, 50), (10, 20, 30, 40, 50), (100, 200, 300, 400, 500), (1001, 2001, 3001, 4001, 5001);"""
@@ -378,10 +372,8 @@ suite("test_analyze_mv") {
378
372
);
379
373
"""
380
374
381
- sql """ create materialized view mv1 as select key1 from mvTestUni;"""
382
- wait_mv_finish(" test_analyze_mv" , " mvTestUni" )
383
- sql """ create materialized view mv6 as select key2, value2, value3 from mvTestUni;"""
384
- wait_mv_finish(" test_analyze_mv" , " mvTestUni" )
375
+ createMV(" create materialized view mv1 as select key1 from mvTestUni;" )
376
+ createMV(" create materialized view mv6 as select key2, value2, value3 from mvTestUni;" )
385
377
sql """ insert into mvTestUni values (1, 2, 3, 4, 5), (1, 2, 3, 7, 8), (1, 11, 22, 33, 44), (10, 20, 30, 40, 50), (10, 20, 30, 40, 50), (100, 200, 300, 400, 500), (1001, 2001, 3001, 4001, 5001);"""
386
378
387
379
sql """ analyze table mvTestUni with sync;"""
0 commit comments