NotificationsYou must be signed in to change notification settings
Fork5
Star27

Commitc758c4b

committed

pathman: plpgsql functions return values

1 parentaf522cd commitc758c4bCopy full SHA for c758c4b

File tree

3 files changed

+17

-11

lines changed

contrib/pg_pathman
- expected
  - pg_pathman.out
- sql
  - init.sql
  - range.sql

3 files changed

+17

-11

lines changed

`‎contrib/pg_pathman/expected/pg_pathman.out‎`

Lines changed: 6 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,7 @@ NOTICE: Copying data to test.range_rel_2 (condition: ((dt >= 'Sun Feb 01 00:00:`
`34`	`34`	`NOTICE: Copying data to test.range_rel_1 (condition: ((dt >= 'Thu Jan 01 00:00:00 2015'::timestamp without time zone) AND (dt < 'Sun Feb 01 00:00:00 2015'::timestamp without time zone)))`
`35`	`35`	`partition_data`
`36`	`36`	`----------------`
`37`		`- 0`
	`37`	`+120`
`38`	`38`	`(1 row)`
`39`	`39`
`40`	`40`	`CREATE TABLE test.num_range_rel (`
`@@ -81,9 +81,9 @@ SELECT * FROM test.hash_rel WHERE value = 7;`
`81`	`81`	`(1 row)`
`82`	`82`
`83`	`83`	`SELECT pathman.create_range_update_trigger('test.num_range_rel');`
`84`		`- create_range_update_trigger`
`85`		`------------------------------`
`86`		`-`
	`84`	`+create_range_update_trigger`
	`85`	`+------------------------------------------`
	`86`	`+test.num_range_rel_update_trigger_func()`
`87`	`87`	`(1 row)`
`88`	`88`
`89`	`89`	`UPDATE test.num_range_rel SET id = 3001 WHERE id = 1;`
`@@ -518,7 +518,7 @@ NOTICE: Copying data to hash_rel_1 (condition: ((value % 3) = 1))`
`518`	`518`	`NOTICE: Copying data to hash_rel_2 (condition: ((value % 3) = 2))`
`519`	`519`	`partition_data`
`520`	`520`	`----------------`
`521`		`- 0`
	`521`	`+10000`
`522`	`522`	`(1 row)`
`523`	`523`
`524`	`524`	`EXPLAIN (COSTS OFF) SELECT * FROM hash_rel WHERE id = 1234;`
`@@ -562,7 +562,7 @@ NOTICE: Copying data to range_rel_11 (condition: ((dt >= 'Mon Nov 01 00:00:00 2`
`562`	`562`	`NOTICE: Copying data to range_rel_12 (condition: ((dt >= 'Wed Dec 01 00:00:00 2010'::timestamp without time zone) AND (dt < 'Sat Jan 01 00:00:00 2011'::timestamp without time zone)))`
`563`	`563`	`partition_data`
`564`	`564`	`----------------`
`565`		`- 0`
	`565`	`+365`
`566`	`566`	`(1 row)`
`567`	`567`
`568`	`568`	`SELECT merge_range_partitions('range_rel_1', 'range_rel_2');`

`‎contrib/pg_pathman/sql/init.sql‎`

Lines changed: 7 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -41,13 +41,16 @@ RETURNS ANYARRAY AS 'pg_pathman', 'get_range_by_idx' LANGUAGE C STRICT;`
`41`	`41`	`/*`
`42`	`42`	`* Copy rows to partitions`
`43`	`43`	`*/`
`44`		`-CREATEOR REPLACE FUNCTION @extschema@.partition_data(p_parenttext)`
`45`		`-RETURNSbigintAS`
	`44`	`+CREATEOR REPLACE FUNCTION @extschema@.partition_data(p_parenttext, OUT p_totalBIGINT)`
	`45`	`+AS`
`46`	`46`	`$$`
`47`	`47`	`DECLARE`
`48`	`48`	`rec RECORD;`
	`49`	`+ cntBIGINT :=0;`
`49`	`50`	`BEGIN`
`50`	`51`	`p_parent := @extschema@.validate_relname(p_parent);`
	`52`	`+`
	`53`	`+ p_total :=0;`
`51`	`54`	`FOR recIN (SELECT inhrelidas child_id,pg_constraint.consrc`
`52`	`55`	`FROM @extschema@.pathman_configas cfg`
`53`	`56`	`JOIN pg_classAS parentONparent.relfilenode=cfg.relname::regclass::oid`
`@@ -62,8 +65,9 @@ BEGIN`
`62`	`65`	`, p_parent`
`63`	`66`	`,rec.consrc`
`64`	`67`	`,rec.child_id::regclass::text);`
	`68`	`+ GET DIAGNOSTICS cnt= ROW_COUNT;`
	`69`	`+ p_total := p_total+ cnt;`
`65`	`70`	`END LOOP;`
`66`		`- RETURN0;`
`67`	`71`	`END`
`68`	`72`	`$$`
`69`	`73`	`LANGUAGE plpgsql;`

`‎contrib/pg_pathman/sql/range.sql‎`

Lines changed: 4 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -262,7 +262,6 @@ BEGIN`
`262`	`262`	`END`
`263`	`263`	`$$ LANGUAGE plpgsql;`
`264`	`264`
`265`		`-`
`266`	`265`	`/*`
`267`	`266`	`* Split RANGE partition`
`268`	`267`	`*/`
`@@ -596,7 +595,7 @@ $$ LANGUAGE plpgsql;`
`596`	`595`	`*/`
`597`	`596`	`CREATEOR REPLACE FUNCTION @extschema@.create_range_update_trigger(`
`598`	`597`	`IN relationTEXT)`
`599`		`-RETURNSVOIDAS`
	`598`	`+RETURNSTEXTAS`
`600`	`599`	`$$`
`601`	`600`	`DECLARE`
`602`	`601`	`funcTEXT :='`
`@@ -630,6 +629,7 @@ DECLARE`
`630`	`629`	`numINTEGER :=0;`
`631`	`630`	`attrTEXT;`
`632`	`631`	`BEGIN`
	`632`	`+ relation := @extschema@.validate_relname(relation);`
`633`	`633`	`relid := relation::regclass::oid;`
`634`	`634`	`SELECT string_agg(attname,','),`
`635`	`635`	`string_agg('OLD.'\|\| attname,','),`
`@@ -656,6 +656,8 @@ BEGIN`
`656`	`656`	`, relation);`
`657`	`657`	`num := num+1;`
`658`	`658`	`END LOOP;`
	`659`	`+`
	`660`	`+ RETURN format('%s_update_trigger_func()', relation);`
`659`	`661`	`END`
`660`	`662`	`$$ LANGUAGE plpgsql;`
`661`	`663`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commitc758c4b

File tree

3 files changed

3 files changed

`‎contrib/pg_pathman/expected/pg_pathman.out‎`

`‎contrib/pg_pathman/sql/init.sql‎`

`‎contrib/pg_pathman/sql/range.sql‎`

0 commit comments