Add pg_dist_object test

velioglu/prop_dep_view_review
Ahmet Gedemenli 2022-05-24 18:39:10 +03:00
parent 73a600c203
commit 8535064b52
2 changed files with 16 additions and 0 deletions

View File

@ -805,6 +805,13 @@ SELECT run_command_on_workers($$SELECT COUNT(*) FROM pg_views WHERE viewname LIK
(localhost,57638,t,2)
(2 rows)
SELECT pg_identify_object_as_address(classid, objid, objsubid) from pg_catalog.pg_dist_object where objid IN('viewsc.prop_view'::regclass::oid, 'viewsc.prop_view2'::regclass::oid);
pg_identify_object_as_address
---------------------------------------------------------------------
(view,"{viewsc,prop_view2}",{})
(view,"{viewsc,prop_view}",{})
(2 rows)
-- drop views
DROP VIEW viewsc.prop_view;
DROP VIEW viewsc.prop_view2;
@ -850,6 +857,13 @@ SELECT run_command_on_workers($$SELECT COUNT(*) FROM pg_views WHERE viewname LIK
(localhost,57638,t,2)
(2 rows)
SELECT pg_identify_object_as_address(classid, objid, objsubid) from pg_catalog.pg_dist_object where objid IN('viewsc.prop_view3'::regclass::oid, 'viewsc.prop_view4'::regclass::oid);
pg_identify_object_as_address
---------------------------------------------------------------------
(view,"{viewsc,prop_view3}",{})
(view,"{viewsc,prop_view4}",{})
(2 rows)
-- cleanup at exit
set client_min_messages to error;
DROP SCHEMA citus_local_tables_mx CASCADE;

View File

@ -422,6 +422,7 @@ SELECT citus_add_local_table_to_metadata('view_tbl_1');
SELECT viewname, definition FROM pg_views WHERE viewname LIKE 'prop_view%' ORDER BY viewname;
SELECT run_command_on_workers($$SELECT COUNT(*) FROM pg_views WHERE viewname LIKE 'prop_view%';$$);
SELECT pg_identify_object_as_address(classid, objid, objsubid) from pg_catalog.pg_dist_object where objid IN('viewsc.prop_view'::regclass::oid, 'viewsc.prop_view2'::regclass::oid);
-- drop views
DROP VIEW viewsc.prop_view;
DROP VIEW viewsc.prop_view2;
@ -440,6 +441,7 @@ SELECT run_command_on_workers($$SELECT COUNT(*) FROM pg_views WHERE viewname LIK
SELECT citus_add_local_table_to_metadata('view_tbl_2');
-- verify both views are distributed
SELECT run_command_on_workers($$SELECT COUNT(*) FROM pg_views WHERE viewname LIKE 'prop_view%';$$);
SELECT pg_identify_object_as_address(classid, objid, objsubid) from pg_catalog.pg_dist_object where objid IN('viewsc.prop_view3'::regclass::oid, 'viewsc.prop_view4'::regclass::oid);
-- cleanup at exit
set client_min_messages to error;