src/hooks.o src/nodes_common.o src/xact_handling.o src/utility_stmt_hooking.o \

pathman_utility_stmt_hooking \

ERROR: partitioning key "value" must be NOT NULL

ERROR: partitioning key "dt" must be NOT NULL

ERROR: not enough partitions to fit all values of "dt"

/*

* Test inlined SQL functions

*/

CREATE TABLE test.sql_inline (id INT NOT NULL);

SELECT pathman.create_hash_partitions('test.sql_inline', 'id', 3);

create_hash_partitions

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

3

(1 row)

CREATE OR REPLACE FUNCTION test.sql_inline_func(i_id int) RETURNS SETOF INT AS $$

select * from test.sql_inline where id = i_id limit 1;

$$ LANGUAGE sql STABLE;

EXPLAIN (COSTS OFF) SELECT * FROM test.sql_inline_func(5);

QUERY PLAN

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

Limit

-> Append

-> Seq Scan on sql_inline_0

Filter: (id = 5)

(4 rows)

EXPLAIN (COSTS OFF) SELECT * FROM test.sql_inline_func(1);

QUERY PLAN

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

Limit

-> Append

-> Seq Scan on sql_inline_2

Filter: (id = 1)

(4 rows)

DROP FUNCTION test.sql_inline_func(int);

DROP TABLE test.sql_inline CASCADE;

NOTICE: drop cascades to 3 other objects

/*

* Test by @baiyinqiqi (issue #60)

*/

CREATE TABLE test.hash_varchar(val VARCHAR(40) NOT NULL);

INSERT INTO test.hash_varchar SELECT generate_series(1, 20);

SELECT pathman.create_hash_partitions('test.hash_varchar', 'val', 4);

create_hash_partitions

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

4

(1 row)

SELECT * FROM test.hash_varchar WHERE val = 'a';

val

-----

(0 rows)

SELECT * FROM test.hash_varchar WHERE val = '12'::TEXT;

val

-----

12

(1 row)

DROP TABLE test.hash_varchar CASCADE;

NOTICE: drop cascades to 4 other objects

/* Test replacing hash partition */

CREATE TABLE test.hash_rel_extern (LIKE test.hash_rel INCLUDING ALL);

SELECT pathman.replace_hash_partition('test.hash_rel_0', 'test.hash_rel_extern');

replace_hash_partition

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

test.hash_rel_extern

(1 row)

\d+ test.hash_rel_0

Table "test.hash_rel_0"

Column | Type | Modifiers | Storage | Stats target | Description

--------+---------+------------------------------------------------------------+---------+--------------+-------------

id | integer | not null default nextval('test.hash_rel_id_seq'::regclass) | plain | |

value | integer | not null | plain | |

abc | integer | | plain | |

Indexes:

"hash_rel_0_pkey" PRIMARY KEY, btree (id)

Triggers:

hash_rel_upd_trig BEFORE UPDATE ON test.hash_rel_0 FOR EACH ROW EXECUTE PROCEDURE test.hash_rel_upd_trig_func()

\d+ test.hash_rel_extern

Table "test.hash_rel_extern"

Column | Type | Modifiers | Storage | Stats target | Description

--------+---------+------------------------------------------------------------+---------+--------------+-------------

id | integer | not null default nextval('test.hash_rel_id_seq'::regclass) | plain | |

value | integer | not null | plain | |

abc | integer | | plain | |

Indexes:

"hash_rel_extern_pkey" PRIMARY KEY, btree (id)

Check constraints:

"pathman_hash_rel_extern_2_check" CHECK (pathman.get_hash_part_idx(hashint4(value), 3) = 0)

Inherits: test.hash_rel

INSERT INTO test.hash_rel SELECT * FROM test.hash_rel_0;

DROP TABLE test.hash_rel_0;

/* Table with which we are replacing partition must have exact same structure */

CREATE TABLE test.hash_rel_wrong(

id INTEGER NOT NULL,

value INTEGER);

SELECT pathman.replace_hash_partition('test.hash_rel_1', 'test.hash_rel_wrong');

ERROR: partition must have the exact same structure as parent

EXPLAIN (COSTS OFF) SELECT * FROM test.hash_rel;

QUERY PLAN

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

Append

-> Seq Scan on hash_rel_extern

-> Seq Scan on hash_rel_1

-> Seq Scan on hash_rel_2

(4 rows)

NOTICE: drop cascades to 2 other objects

NOTICE: 2 rows copied from test.hash_rel_extern

SELECT add_range_partition('test.index_on_childs', 1, 1000, 'test.index_on_childs_1_1k');

SELECT append_range_partition('test.index_on_childs', 'test.index_on_childs_1k_2k');

SELECT append_range_partition('test.index_on_childs', 'test.index_on_childs_2k_3k');

SELECT append_range_partition('test.index_on_childs', 'test.index_on_childs_3k_4k');

SELECT append_range_partition('test.index_on_childs', 'test.index_on_childs_4k_5k');

NOTICE: drop cascades to 51 other objects

validate_relname

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

(1 row)

SELECT validate_relname(1::REGCLASS);

ERROR: relation "1" does not exist

SELECT validate_relname(NULL);

ERROR: relation should not be NULL

/* check function get_number_of_partitions() */

SELECT get_number_of_partitions('calamity.part_test');

get_number_of_partitions

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

0

(1 row)

SELECT get_number_of_partitions(NULL) IS NULL;

?column?

----------

t

/* check function create_hash_partitions_internal() (called for the 2nd time) */

CREATE TABLE calamity.hash_two_times(val serial);

SELECT create_hash_partitions_internal('calamity.hash_two_times', 'val', 2);

ERROR: table "hash_two_times" is not partitioned

SELECT create_hash_partitions('calamity.hash_two_times', 'val', 2);

create_hash_partitions

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

2

(1 row)

SELECT create_hash_partitions_internal('calamity.hash_two_times', 'val', 2);

ERROR: cannot add new HASH partitions

/* check function disable_pathman_for() */

CREATE TABLE calamity.to_be_disabled(val INT NOT NULL);

SELECT create_hash_partitions('calamity.to_be_disabled', 'val', 3); /* add row to main config */

create_hash_partitions

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

3

(1 row)

SELECT set_enable_parent('calamity.to_be_disabled', true); /* add row to params */

set_enable_parent

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

(1 row)

SELECT disable_pathman_for('calamity.to_be_disabled'); /* should delete both rows */

NOTICE: function calamity.to_be_disabled_upd_trig_func() does not exist, skipping

disable_pathman_for

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

(1 row)

SELECT count(*) FROM pathman_config WHERE partrel = 'calamity.to_be_disabled'::REGCLASS;

count

-------

0

(1 row)

SELECT count(*) FROM pathman_config_params WHERE partrel = 'calamity.to_be_disabled'::REGCLASS;

count

-------

0

(1 row)

NOTICE: drop cascades to 15 other objects