From 1490acbbe9d7bc560c0bb8eac719d57e64d4280f Mon Sep 17 00:00:00 2001 From: Halil Ozan Akgul Date: Fri, 1 Jul 2022 10:28:31 +0300 Subject: [PATCH] Removes incorrect parameter from get_all_active_transactions --- .../distributed/sql/citus--11.0-3--11.1-1.sql | 5 +++++ .../sql/downgrades/citus--11.1-1--11.0-3.sql | 5 +++++ .../sql/udfs/get_all_active_transactions/11.1-1.sql | 12 ++++++++++++ .../sql/udfs/get_all_active_transactions/latest.sql | 2 +- 4 files changed, 23 insertions(+), 1 deletion(-) create mode 100644 src/backend/distributed/sql/udfs/get_all_active_transactions/11.1-1.sql diff --git a/src/backend/distributed/sql/citus--11.0-3--11.1-1.sql b/src/backend/distributed/sql/citus--11.0-3--11.1-1.sql index 0b5f5156d..20273e914 100644 --- a/src/backend/distributed/sql/citus--11.0-3--11.1-1.sql +++ b/src/backend/distributed/sql/citus--11.0-3--11.1-1.sql @@ -8,3 +8,8 @@ DROP FUNCTION pg_catalog.worker_range_partition_table(bigint, integer, text, tex DROP FUNCTION pg_catalog.worker_repartition_cleanup(bigint); #include "../../columnar/sql/columnar--11.0-3--11.1-1.sql" + +DROP FUNCTION pg_catalog.get_all_active_transactions(OUT datid oid, OUT process_id int, OUT initiator_node_identifier int4, + OUT worker_query BOOL, OUT transaction_number int8, OUT transaction_stamp timestamptz, + OUT global_pid int8); +#include "udfs/get_all_active_transactions/11.1-1.sql" diff --git a/src/backend/distributed/sql/downgrades/citus--11.1-1--11.0-3.sql b/src/backend/distributed/sql/downgrades/citus--11.1-1--11.0-3.sql index 98dbefc75..e832d9730 100644 --- a/src/backend/distributed/sql/downgrades/citus--11.1-1--11.0-3.sql +++ b/src/backend/distributed/sql/downgrades/citus--11.1-1--11.0-3.sql @@ -47,3 +47,8 @@ CREATE FUNCTION pg_catalog.worker_repartition_cleanup(bigint) AS 'MODULE_PATHNAME', $function$worker_repartition_cleanup$function$; #include "../../../columnar/sql/downgrades/columnar--11.1-1--11.0-3.sql" + +DROP FUNCTION pg_catalog.get_all_active_transactions(OUT datid oid, OUT process_id int, OUT initiator_node_identifier int4, + OUT worker_query BOOL, OUT transaction_number int8, OUT transaction_stamp timestamptz, + OUT global_pid int8); +#include "../udfs/get_all_active_transactions/11.0-1.sql" diff --git a/src/backend/distributed/sql/udfs/get_all_active_transactions/11.1-1.sql b/src/backend/distributed/sql/udfs/get_all_active_transactions/11.1-1.sql new file mode 100644 index 000000000..c8517cc0c --- /dev/null +++ b/src/backend/distributed/sql/udfs/get_all_active_transactions/11.1-1.sql @@ -0,0 +1,12 @@ +DROP FUNCTION IF EXISTS pg_catalog.get_all_active_transactions(); +CREATE OR REPLACE FUNCTION pg_catalog.get_all_active_transactions(OUT datid oid, OUT process_id int, OUT initiator_node_identifier int4, + OUT worker_query BOOL, OUT transaction_number int8, OUT transaction_stamp timestamptz, + OUT global_pid int8) +RETURNS SETOF RECORD +LANGUAGE C STRICT AS 'MODULE_PATHNAME', +$$get_all_active_transactions$$; + +COMMENT ON FUNCTION pg_catalog.get_all_active_transactions(OUT datid oid, OUT process_id int, OUT initiator_node_identifier int4, + OUT worker_query BOOL, OUT transaction_number int8, OUT transaction_stamp timestamptz, + OUT global_pid int8) +IS 'returns transaction information for all Citus initiated transactions'; diff --git a/src/backend/distributed/sql/udfs/get_all_active_transactions/latest.sql b/src/backend/distributed/sql/udfs/get_all_active_transactions/latest.sql index 636abb0dd..c8517cc0c 100644 --- a/src/backend/distributed/sql/udfs/get_all_active_transactions/latest.sql +++ b/src/backend/distributed/sql/udfs/get_all_active_transactions/latest.sql @@ -6,7 +6,7 @@ RETURNS SETOF RECORD LANGUAGE C STRICT AS 'MODULE_PATHNAME', $$get_all_active_transactions$$; -COMMENT ON FUNCTION pg_catalog.get_all_active_transactions(OUT datid oid, OUT datname text, OUT process_id int, OUT initiator_node_identifier int4, +COMMENT ON FUNCTION pg_catalog.get_all_active_transactions(OUT datid oid, OUT process_id int, OUT initiator_node_identifier int4, OUT worker_query BOOL, OUT transaction_number int8, OUT transaction_stamp timestamptz, OUT global_pid int8) IS 'returns transaction information for all Citus initiated transactions';