File tree Expand file tree Collapse file tree 2 files changed +8
-3
lines changed Expand file tree Collapse file tree 2 files changed +8
-3
lines changed Original file line number Diff line number Diff line change @@ -198,6 +198,7 @@ DECLARE
198
198
v_limit_clause TEXT := ' ' ;
199
199
v_where_clause TEXT := ' ' ;
200
200
ctids TID[];
201
+
201
202
BEGIN
202
203
SELECT attname INTO v_attr
203
204
FROM @extschema@.pathman_config WHERE partrel = p_relation;
@@ -244,7 +245,7 @@ BEGIN
244
245
RETURN;
245
246
END
246
247
$$
247
- LANGUAGE plpgsql STRICT
248
+ LANGUAGE plpgsql
248
249
SET pg_pathman .enable_partitionfilter = on ; /* ensures that PartitionFilter is ON */
249
250
250
251
/*
@@ -708,8 +709,9 @@ CREATE OR REPLACE FUNCTION @extschema@.validate_on_partition_created_callback(ca
708
709
RETURNS VOID AS ' pg_pathman' , ' validate_on_part_init_callback_pl'
709
710
LANGUAGE C STRICT;
710
711
712
+
711
713
/*
712
- * Builds JSONB object containing new partition parameters and invoke the callback .
714
+ * Invoke init_callback on RANGE partition.
713
715
*/
714
716
CREATE OR REPLACE FUNCTION @extschema@.invoke_on_partition_created_callback(
715
717
parent_relid REGCLASS,
@@ -720,6 +722,9 @@ CREATE OR REPLACE FUNCTION @extschema@.invoke_on_partition_created_callback(
720
722
RETURNS VOID AS ' pg_pathman' , ' invoke_on_partition_created_callback'
721
723
LANGUAGE C;
722
724
725
+ /*
726
+ * Invoke init_callback on HASH partition.
727
+ */
723
728
CREATE OR REPLACE FUNCTION @extschema@.invoke_on_partition_created_callback(
724
729
parent_relid REGCLASS,
725
730
partition REGCLASS,
Original file line number Diff line number Diff line change @@ -844,7 +844,7 @@ invoke_on_partition_created_callback(PG_FUNCTION_ARGS)
844
844
part_type = PT_HASH ;
845
845
846
846
/* Either RANGE_START or RANGE_END is missing */
847
- if (PG_ARGISNULL (ARG_RANGE_START ) || PG_ARGISNULL (ARG_RANGE_START ))
847
+ else if (PG_ARGISNULL (ARG_RANGE_START ) || PG_ARGISNULL (ARG_RANGE_START ))
848
848
elog (ERROR , "both boundaries must be provided for RANGE partition" );
849
849
850
850
/* Both RANGE_START & RANGE_END are provided */
You can’t perform that action at this time.
0 commit comments