Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
148 changes: 105 additions & 43 deletions e2e_test/streaming/mv_on_mv.slt
Original file line number Diff line number Diff line change
@@ -1,221 +1,221 @@
control sortmode rowsort

statement ok
create table mom_t1(v1 int not null, v2 int not null);
create table t1(v1 int not null, v2 int not null);

statement ok
create table mom_t2(v1 real not null, v2 int not null, v3 real not null);
create table t2(v1 real not null, v2 int not null, v3 real not null);

statement ok
create materialized view mom_m1 as select v1, v2 from mom_t1 where v1 = 1;
create materialized view m1 as select v1, v2 from t1 where v1 = 1;

statement ok
create materialized view mom_m2 as select v1, v2 from mom_t1 where v2 = 1;
create materialized view m2 as select v1, v2 from t1 where v2 = 1;

statement ok
create materialized view mom_m3 as select sum(mom_m1.v1) as sum_mom_m1_v1, sum(mom_m1.v2) as sum_mom_m1_v2 from mom_m1;
create materialized view m3 as select sum(m1.v1) as sum_m1_v1, sum(m1.v2) as sum_m1_v2 from m1;

statement ok
create materialized view mom_m4 as select mom_m1.v1, mom_m1.v2, mom_m2.v1, mom_m2.v2 from mom_m1 join mom_m2 on mom_m1.v1 = mom_m2.v1;
create materialized view m4 as select m1.v1, m1.v2, m2.v1, m2.v2 from m1 join m2 on m1.v1 = m2.v1;

statement ok
flush;

statement ok
insert into mom_t1 values (2,1),(1,2),(1,1);
insert into t1 values (2,1),(1,2),(1,1);

statement ok
flush;

query II
select v1, v2 from mom_t1;
select v1, v2 from t1;
----
2 1
1 2
1 1

query II
select v1, v2 from mom_m1;
select v1, v2 from m1;
----
1 2
1 1

query II
select v1, v2 from mom_m2;
select v1, v2 from m2;
----
2 1
1 1

query II
select sum_mom_m1_v1, sum_mom_m1_v2 from mom_m3;
select sum_m1_v1, sum_m1_v2 from m3;
----
2 3

query IIII
select v1, v2, v10, v20 from mom_m4;
select v1, v2, v10, v20 from m4;
----
1 2 1 1
1 1 1 1

statement ok
create materialized view mom_m5 as select mom_m1.v1, mom_m1.v2, mom_m2.v1, mom_m2.v2 from mom_m1 join mom_m2 on mom_m1.v1 = mom_m2.v1;
create materialized view m5 as select m1.v1, m1.v2, m2.v1, m2.v2 from m1 join m2 on m1.v1 = m2.v1;

statement ok
flush;

query IIII
select v1, v2, v10, v20 from mom_m5;
select v1, v2, v10, v20 from m5;
----
1 2 1 1
1 1 1 1

statement ok
insert into mom_t1 values (3,1),(1,3);
insert into t1 values (3,1),(1,3);

statement ok
flush;

query IIII
select v1, v2, v10, v20 from mom_m5;
select v1, v2, v10, v20 from m5;
----
1 2 1 1
1 1 1 1
1 3 1 1

statement ok
create materialized view mom_m6 as select v2, v3, v1 from mom_t2;
create materialized view m6 as select v2, v3, v1 from t2;

statement ok
create materialized view mom_m7 as select sum(v1) as sum_v1, avg(v3) as avg_v3 from mom_m6 group by v1;
create materialized view m7 as select sum(v1) as sum_v1, avg(v3) as avg_v3 from m6 group by v1;

statement ok
create materialized view mom_m8 as select sum(v1) as sum_v1 from mom_m6 group by v2;
create materialized view m8 as select sum(v1) as sum_v1 from m6 group by v2;

statement ok
flush;

statement ok
insert into mom_t2 values (1,2,3),(1,5,6),(3,2,6);
insert into t2 values (1,2,3),(1,5,6),(3,2,6);

statement ok
flush;

query III
select v1, v2, v3 from mom_t2;
select v1, v2, v3 from t2;
----
1 2 3
1 5 6
3 2 6

