To install pathman run:

To install pathman run in psql:

from its directory.Then modify shared_preload_libraries parameter in postgres.conf as following:

Then modify shared_preload_libraries parameter in postgres.conf as following:

Для установки pathman выполните вдиректории расширения команду:

Для установки pathman выполните вкомандной строке:

Затем модифицируйте параметр shared_preload_libraries в конфигурационном файле postgres.conf:

\set VERBOSITY terse

CREATE SCHEMA pathman;

CREATE EXTENSION pathman SCHEMA pathman;

CREATE SCHEMA test;

CREATE EXTENSION pathman;

CREATE TABLE test.hash_rel (

id SERIAL PRIMARY KEY,

value INTEGER);

SELECT create_hash_partitions('test.hash_rel', 'value', 3);

SELECTpathman.create_hash_partitions('test.hash_rel', 'value', 3);

NOTICE: trigger "test_hash_rel_insert_trigger" for relation "test.hash_rel" does not exist, skipping

NOTICE: function test.hash_rel_hash_insert_trigger_func() does not exist, skipping

create_hash_partitions

id SERIAL PRIMARY KEY,

dt TIMESTAMP,

txt TEXT);

SELECT create_range_partitions('test.range_rel', 'dt', '2015-01-01'::DATE, '1 month'::INTERVAL, 3);

SELECTpathman.create_range_partitions('test.range_rel', 'dt', '2015-01-01'::DATE, '1 month'::INTERVAL, 3);

NOTICE: sequence "range_rel_seq" does not exist, skipping

create_range_partitions

-------------------------

CREATE TABLE test.num_range_rel (

id SERIAL PRIMARY KEY,

txt TEXT);

SELECT create_range_partitions('test.num_range_rel', 'id', 0, 1000, 3);

SELECTpathman.create_range_partitions('test.num_range_rel', 'id', 0, 1000, 3);

NOTICE: sequence "num_range_rel_seq" does not exist, skipping

create_range_partitions

-------------------------

* Test split and merge

*/

/* Split first partition in half */

SELECT split_range_partition('test.num_range_rel_1', 500);

SELECTpathman.split_range_partition('test.num_range_rel_1', 500);

NOTICE: Creating new partition...

NOTICE: Copying data to new partition...

NOTICE: Altering original partition...

Index Cond: (id <= 700)

(5 rows)

SELECT split_range_partition('test.range_rel_1', '2015-01-15'::DATE);

SELECTpathman.split_range_partition('test.range_rel_1', '2015-01-15'::DATE);

NOTICE: Creating new partition...

NOTICE: Copying data to new partition...

NOTICE: Altering original partition...

(1 row)

/* Merge two partitions into one */

SELECT merge_range_partitions('test.num_range_rel_1', 'test.num_range_rel_' || currval('test.num_range_rel_seq'));

SELECTpathman.merge_range_partitions('test.num_range_rel_1', 'test.num_range_rel_' || currval('test.num_range_rel_seq'));

NOTICE: Altering first partition...

NOTICE: Copying data...

NOTICE: Dropping second partition...

Index Cond: ((id >= 100) AND (id <= 700))

(3 rows)

SELECT merge_range_partitions('test.range_rel_1', 'test.range_rel_' || currval('test.range_rel_seq'));

SELECTpathman.merge_range_partitions('test.range_rel_1', 'test.range_rel_' || currval('test.range_rel_seq'));

NOTICE: Altering first partition...

NOTICE: Copying data...

NOTICE: Dropping second partition...

(1 row)

/* Append and prepend partitions */

SELECT append_partition('test.num_range_rel');

SELECTpathman.append_partition('test.num_range_rel');

NOTICE: Appending new partition...

NOTICE: Done!

append_partition

------------------

(1 row)

SELECT prepend_partition('test.num_range_rel');

SELECTpathman.prepend_partition('test.num_range_rel');

NOTICE: Prepending new partition...

NOTICE: Done!

prepend_partition

-------------------

(1 row)

SELECT append_partition('test.range_rel');

SELECTpathman.append_partition('test.range_rel');

NOTICE: Appending new partition...

NOTICE: Done!

append_partition

------------------

(1 row)

SELECT prepend_partition('test.range_rel');

