ISOLATIONCHECKS=insert_trigger

isolationcheck:

submake-isolation:

$(MAKE) -C$(top_builddir)/src/test/isolation all

isolationcheck: | submake-isolation

$(MKDIR_P) isolation_output

--temp-config=$(top_srcdir)/$(subdir)/conf.add\

Performs RANGE partitioning for`relation` by partitioning key`attribute`.`start_value` argument specifies initial value,`interval` sets the range of values in a single partition,`premake` is the number of premade partitions. All the data will be automatically copied from the parent to partitions.

Performs RANGE partitioning for`relation` by partitioning key`attribute`.`start_value` argument specifies initial value,`interval` sets the range of values in a single partition,`premake` is the number of premade partitions (if not set then pathman tries to determine it based on attribute values). All the data will be automatically copied from the parent to partitions.

Performs RANGE-partitioning from specified range for`relation` by partitioning key`attribute`. Data will be copied to partitions as well.

Creates the trigger on UPDATE for HASH partitions. The UPDATE trigger isn't created by default because of overhead. It is useful in cases when key attribute could be changed.

Same as above for RANGEsections.

Same as above for RANGEpartitioned table.

Merge two adjacent RANGE partitions. Data from`partition2` is copied to`partition1`. Then the`partition2` is removed.

Appends new partitionwith the range equal to the range of the previous partition.

Appends newRANGEpartitionand returns

Prepends new partition with the range equal to the range of the first partition.

Prepends new RANGE partition.

Creates new RANGE partition for`relation` with specified values range.

Drops RANGE partition and all its data.

Attaches partition to existing RANGE partitioned relation. The table being attached must have exact same structure as the parent one.

Detaches partition from existing RANGE partitioned relation.

Выполняет RANGE-секционирование таблицы`relation` по полю`attribute`. Аргумент`start_value` задает начальное значение,`interval` -- диапазон значений внутри одной секции,`premake` -- количество заранее создаваемых секций. Данные из родительской таблицы будут автоматически скопированы в дочерние.

Выполняет RANGE-секционирование таблицы`relation` по полю`attribute`. Аргумент`start_value` задает начальное значение,`interval` -- диапазон значений внутри одной секции,`premake` -- количество заранее создаваемых секций (если не задано, то pathman попытается определить количество секций на основе значений аттрибута). Данные из родительской таблицы будут автоматически скопированы в дочерние.

Объединяет две смежные RANGE секции. Данные из`partition2` копируются в`partition1`, после чего секция`partition2` удаляется.

Добавляет новую секцию в конец списка секций. Диапазон значений устанавливается равным последней секции.

Добавляет новуюRANGEсекцию в конец списка секций.

Добавляет новую секцию в начало списка секций.

Добавляет новую RANGE секцию в начало списка секций.

Добавляет новую RANGE секцию с заданным диапазоном к секционированной таблице`relation`.

Удаляет RANGE секцию вместе с содержащимися в ней данными.

Присоединяет существующую таблицу`partition` в качестве секции к ранее секционированной таблице`relation`. Структура присоединяемой таблицы должна в точности повторять структуру родительской.

Отсоединяет секцию`partition`, после чего она становится независимой таблицей.

Parsed test spec with 2 sessions

starting permutation: s1b s1_insert_150 s1r s1_show_partitions s2b s2_insert_150 s2c s2_show_partitions

create_range_partitions

1

step s1b: BEGIN;

step s1_insert_150: INSERT INTO range_rel SELECT generate_series(1, 150);

step s1r: ROLLBACK;

step s1_show_partitions: SELECT * FROM pg_inherits WHERE inhparent = 'range_rel'::regclass::oid;

inhrelid inhparent inhseqno

16453 16445 1

16462 16445 1

step s2b: BEGIN;

step s2_insert_150: INSERT INTO range_rel SELECT generate_series(1, 150);

step s2c: COMMIT;

step s2_show_partitions: SELECT * FROM pg_inherits WHERE inhparent = 'range_rel'::regclass::oid;

inhrelid inhparent inhseqno

16453 16445 1

16462 16445 1

starting permutation: s1b s1_insert_150 s1r s1_show_partitions s2b s2_insert_300 s2c s2_show_partitions

create_range_partitions

1

step s1b: BEGIN;

step s1_insert_150: INSERT INTO range_rel SELECT generate_series(1, 150);

step s1r: ROLLBACK;

step s1_show_partitions: SELECT * FROM pg_inherits WHERE inhparent = 'range_rel'::regclass::oid;

inhrelid inhparent inhseqno

16537 16529 1

16545 16529 1

step s2b: BEGIN;

step s2_insert_300: INSERT INTO range_rel SELECT generate_series(151, 300);

step s2c: COMMIT;

step s2_show_partitions: SELECT * FROM pg_inherits WHERE inhparent = 'range_rel'::regclass::oid;

inhrelid inhparent inhseqno

16537 16529 1

16545 16529 1

16552 16529 1

starting permutation: s1b s1_insert_300 s1r s1_show_partitions s2b s2_insert_150 s2c s2_show_partitions

create_range_partitions

1

step s1b: BEGIN;

step s1_insert_300: INSERT INTO range_rel SELECT generate_series(151, 300);

step s1r: ROLLBACK;

step s1_show_partitions: SELECT * FROM pg_inherits WHERE inhparent = 'range_rel'::regclass::oid;

