Skip to content

Commit 4f6148c

Browse files
authored
FDN-2403: Remove functions referencing legacy pg_partman (#30)
1 parent 6a9c429 commit 4f6148c

1 file changed

Lines changed: 28 additions & 0 deletions

File tree

scripts/20240619-121444.sql

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,28 @@
1+
-- Make refresh_journaling delegate to refresh_journaling_native. We
2+
-- need to keep both for the moment because of references from Scala
3+
-- code, e.g., in lib-event-relation-mapper's TableSchemaManager.
4+
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)
5+
RETURNS character varying
6+
LANGUAGE plpgsql
7+
AS $function$
8+
BEGIN
9+
RETURN journal.refresh_journaling_native(p_source_schema_name, p_source_table_name, p_target_schema_name, p_target_table_name);
10+
END;
11+
$function$;
12+
13+
DROP FUNCTION IF EXISTS audit.setup;
14+
DROP FUNCTION IF EXISTS queue.create_queue;
15+
DROP FUNCTION IF EXISTS kinesis.create_kinesis_tables;
16+
DROP FUNCTION IF EXISTS kinesis.partition_n_days;
17+
18+
-- Remove all _trig_func functions that were invoked by partitioning triggers.
19+
DO LANGUAGE plpgsql $$
20+
DECLARE r record;
21+
BEGIN
22+
FOR r IN SELECT routine_schema, routine_name from information_schema.routines where routine_name like '%_part_trig_func'
23+
LOOP
24+
EXECUTE 'DROP FUNCTION ' || quote_ident(r.routine_schema) || '.' || quote_ident(r.routine_name);
25+
END LOOP;
26+
END;
27+
$$;
28+

0 commit comments

Comments
 (0)