NotificationsYou must be signed in to change notification settings
Fork5
Star27

Commit2ca82a8

committed

pathman: pl functions fixes

1 parent7915152 commit2ca82a8Copy full SHA for 2ca82a8

File tree

3 files changed

+42

-4

lines changed

contrib/pathman
- init.c
- pathman.c
- sql
  - range.sql

3 files changed

+42

-4

lines changed

`‎contrib/pathman/init.c‎`

Lines changed: 3 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -97,7 +97,7 @@ create_part_relations_hashtable()`
`97`	`97`	`hash_destroy(relations);`
`98`	`98`
`99`	`99`	`relations=ShmemInitHash("Partitioning relation info",`
`100`		`-128,128,`
	`100`	`+16,16,`
`101`	`101`	`&ctl,HASH_ELEM \|HASH_BLOBS);`
`102`	`102`	`}`
`103`	`103`
`@@ -175,7 +175,7 @@ create_hash_restrictions_hashtable()`
`175`	`175`	`hash_destroy(hash_restrictions);`
`176`	`176`
`177`	`177`	`hash_restrictions=ShmemInitHash("pg_pathman hash restrictions",`
`178`		`-1024,1024,`
	`178`	`+128,128,`
`179`	`179`	`&ctl,HASH_ELEM \|HASH_BLOBS);`
`180`	`180`	`}`
`181`	`181`
`@@ -312,8 +312,7 @@ create_range_restrictions_hashtable()`
`312`	`312`	`memset(&ctl,0,sizeof(ctl));`
`313`	`313`	`ctl.keysize=sizeof(int);`
`314`	`314`	`ctl.entrysize=sizeof(RangeRelation);`
`315`		`-`
`316`	`315`	`range_restrictions=ShmemInitHash("pg_pathman range restrictions",`
`317`		`-16,16,`
	`316`	`+512,512,`
`318`	`317`	`&ctl,HASH_ELEM \|HASH_BLOBS);`
`319`	`318`	`}`

`‎contrib/pathman/pathman.c‎`

Lines changed: 3 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -827,6 +827,9 @@ on_partitions_removed(PG_FUNCTION_ARGS) {`
`827`	`827`	`prel= (PartRelationInfo*)`
`828`	`828`	`hash_search(relations, (constvoid*)&relid,HASH_FIND,0);`
`829`	`829`
	`830`	`+if (!prel)`
	`831`	`+PG_RETURN_NULL();`
	`832`	`+`
`830`	`833`	`/* remove children relations */`
`831`	`834`	`switch (prel->parttype)`
`832`	`835`	`{`

`‎contrib/pathman/sql/range.sql‎`

Lines changed: 36 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -159,7 +159,14 @@ RETURNS VOID AS`
`159`	`159`	`$$`
`160`	`160`	`DECLARE`
`161`	`161`	`v_child_relnameTEXT;`
	`162`	`+ v_checkTEXT;`
	`163`	`+ v_min_valueTEXT;`
	`164`	`+ v_max_valueTEXT;`
	`165`	`+ v_attnameTEXT;`
`162`	`166`	`BEGIN`
	`167`	`+ v_attname := attnameFROM pg_pathman_rels`
	`168`	`+WHERE relname= v_parent_relname;`
	`169`	`+`
`163`	`170`	`IF v_type='time' THEN`
`164`	`171`	`v_child_relname := format('%s_%s'`
`165`	`172`	`, v_parent_relname`
`@@ -190,13 +197,24 @@ BEGIN`
`190`	`197`	`, v_start_value::TIMESTAMP`
`191`	`198`	`, v_start_value::TIMESTAMP+ v_interval::INTERVAL`
`192`	`199`	`, v_child_relname);`
	`200`	`+ v_min_value := to_char(v_start_value::TIMESTAMP,'YYYY-MM-DD HH:MI:SS');`
	`201`	`+ v_max_value := to_char(v_start_value::TIMESTAMP+ v_interval::INTERVAL,'YYYY-MM-DD HH:MI:SS');`
`193`	`202`	`ELSIF v_type='num' THEN`
`194`	`203`	`INSERT INTO pg_pathman_range_rels (parent, min_num, max_num, child)`
`195`	`204`	`VALUES (v_parent_relname`
`196`	`205`	`, v_start_value::DOUBLE PRECISION`
`197`	`206`	`, v_start_value::DOUBLE PRECISION+ v_interval::DOUBLE PRECISION`
`198`	`207`	`, v_child_relname);`
	`208`	`+ v_min_value := v_start_value::DOUBLE PRECISION;`
	`209`	`+ v_max_value := v_start_value::DOUBLE PRECISION+ v_interval::DOUBLE PRECISION;`
`199`	`210`	`END IF;`
	`211`	`+`
	`212`	`+ EXECUTE format('ALTER TABLE %s ADD CHECK (%s >=''%s'' AND %s <''%s'')'`
	`213`	`+ , v_child_relname`
	`214`	`+ , v_attname`
	`215`	`+ , v_min_value`
	`216`	`+ , v_attname`
	`217`	`+ , v_max_value);`
`200`	`218`	`END`
`201`	`219`	`$$ LANGUAGE plpgsql;`
`202`	`220`
`@@ -298,6 +316,24 @@ BEGIN`
`298`	`316`	`END`
`299`	`317`	`$$ LANGUAGE plpgsql;`
`300`	`318`
	`319`	`+/*`
	`320`	`+ *`
	`321`	`+*/`
	`322`	`+CREATE OR REPLACEFUNCTIONdisable_range_partitions(IN relationTEXT)`
	`323`	`+RETURNS VOIDAS`
	`324`	`+$$`
	`325`	`+DECLARE`
	`326`	`+ v_relidINTEGER;`
	`327`	`+ v_rec RECORD;`
	`328`	`+BEGIN`
	`329`	`+DELETEFROM pg_pathman_relsWHERE relname= relation;`
	`330`	`+DELETEFROM pg_pathman_range_relsWHERE parent= relation;`
	`331`	`+`
	`332`	`+/* Notify backend about changes*/`
	`333`	`+ PERFORM pg_pathman_on_remove_partitions(v_relid);`
	`334`	`+END`
	`335`	`+$$ LANGUAGE plpgsql;`
	`336`	`+`
`301`	`337`	`/*`
`302`	`338`	`* Drop trigger`
`303`	`339`	`*/`

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!

Commit2ca82a8

File tree

3 files changed

3 files changed

`‎contrib/pathman/init.c‎`

`‎contrib/pathman/pathman.c‎`

`‎contrib/pathman/sql/range.sql‎`

0 commit comments