Commit3999694

committed

check if operator + and - are available for given type in append_range_partition() and prepend_range_partition() functions

1 parent73e0b26 commit3999694Copy full SHA for 3999694

File tree

+35

-1

lines changed

+35

-1

lines changed

Lines changed: 10 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -896,3 +896,13 @@ CREATE OR REPLACE FUNCTION @extschema@.invoke_on_partition_created_callback(`
`896`	`896`	`init_callbackREGPROCEDURE)`
`897`	`897`	`RETURNS VOIDAS'pg_pathman','invoke_on_partition_created_callback'`
`898`	`898`	`LANGUAGE C;`
	`899`	`+`
	`900`	`+/*`
	`901`	`+ *`
	`902`	`+*/`
	`903`	`+CREATEOR REPLACE FUNCTION @extschema@.is_operator_supported(`
	`904`	`+type_oidOID,`
	`905`	`+opnameTEXT)`
	`906`	`+RETURNSBOOLEANAS'pg_pathman','is_operator_supported'`
	`907`	`+LANGUAGE C;`
	`908`	`+`

Lines changed: 8 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -573,6 +573,10 @@ BEGIN`
`573`	`573`
`574`	`574`	`v_atttype := @extschema@.get_partition_key_type(parent_relid);`
`575`	`575`
	`576`	`+IF NOT @extschema@.is_operator_supported(v_atttype,'+') THEN`
	`577`	`+RAISE EXCEPTION'Type % doesn''t support''+'' operator', v_atttype::regtype;`
	`578`	`+END IF;`
	`579`	`+`
`576`	`580`	`SELECT range_interval`
`577`	`581`	`FROM @extschema@.pathman_config`
`578`	`582`	`WHERE partrel= parent_relid`
`@@ -678,6 +682,10 @@ BEGIN`
`678`	`682`
`679`	`683`	`v_atttype := @extschema@.get_partition_key_type(parent_relid);`
`680`	`684`
	`685`	`+IF NOT @extschema@.is_operator_supported(v_atttype,'-') THEN`
	`686`	`+RAISE EXCEPTION'Type % doesn''t support''-'' operator', v_atttype::regtype;`
	`687`	`+END IF;`
	`688`	`+`
`681`	`689`	`SELECT range_interval`
`682`	`690`	`FROM @extschema@.pathman_config`
`683`	`691`	`WHERE partrel= parent_relid`

Lines changed: 16 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -69,6 +69,8 @@ PG_FUNCTION_INFO_V1( check_security_policy );`
`69`	`69`	`PG_FUNCTION_INFO_V1(debug_capture );`
`70`	`70`	`PG_FUNCTION_INFO_V1(get_pathman_lib_version );`
`71`	`71`
	`72`	`+PG_FUNCTION_INFO_V1(is_operator_supported );`
	`73`	`+`
`72`	`74`
`73`	`75`	`/*`
`74`	`76`	`* User context for function show_partition_list_internal().`
`@@ -900,6 +902,20 @@ check_security_policy(PG_FUNCTION_ARGS)`
`900`	`902`	`PG_RETURN_BOOL(true);`
`901`	`903`	`}`
`902`	`904`
	`905`	`+Datum`
	`906`	`+is_operator_supported(PG_FUNCTION_ARGS)`
	`907`	`+{`
	`908`	`+Oidtp=PG_GETARG_OID(0);`
	`909`	`+char*opname=TextDatumGetCString(PG_GETARG_TEXT_P(1));`
	`910`	`+Oidopid;`
	`911`	`+`
	`912`	`+opid=compatible_oper_opid(list_make1(makeString(opname)),tp,tp, true);`
	`913`	`+if (!OidIsValid(opid))`
	`914`	`+PG_RETURN_BOOL(false);`
	`915`	`+`
	`916`	`+PG_RETURN_BOOL(true);`
	`917`	`+}`
	`918`	`+`
`903`	`919`
`904`	`920`	`/*`
`905`	`921`	`* -------`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -795,7 +795,7 @@ interval_is_trivial(Oid atttype, Datum interval, Oid interval_type)`
`795`	`795`	`/*`
`796`	`796`	`* If operator result type isn't the same as original value then`
`797`	`797`	`* convert it. We need this to make sure that specified interval would`
`798`		`- * change the_origianal_ value somehow. For example, if we add one second`
	`798`	`+ * change the_original_ value somehow. For example, if we add one second`
`799`	`799`	`* to a date then we'll get a timestamp which is one second later than`
`800`	`800`	`* original date (obviously). But when we convert it back to a date we will`
`801`	`801`	`* get the same original value meaning that one second interval wouldn't`

Comments

(0)