From 0a70b78bf59998e3fbcf4db8622fd2f5dd21914c Mon Sep 17 00:00:00 2001 From: Burak Velioglu Date: Fri, 4 Feb 2022 16:29:12 +0300 Subject: [PATCH] Add test for dist type --- .../regress/expected/metadata_sync_helpers.out | 16 ++++++++++++++++ src/test/regress/sql/metadata_sync_helpers.sql | 13 +++++++++++++ 2 files changed, 29 insertions(+) diff --git a/src/test/regress/expected/metadata_sync_helpers.out b/src/test/regress/expected/metadata_sync_helpers.out index 15de77e4d..cb3b113e2 100644 --- a/src/test/regress/expected/metadata_sync_helpers.out +++ b/src/test/regress/expected/metadata_sync_helpers.out @@ -664,6 +664,22 @@ BEGIN TRANSACTION ISOLATION LEVEL READ COMMITTED; SELECT citus_internal_add_object_metadata(typetext, objnames, objargs, distargumentindex, colocationid, force_delegation) FROM distributed_object_data; ERROR: must be owner of function distribution_test_function ROLLBACK; +BEGIN TRANSACTION ISOLATION LEVEL READ COMMITTED; + SELECT assign_distributed_transaction_id(0, 8, '2021-07-09 15:41:55.542377+02'); + assign_distributed_transaction_id +--------------------------------------------------------------------- + +(1 row) + + SET application_name to 'citus_internal'; + \set VERBOSITY terse + CREATE TYPE distributed_test_type AS (a int, b int); + SET ROLE metadata_sync_helper_role; + WITH distributed_object_data(typetext, objnames, objargs, distargumentindex, colocationid, force_delegation) + AS (VALUES ('type', ARRAY['distributed_test_type']::text[], ARRAY[]::text[], -1, 0, false)) + SELECT citus_internal_add_object_metadata(typetext, objnames, objargs, distargumentindex, colocationid, force_delegation) FROM distributed_object_data; +ERROR: must be owner of type distributed_test_type +ROLLBACK; -- we do not allow wrong partmethod -- so manually insert wrong partmethod for the sake of the test SET search_path TO metadata_sync_helpers; diff --git a/src/test/regress/sql/metadata_sync_helpers.sql b/src/test/regress/sql/metadata_sync_helpers.sql index 7054c5414..22e337443 100644 --- a/src/test/regress/sql/metadata_sync_helpers.sql +++ b/src/test/regress/sql/metadata_sync_helpers.sql @@ -425,6 +425,19 @@ BEGIN TRANSACTION ISOLATION LEVEL READ COMMITTED; SELECT citus_internal_add_object_metadata(typetext, objnames, objargs, distargumentindex, colocationid, force_delegation) FROM distributed_object_data; ROLLBACK; +BEGIN TRANSACTION ISOLATION LEVEL READ COMMITTED; + SELECT assign_distributed_transaction_id(0, 8, '2021-07-09 15:41:55.542377+02'); + SET application_name to 'citus_internal'; + \set VERBOSITY terse + + CREATE TYPE distributed_test_type AS (a int, b int); + + SET ROLE metadata_sync_helper_role; + WITH distributed_object_data(typetext, objnames, objargs, distargumentindex, colocationid, force_delegation) + AS (VALUES ('type', ARRAY['distributed_test_type']::text[], ARRAY[]::text[], -1, 0, false)) + SELECT citus_internal_add_object_metadata(typetext, objnames, objargs, distargumentindex, colocationid, force_delegation) FROM distributed_object_data; +ROLLBACK; + -- we do not allow wrong partmethod -- so manually insert wrong partmethod for the sake of the test SET search_path TO metadata_sync_helpers;