Commit97c31cd

committed

introduce drop_range_triggers() function

1 parent421b2ed commit97c31cdCopy full SHA for 97c31cd

File tree

+23

-46

lines changed

+23

-46

lines changed

Lines changed: 1 addition & 22 deletions

Original file line number	Diff line number	Diff line change
`@@ -83,7 +83,7 @@ BEGIN`
`83`	`83`	`v_relname := @extschema@.validate_relname(relation);`
`84`	`84`
`85`	`85`	`/* Drop trigger first*/`
`86`		`-PERFORM @extschema@.drop_hash_triggers(relation);`
	`86`	`+PERFORM @extschema@.drop_triggers(relation);`
`87`	`87`	`DELETEFROM @extschema@.pathman_configWHERE relname::regclass= relation;`
`88`	`88`
`89`	`89`	`FOR v_recin (SELECT inhrelid::regclass::textAS tbl`
`@@ -108,27 +108,6 @@ BEGIN`
`108`	`108`	`END`
`109`	`109`	`$$ LANGUAGE plpgsql;`
`110`	`110`
`111`		`-/*`
`112`		`- * Drops hash trigger`
`113`		`-*/`
`114`		`-CREATEOR REPLACE FUNCTION @extschema@.drop_hash_triggers(IN relation REGCLASS)`
`115`		`-RETURNS VOIDAS`
`116`		`-$$`
`117`		`-DECLARE`
`118`		`-relnameTEXT;`
`119`		`-schemaTEXT;`
`120`		`-funcnameTEXT;`
`121`		`-BEGIN`
`122`		`-SELECT* INTO schema, relname`
`123`		`-FROM @extschema@.get_plain_schema_and_relname(relation);`
`124`		`-`
`125`		`-funcname := schema\|\|'.'\|\| quote_ident(format('%s_insert_trigger_func', relname));`
`126`		`-EXECUTE format('DROP FUNCTION IF EXISTS %s() CASCADE', funcname);`
`127`		`-funcname := schema\|\|'.'\|\| quote_ident(format('%s_update_trigger_func', relname));`
`128`		`-EXECUTE format('DROP FUNCTION IF EXISTS %s() CASCADE', funcname);`
`129`		`-END`
`130`		`-$$ LANGUAGE plpgsql;`
`131`		`-`
`132`	`111`	`/*`
`133`	`112`	`* Creates an update trigger`
`134`	`113`	`*/`

Lines changed: 21 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -127,9 +127,9 @@ BEGIN`
`127`	`127`
`128`	`128`	`DELETEFROM @extschema@.pathman_configWHERE relname= relation;`
`129`	`129`	`IF parttype=1 THEN`
`130`		`-PERFORM @extschema@.drop_hash_triggers(relation);`
	`130`	`+PERFORM @extschema@.drop_triggers(relation);`
`131`	`131`	`ELSIF parttype=2 THEN`
`132`		`-PERFORM @extschema@.drop_range_triggers(relation);`
	`132`	`+PERFORM @extschema@.drop_triggers(relation);`
`133`	`133`	`END IF;`
`134`	`134`
`135`	`135`	`/* Notify backend about changes*/`
`@@ -340,3 +340,22 @@ RETURNS VOID AS 'pg_pathman', 'acquire_partitions_lock' LANGUAGE C STRICT;`
`340`	`340`	`*/`
`341`	`341`	`CREATEOR REPLACE FUNCTION @extschema@.release_partitions_lock()`
`342`	`342`	`RETURNS VOIDAS'pg_pathman','release_partitions_lock' LANGUAGE C STRICT;`
	`343`	`+`
	`344`	`+/*`
	`345`	`+ * Drop trigger`
	`346`	`+*/`
	`347`	`+CREATEOR REPLACE FUNCTION @extschema@.drop_triggers(IN relation REGCLASS)`
	`348`	`+RETURNS VOIDAS`
	`349`	`+$$`
	`350`	`+DECLARE`
	`351`	`+relnameTEXT;`
	`352`	`+schemaTEXT;`
	`353`	`+funcnameTEXT;`
	`354`	`+BEGIN`
	`355`	`+SELECT* INTO schema, relname`
	`356`	`+FROM @extschema@.get_plain_schema_and_relname(relation);`
	`357`	`+`
	`358`	`+funcname := schema\|\|'.'\|\| quote_ident(format('%s_update_trigger_func', relname));`
	`359`	`+EXECUTE format('DROP FUNCTION IF EXISTS %s() CASCADE', funcname);`
	`360`	`+END`
	`361`	`+$$ LANGUAGE plpgsql;`

Lines changed: 1 addition & 22 deletions

Original file line number	Diff line number	Diff line change
`@@ -1094,7 +1094,7 @@ BEGIN`
`1094`	`1094`	`v_relname := @extschema@.validate_relname(relation);`
`1095`	`1095`
`1096`	`1096`	`/* Drop trigger first*/`
`1097`		`-PERFORM @extschema@.drop_range_triggers(relation);`
	`1097`	`+PERFORM @extschema@.drop_triggers(relation);`
`1098`	`1098`
`1099`	`1099`	`FOR v_recIN (SELECT inhrelid::regclass::textAS tbl`
`1100`	`1100`	`FROM pg_inheritsWHERE inhparent::regclass= relation)`
`@@ -1120,27 +1120,6 @@ BEGIN`
`1120`	`1120`	`END`
`1121`	`1121`	`$$ LANGUAGE plpgsql;`
`1122`	`1122`
`1123`		`-`
`1124`		`-/*`
`1125`		`- * Drop trigger`
`1126`		`-*/`
`1127`		`-CREATEOR REPLACE FUNCTION @extschema@.drop_range_triggers(IN relation REGCLASS)`
`1128`		`-RETURNS VOIDAS`
`1129`		`-$$`
`1130`		`-DECLARE`
`1131`		`-schemaTEXT;`
`1132`		`-relnameTEXT;`
`1133`		`-BEGIN`
`1134`		`-SELECT* INTO schema, relname`
`1135`		`-FROM @extschema@.get_plain_schema_and_relname(relation);`
`1136`		`-`
`1137`		`---EXECUTE format('DROP TRIGGER IF EXISTS %s ON %s CASCADE'`
`1138`		`--- , format('"%s_%s_insert_trigger"', schema, relname)`
`1139`		`--- , relation::TEXT);`
`1140`		`-END`
`1141`		`-$$ LANGUAGE plpgsql;`
`1142`		`-`
`1143`		`-`
`1144`	`1123`	`/*`
`1145`	`1124`	`* Internal function used to create new partitions on insert or update trigger.`
`1146`	`1125`	`* Invoked from C-function find_or_create_range_partition().`

Comments

(0)