inhrelid inhparent inhseqno

16627 16619 1

16635 16619 1

16642 16619 1

step s2b: BEGIN;

step s2_insert_150: INSERT INTO range_rel SELECT generate_series(1, 150);

step s2c: COMMIT;

step s2_show_partitions: SELECT * FROM pg_inherits WHERE inhparent = 'range_rel'::regclass::oid;

inhrelid inhparent inhseqno

16627 16619 1

16635 16619 1

16642 16619 1

starting permutation: s1b s1_insert_150 s2b s2_insert_300 s1r s2r s2_show_partitions

create_range_partitions

1

step s1b: BEGIN;

step s1_insert_150: INSERT INTO range_rel SELECT generate_series(1, 150);

step s2b: BEGIN;

step s2_insert_300: INSERT INTO range_rel SELECT generate_series(151, 300);

step s1r: ROLLBACK;

step s2r: ROLLBACK;

step s2_show_partitions: SELECT * FROM pg_inherits WHERE inhparent = 'range_rel'::regclass::oid;

inhrelid inhparent inhseqno

16717 16709 1

16725 16709 1

16732 16709 1

Index Cond: (dt <= 'Thu Jan 15 00:00:00 2015'::timestamp without time zone)

(6 rows)

SELECT pathman.detach_range_partition('test.range_rel_archive');

detach_range_partition

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

test.range_rel_archive

(1 row)

EXPLAIN (COSTS OFF) SELECT * FROM test.range_rel WHERE dt BETWEEN '2014-11-15' AND '2015-01-15';

QUERY PLAN

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

Append

-> Seq Scan on range_rel_8

-> Index Scan using range_rel_1_dt_idx on range_rel_1

Index Cond: (dt <= 'Thu Jan 15 00:00:00 2015'::timestamp without time zone)

(4 rows)

/*

* Clean up

*/

SELECT pathman.drop_hash_partitions('test.hash_rel');

NOTICE: drop cascades to trigger test_hash_rel_insert_trigger on table test.hash_rel

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

NOTICE: 2 rows copied from test.hash_rel_2

NOTICE: 3 rows copied from test.hash_rel_1

NOTICE: 1 rows copied from test.hash_rel_0

drop_hash_partitions

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

3

(1 row)

SELECT COUNT(*) FROM ONLY test.hash_rel;

count

-------

6

(1 row)

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

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

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

NOTICE: Copying data to partitions...

create_hash_partitions

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

3

(1 row)

SELECT pathman.drop_hash_partitions('test.hash_rel', TRUE);

NOTICE: drop cascades to trigger test_hash_rel_insert_trigger on table test.hash_rel

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

drop_hash_partitions

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

3

(1 row)

SELECT COUNT(*) FROM ONLY test.hash_rel;

count

-------

0

(1 row)

DROP TABLE test.hash_rel CASCADE;

CREATEOR REPLACE FUNCTION @extschema@.drop_hash_partitions(IN relationTEXT)

RETURNS VOIDAS

CREATEOR REPLACE FUNCTION @extschema@.drop_hash_partitions(

IN relationTEXT

, delete_dataBOOLEAN DEFAULT FALSE)

RETURNSINTEGERAS

$$

DECLARE

relidINTEGER;

partitions_countINTEGER;

rec RECORD;

numINTEGER :=0;

v_rec RECORD;

v_rowsINTEGER;

v_part_countINTEGER :=0;

relation := @extschema@.validate_relname(relation);

PERFORM @extschema@.drop_hash_triggers(relation);

DELETEFROM @extschema@.pathman_configWHERE relname= relation;

FOR recin (SELECT*FROM pg_inheritsWHERE inhparent= relation::regclass::oid)

FOR v_recin (SELECT inhrelid::regclass::textAS tbl

FROM pg_inheritsWHERE inhparent= relation::regclass::oid)

LOOP

EXECUTE format('DROP TABLE %s',rec.inhrelid::regclass::text);

IF NOT delete_data THEN

EXECUTE format('WITH part_data AS (DELETE FROM %s RETURNING *)

,v_rec.tbl

, relation);

GET DIAGNOSTICS v_rows= ROW_COUNT;

RAISE NOTICE'% rows copied from %', v_rows,v_rec.tbl;

END IF;

EXECUTE format('DROP TABLE %s',v_rec.tbl);

v_part_count := v_part_count+1;

END LOOP;

PERFORM @extschema@.on_remove_partitions(relation::regclass::oid);

RETURN v_part_count;

END

$$ LANGUAGE plpgsql;

TYPECACHE_CMP_PROC |TYPECACHE_CMP_PROC_FINFO);

prel=get_pathman_relation_info(relid,NULL);

rangerel=get_pathman_range_relation(relid,NULL);

if (!prel|| !rangerel||rangerel->ranges.length==0)

PG_RETURN_NULL();

cmp_proc_oid=get_opfamily_proc(tce->btree_opf,

value_type,

prel->atttype,

BTORDER_PROC);

fmgr_info(cmp_proc_oid,&cmp_func);

rangerel=get_pathman_range_relation(relid,NULL);

if (!rangerel||rangerel->ranges.length==0)

PG_RETURN_NULL();

ranges=dsm_array_get_pointer(&rangerel->ranges);

pos=range_binary_search(rangerel,&cmp_func,value,&found);