query III
select v2, v3, v1 from mom_m6;
select v2, v3, v1 from m6;
----
2 3 1
5 6 1
2 6 3

query II
select sum_v1, avg_v3 from mom_m7;
select sum_v1, avg_v3 from m7;
----
2 4.5
3 6

query I
select sum_v1 from mom_m8;
select sum_v1 from m8;
----
4
1

statement ok
create materialized view mom_m9 as select * from mom_t2;
create materialized view m9 as select * from t2;

statement ok
create materialized view mom_m10 as select sum(v1) as sum_v1, sum(v3) as sum_v3 from mom_m9 group by v2;
create materialized view m10 as select sum(v1) as sum_v1, sum(v3) as sum_v3 from m9 group by v2;

statement ok
flush;

query III
select v1, v2, v3 from mom_m9;
select v1, v2, v3 from m9;
----
1 2 3
1 5 6
3 2 6

query II
select sum_v1, sum_v3 from mom_m10;
select sum_v1, sum_v3 from m10;
----
4 9
1 6

statement ok
create table mom_t3(v1 int not null, v2 int not null, v3 int not null);
create table t3(v1 int not null, v2 int not null, v3 int not null);

statement ok
flush;

statement ok
insert into mom_t3 values (1,2,3),(1,5,6),(3,2,6);
insert into t3 values (1,2,3),(1,5,6),(3,2,6);

statement ok
flush;

statement ok
create materialized view mom_m11 as select v1, v2, v3 from mom_t3;
create materialized view m11 as select v1, v2, v3 from t3;

statement ok
create materialized view mom_m12 as select round(avg(v1), 1) as avg_v1, sum(v2) as sum_v2, count(v3) as count_v3 from mom_m11;
create materialized view m12 as select round(avg(v1), 1) as avg_v1, sum(v2) as sum_v2, count(v3) as count_v3 from m11;

statement ok
flush;

query III
select v1, v2, v3 from mom_m11;
select v1, v2, v3 from m11;
----
1 2 3
1 5 6
3 2 6

query III
select avg_v1, sum_v2, count_v3 from mom_m12;
select avg_v1, sum_v2, count_v3 from m12;
----
1.7 9 3

statement ok
create table mom_t4(v1 real not null);
create table t4(v1 real not null);

statement ok
flush;

statement ok
insert into mom_t4 values(1),(2),(3);
insert into t4 values(1),(2),(3);

statement ok
flush;

statement ok
create materialized view mom_m13 as select * from mom_t4;
create materialized view m13 as select * from t4;

statement ok
create materialized view mom_m14 as select count(v1) as count_v1 from mom_m13;
create materialized view m14 as select count(v1) as count_v1 from m13;

statement ok
flush;

query I
select v1 from mom_m13;
select v1 from m13;
----
1
2
3

query I
select * from mom_m14;
select * from m14;
----
3

statement ok
create materialized view mom_m15 as select * from (select t1.v1 as t1v1, t2.v1 as t2v1 from mom_m13 t1 join mom_m13 t2 on t1.v1 = t2.v1);
create materialized view m15 as select * from (select t1.v1 as t1v1, t2.v1 as t2v1 from m13 t1 join m13 t2 on t1.v1 = t2.v1);

statement ok
flush;
Expand All @@ -227,8 +227,70 @@ statement ok
flush;

query II
select v1, v10 from mom_m15;
select v1, v10 from m15;
----
1 1
2 2
3 3
3 3



statement ok
drop materialized view m3;

statement ok
drop materialized view m4;

statement ok
drop materialized view m5;

statement ok
drop materialized view m1;

statement ok
drop materialized view m2;

statement ok
drop table t1;


statement ok
drop materialized view m7;

statement ok
drop materialized view m8;

statement ok
drop materialized view m6;

statement ok
drop materialized view m10;

statement ok
drop materialized view m9;

statement ok
drop table t2;


statement ok
drop materialized view m12;

statement ok
drop materialized view m11;

statement ok
drop table t3;


statement ok
drop materialized view m14;

statement ok
drop materialized view m15;

statement ok
drop materialized view m13;

statement ok
drop table t4;
Loading