Commit86d609a

committed

_partition_data_concurrent() should not be STRICT, fix ARGISNULL 'else if' checks in invoke_on_partition_created_callback()

1 parent1385218 commit86d609aCopy full SHA for 86d609a

File tree

-3

lines changed

-3

lines changed

Lines changed: 7 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -198,6 +198,7 @@ DECLARE`
`198`	`198`	`v_limit_clauseTEXT :='';`
`199`	`199`	`v_where_clauseTEXT :='';`
`200`	`200`	`ctidsTID[];`
	`201`	`+`
`201`	`202`	`BEGIN`
`202`	`203`	`SELECT attname INTO v_attr`
`203`	`204`	`FROM @extschema@.pathman_configWHERE 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`	`SETpg_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 VOIDAS'pg_pathman','validate_on_part_init_callback_pl'`
`709`	`710`	`LANGUAGE C STRICT;`
`710`	`711`
	`712`	`+`
`711`	`713`	`/*`
`712`		`- *Builds JSONB object containing newpartition parameters and invoke the callback.`
	`714`	`+ *Invoke init_callback on RANGEpartition.`
`713`	`715`	`*/`
`714`	`716`	`CREATEOR REPLACE FUNCTION @extschema@.invoke_on_partition_created_callback(`
`715`	`717`	`parent_relidREGCLASS,`
`@@ -720,6 +722,9 @@ CREATE OR REPLACE FUNCTION @extschema@.invoke_on_partition_created_callback(`
`720`	`722`	`RETURNS VOIDAS'pg_pathman','invoke_on_partition_created_callback'`
`721`	`723`	`LANGUAGE C;`
`722`	`724`
	`725`	`+/*`
	`726`	`+ * Invoke init_callback on HASH partition.`
	`727`	`+*/`
`723`	`728`	`CREATEOR REPLACE FUNCTION @extschema@.invoke_on_partition_created_callback(`
`724`	`729`	`parent_relidREGCLASS,`
`725`	`730`	`partitionREGCLASS,`

Lines changed: 1 addition & 1 deletion

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`	`+elseif (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 */`

Comments

(0)