Skip to content

Commit

Permalink
sql test
Browse files Browse the repository at this point in the history
  • Loading branch information
murphyatwork committed Dec 27, 2024
1 parent b309d0c commit fe7cd4e
Show file tree
Hide file tree
Showing 2 changed files with 74 additions and 2 deletions.
41 changes: 40 additions & 1 deletion test/sql/test_materialized_view/R/test_show_materialized_view
Original file line number Diff line number Diff line change
Expand Up @@ -80,6 +80,45 @@ AS SELECT `user_tags`.`user_id`, bitmap_union(to_bitmap(`user_tags`.`tag_id`)) A
FROM `test_show_materialized_view`.`user_tags`
GROUP BY `user_tags`.`user_id`;
-- !result
drop database test_show_materialized_view;
refresh materialized view user_tags_mv1 with sync mode;
select
TABLE_NAME,
LAST_REFRESH_STATE,
LAST_REFRESH_ERROR_CODE,
IS_ACTIVE,
INACTIVE_REASON
from information_schema.materialized_views where table_name = 'user_tags_mv1';
-- result:
user_tags_mv1 SUCCESS 0 true
-- !result
set @last_refresh_time = (
select max(last_refresh_start_time)
from information_schema.materialized_views where table_name = 'user_tags_mv1'
);
-- result:
-- !result
refresh materialized view user_tags_mv1 force with sync mode;
select
TABLE_NAME,
LAST_REFRESH_STATE,
LAST_REFRESH_ERROR_CODE,
IS_ACTIVE,
INACTIVE_REASON
from information_schema.materialized_views where table_name = 'user_tags_mv1';
-- result:
user_tags_mv1 SUCCESS 0 true
-- !result
set @this_refresh_time = (
select max(last_refresh_start_time)
from information_schema.materialized_views where table_name = 'user_tags_mv1'
);
-- result:
-- !result
select if(@last_refresh_time != @this_refresh_time,
'refreshed', concat('no refresh after ', @last_refresh_time));
-- result:
refreshed
-- !result
drop database test_show_materialized_view;
-- result:
-- !result
35 changes: 34 additions & 1 deletion test/sql/test_materialized_view/T/test_show_materialized_view
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,43 @@ use test_show_materialized_view;
create table user_tags (time date, user_id int, user_name varchar(20), tag_id int) partition by range (time) (partition p1 values less than MAXVALUE) distributed by hash(time) buckets 3 properties('replication_num' = '1');
create materialized view user_tags_mv1 distributed by hash(user_id) as select user_id, bitmap_union(to_bitmap(tag_id)) from user_tags group by user_id;


show create materialized view user_tags_mv1;
show create table user_tags_mv1;
alter materialized view user_tags_mv1 set ("session.insert_timeout" = "3600");
alter materialized view user_tags_mv1 set ("mv_rewrite_staleness_second" = "3600");
show create materialized view user_tags_mv1;
show create table user_tags_mv1;
drop database test_show_materialized_view;

-- information_schema.materialized_views
refresh materialized view user_tags_mv1 with sync mode;
select
TABLE_NAME,
LAST_REFRESH_STATE,
LAST_REFRESH_ERROR_CODE,
IS_ACTIVE,
INACTIVE_REASON
from information_schema.materialized_views where table_name = 'user_tags_mv1';
set @last_refresh_time = (
select max(last_refresh_start_time)
from information_schema.materialized_views where table_name = 'user_tags_mv1'
);

-- multiple refresh tasks
refresh materialized view user_tags_mv1 force with sync mode;
select
TABLE_NAME,
LAST_REFRESH_STATE,
LAST_REFRESH_ERROR_CODE,
IS_ACTIVE,
INACTIVE_REASON
from information_schema.materialized_views where table_name = 'user_tags_mv1';
set @this_refresh_time = (
select max(last_refresh_start_time)
from information_schema.materialized_views where table_name = 'user_tags_mv1'
);
select if(@last_refresh_time != @this_refresh_time,
'refreshed', concat('no refresh after ', @last_refresh_time));


drop database test_show_materialized_view;

0 comments on commit fe7cd4e

Please sign in to comment.