From 59b0daa0fb7b24077ff5d7df02ad36ac3cfd3fcc Mon Sep 17 00:00:00 2001 From: Nicola Girardi Date: Wed, 19 Jun 2024 13:14:44 +0100 Subject: [PATCH] FDN-2403: Remove functions referencing legacy pg_partman --- scripts/20240619-121444.sql | 28 ++++++++++++++++++++++++++++ 1 file changed, 28 insertions(+) create mode 100644 scripts/20240619-121444.sql diff --git a/scripts/20240619-121444.sql b/scripts/20240619-121444.sql new file mode 100644 index 0000000..cfb6fdb --- /dev/null +++ b/scripts/20240619-121444.sql @@ -0,0 +1,28 @@ +-- Make refresh_journaling delegate to refresh_journaling_native. We +-- need to keep both for the moment because of references from Scala +-- code, e.g., in lib-event-relation-mapper's TableSchemaManager. +CREATE OR REPLACE FUNCTION journal.refresh_journaling(p_source_schema_name character varying, p_source_table_name character varying, p_target_schema_name character varying, p_target_table_name character varying) + RETURNS character varying + LANGUAGE plpgsql +AS $function$ +BEGIN + RETURN journal.refresh_journaling_native(p_source_schema_name, p_source_table_name, p_target_schema_name, p_target_table_name); +END; +$function$; + +DROP FUNCTION IF EXISTS audit.setup; +DROP FUNCTION IF EXISTS queue.create_queue; +DROP FUNCTION IF EXISTS kinesis.create_kinesis_tables; +DROP FUNCTION IF EXISTS kinesis.partition_n_days; + +-- Remove all _trig_func functions that were invoked by partitioning triggers. +DO LANGUAGE plpgsql $$ +DECLARE r record; +BEGIN + FOR r IN SELECT routine_schema, routine_name from information_schema.routines where routine_name like '%_part_trig_func' + LOOP + EXECUTE 'DROP FUNCTION ' || quote_ident(r.routine_schema) || '.' || quote_ident(r.routine_name); + END LOOP; +END; +$$; +