SELECTpathman.prepend_partition('test.range_rel');

NOTICE: Prepending new partition...

NOTICE: Done!

prepend_partition

/*

* Clean up

*/

SELECT drop_hash_partitions('test.hash_rel');

SELECTpathman.drop_hash_partitions('test.hash_rel');

drop_hash_partitions

----------------------

(1 row)

DROP TABLE test.hash_rel CASCADE;

NOTICE: drop cascades to 3 other objects

SELECT drop_range_partitions('test.num_range_rel');

SELECTpathman.drop_range_partitions('test.num_range_rel');

drop_range_partitions

-----------------------

(1 row)

DROP TABLE test.num_range_rel CASCADE;

NOTICE: drop cascades to 6 other objects

DROP EXTENSION pathman;

HTAB*relations=NULL;

staticboolvalidate_range_constraint(Expr*,PartRelationInfo*,Datum*,Datum*);

staticboolvalidate_hash_constraint(Expr*expr,PartRelationInfo*prel,int*hash);

staticintcmp_range_entries(constvoid*p1,constvoid*p2);

new_segment_created=init_dsm_segment(32);

LWLockAcquire(load_config_lock,LW_EXCLUSIVE);

load_part_relations_hashtable(new_segment_created);

load_relations_hashtable(new_segment_created);

LWLockRelease(load_config_lock);

}

check_extension()

get_extension_schema()

{

SPI_exec("SELECT * FROM pg_extension WHERE extname = 'pathman'",0);

returnSPI_processed>0;

intret;

boolisnull;

ret=SPI_exec("SELECT extnamespace::regnamespace::text FROM pg_extension WHERE extname = 'pathman'",0);

if (ret>0&&SPI_tuptable!=NULL)

{

TupleDesctupdesc=SPI_tuptable->tupdesc;

SPITupleTable*tuptable=SPI_tuptable;

HeapTupletuple=tuptable->vals[0];

Datumdatum=SPI_getbinval(tuple,tupdesc,1,&isnull);

if (isnull)

returnNULL;

returnTextDatumGetCString(datum);

}

returnNULL;

}

load_part_relations_hashtable(boolreinitialize)

load_relations_hashtable(boolreinitialize)

{

intret,

i,

proc;

boolisnull;

List*part_oids=NIL;

ListCell*lc;

char*schema;

PartRelationInfo*prel;

List*part_oids=NIL;

ListCell*lc;

"AND attrelid =pg_class.relfilenode";

char*query;

SPI_connect();

schema=get_extension_schema();

if (!check_extension())

if (!schema)

{

SPI_finish();

return;

}

ret=SPI_exec("SELECT pg_class.relfilenode, pg_attribute.attnum, pathman_config.parttype, pg_attribute.atttypid "

"AND attrelid = pg_class.relfilenode",0);

query=psprintf(sql,schema);

ret=SPI_exec(query,0);

proc=SPI_processed;

if (ret>0&&SPI_tuptable!=NULL)

}

}

pfree(query);

foreach(lc,part_oids)

}

create_part_relations_hashtable()

create_relations_hashtable()

{

HASHCTLctl;

alloc_dsm_table();

create_part_relations_hashtable();

create_relations_hashtable();

create_range_restrictions_hashtable();

LWLockRelease(AddinShmemInitLock);

}

pathman_set_rel_pathlist_hook(PlannerInfo*root,RelOptInfo*rel,Indexrti,RangeTblEntry*rte)

voidload_config(void);

voidcreate_part_relations_hashtable(void);

voidcreate_relations_hashtable(void);

voidcreate_hash_restrictions_hashtable(void);

voidcreate_range_restrictions_hashtable(void);

voidload_part_relations_hashtable(boolreinitialize);

voidload_relations_hashtable(boolreinitialize);

voidload_check_constraints(Oidparent_oid);

voidremove_relation_info(Oidrelid);

load_part_relations_hashtable(false);

load_relations_hashtable(false);

LWLockRelease(load_config_lock);

{

LWLockAcquire(load_config_lock,LW_EXCLUSIVE);

remove_relation_info(relid);

load_part_relations_hashtable(false);

load_relations_hashtable(false);

LWLockRelease(load_config_lock);

}