mirror of https://github.com/citusdata/citus.git
Merge pull request #2410 from citusdata/mx_partition_foreign_key
Do not create inherited constraints at worker tablespull/2412/head
Murat Tuncer
GitHub
commit
43a4ef939a
|
|
@ -493,7 +493,13 @@ GetTableForeignConstraintCommands(Oid relationId)
|
|||
{
|
||||
Form_pg_constraint constraintForm = (Form_pg_constraint) GETSTRUCT(heapTuple);
|
||||
|
||||
if (constraintForm->contype == CONSTRAINT_FOREIGN)
|
||||
#if (PG_VERSION_NUM >= 110000)
|
||||
bool inheritedConstraint = OidIsValid(constraintForm->conparentid);
|
||||
#else
|
||||
bool inheritedConstraint = false;
|
||||
#endif
|
||||
|
||||
if (!inheritedConstraint && constraintForm->contype == CONSTRAINT_FOREIGN)
|
||||
{
|
||||
Oid constraintId = get_relation_constraint_oid(relationId,
|
||||
constraintForm->conname.data,
|
||||
|
|
|
|||
|
|
@ -717,6 +717,76 @@ NOTICE: Copying data from local table...
|
|||
(1 row)
|
||||
|
||||
ALTER TABLE partitioning_test ADD CONSTRAINT partitioning_reference_fkey FOREIGN KEY (id) REFERENCES partitioning_test_reference(id) ON DELETE CASCADE;
|
||||
CREATE TABLE partitioning_test_foreign_key(id int PRIMARY KEY, value int);
|
||||
SELECT create_distributed_table('partitioning_test_foreign_key', 'id');
|
||||
create_distributed_table
|
||||
--------------------------
|
||||
|
||||
(1 row)
|
||||
|
||||
INSERT INTO partitioning_test_foreign_key SELECT * FROM partitioning_test_reference;
|
||||
ALTER TABLE partitioning_hash_test ADD CONSTRAINT partitioning_reference_fk_test FOREIGN KEY (id) REFERENCES partitioning_test_foreign_key(id) ON DELETE CASCADE;
|
||||
-- check foreign keys on partitions
|
||||
SELECT
|
||||
table_name, constraint_name, constraint_type FROm information_schema.table_constraints
|
||||
WHERE
|
||||
table_name LIKE 'partitioning_hash_test%' AND
|
||||
constraint_type = 'FOREIGN KEY'
|
||||
ORDER BY
|
||||
1,2;
|
||||
table_name | constraint_name | constraint_type
|
||||
--------------------------+--------------------------------+-----------------
|
||||
partitioning_hash_test | partitioning_reference_fk_test | FOREIGN KEY
|
||||
partitioning_hash_test_0 | partitioning_reference_fk_test | FOREIGN KEY
|
||||
partitioning_hash_test_1 | partitioning_reference_fk_test | FOREIGN KEY
|
||||
partitioning_hash_test_2 | partitioning_reference_fk_test | FOREIGN KEY
|
||||
(4 rows)
|
||||
|
||||
-- check foreign keys on partition shards
|
||||
-- there is some text ordering issue regarding table name
|
||||
-- forcing integer sort by extracting shardid
|
||||
CREATE TYPE foreign_key_details AS (table_name text, constraint_name text, constraint_type text);
|
||||
SELECT right(table_name, 7)::int as shardid, * FROM (
|
||||
SELECT (json_populate_record(NULL::foreign_key_details,
|
||||
json_array_elements_text(result::json)::json )).*
|
||||
FROM run_command_on_workers($$
|
||||
SELECT
|
||||
COALESCE(json_agg(row_to_json(q)), '[]'::json)
|
||||
FROM (
|
||||
SELECT
|
||||
table_name, constraint_name, constraint_type
|
||||
FROM information_schema.table_constraints
|
||||
WHERE
|
||||
table_name LIKE 'partitioning_hash_test%' AND
|
||||
constraint_type = 'FOREIGN KEY'
|
||||
ORDER BY 1, 2, 3
|
||||
) q
|
||||
$$) ) w
|
||||
ORDER BY 1, 2, 3, 4;
|
||||
shardid | table_name | constraint_name | constraint_type
|
||||
---------+----------------------------------+----------------------------------------+-----------------
|
||||
1660012 | partitioning_hash_test_1660012 | partitioning_reference_fk_test_1660012 | FOREIGN KEY
|
||||
1660013 | partitioning_hash_test_1660013 | partitioning_reference_fk_test_1660013 | FOREIGN KEY
|
||||
1660014 | partitioning_hash_test_1660014 | partitioning_reference_fk_test_1660014 | FOREIGN KEY
|
||||
1660015 | partitioning_hash_test_1660015 | partitioning_reference_fk_test_1660015 | FOREIGN KEY
|
||||
1660016 | partitioning_hash_test_0_1660016 | partitioning_reference_fk_test_1660012 | FOREIGN KEY
|
||||
1660017 | partitioning_hash_test_0_1660017 | partitioning_reference_fk_test_1660013 | FOREIGN KEY
|
||||
1660018 | partitioning_hash_test_0_1660018 | partitioning_reference_fk_test_1660014 | FOREIGN KEY
|
||||
1660019 | partitioning_hash_test_0_1660019 | partitioning_reference_fk_test_1660015 | FOREIGN KEY
|
||||
1660020 | partitioning_hash_test_1_1660020 | partitioning_reference_fk_test_1660012 | FOREIGN KEY
|
||||
1660021 | partitioning_hash_test_1_1660021 | partitioning_reference_fk_test_1660013 | FOREIGN KEY
|
||||
1660022 | partitioning_hash_test_1_1660022 | partitioning_reference_fk_test_1660014 | FOREIGN KEY
|
||||
1660023 | partitioning_hash_test_1_1660023 | partitioning_reference_fk_test_1660015 | FOREIGN KEY
|
||||
1660032 | partitioning_hash_test_2_1660032 | partitioning_reference_fk_test_1660012 | FOREIGN KEY
|
||||
1660033 | partitioning_hash_test_2_1660033 | partitioning_reference_fk_test_1660013 | FOREIGN KEY
|
||||
1660034 | partitioning_hash_test_2_1660034 | partitioning_reference_fk_test_1660014 | FOREIGN KEY
|
||||
1660035 | partitioning_hash_test_2_1660035 | partitioning_reference_fk_test_1660015 | FOREIGN KEY
|
||||
(16 rows)
|
||||
|
||||
DROP TYPE foreign_key_details;
|
||||
-- set replication factor back to 1 since it gots reset
|
||||
-- after connection re-establishment
|
||||
SET citus.shard_replication_factor TO 1;
|
||||
SELECT * FROM partitioning_test WHERE id = 11 or id = 12;
|
||||
id | time | new_column
|
||||
----+------------+------------
|
||||
|
|
@ -727,12 +797,33 @@ SELECT * FROM partitioning_test WHERE id = 11 or id = 12;
|
|||
(4 rows)
|
||||
|
||||
DELETE FROM partitioning_test_reference WHERE id = 11 or id = 12;
|
||||
SELECT * FROM partitioning_hash_test ORDER BY 1, 2;
|
||||
id | subid
|
||||
----+-------
|
||||
1 | 2
|
||||
2 | 13
|
||||
3 | 7
|
||||
4 | 4
|
||||
8 | 5
|
||||
9 | 12
|
||||
(6 rows)
|
||||
|
||||
DELETE FROM partitioning_test_foreign_key WHERE id = 2 OR id = 9;
|
||||
-- see data is deleted from referencing table
|
||||
SELECT * FROM partitioning_test WHERE id = 11 or id = 12;
|
||||
id | time | new_column
|
||||
----+------+------------
|
||||
(0 rows)
|
||||
|
||||
SELECT * FROM partitioning_hash_test ORDER BY 1, 2;
|
||||
id | subid
|
||||
----+-------
|
||||
1 | 2
|
||||
3 | 7
|
||||
4 | 4
|
||||
8 | 5
|
||||
(4 rows)
|
||||
|
||||
--
|
||||
-- Transaction tests
|
||||
--
|
||||
|
|
@ -888,10 +979,11 @@ DROP TABLE partitioning_test_reference;
|
|||
-- dropping the parent should CASCADE to the children as well
|
||||
SELECT table_name FROM information_schema.tables WHERE table_name LIKE 'partitioning_test%' ORDER BY 1;
|
||||
table_name
|
||||
---------------------------
|
||||
-------------------------------
|
||||
partitioning_test_2009
|
||||
partitioning_test_failure
|
||||
(2 rows)
|
||||
partitioning_test_foreign_key
|
||||
(3 rows)
|
||||
|
||||
-- test distributing partitioned table colocated with non-partitioned table
|
||||
CREATE TABLE partitioned_users_table (user_id int, time timestamp, value_1 int, value_2 int, value_3 float, value_4 bigint) PARTITION BY RANGE (time);
|
||||
|
|
@ -1135,7 +1227,7 @@ INSERT INTO multi_column_partitioning VALUES(1, 1);
|
|||
INSERT INTO multi_column_partitioning_0_0_10_0 VALUES(5, -5);
|
||||
-- test INSERT to multi-column partitioned table where no suitable partition exists
|
||||
INSERT INTO multi_column_partitioning VALUES(10, 1);
|
||||
ERROR: no partition of relation "multi_column_partitioning_1660097" found for row
|
||||
ERROR: no partition of relation "multi_column_partitioning_1660101" found for row
|
||||
DETAIL: Partition key of the failing row contains (c1, c2) = (10, 1).
|
||||
CONTEXT: while executing command on localhost:57637
|
||||
-- test with MINVALUE/MAXVALUE
|
||||
|
|
@ -1145,7 +1237,7 @@ INSERT INTO multi_column_partitioning VALUES(11, -11);
|
|||
INSERT INTO multi_column_partitioning_10_max_20_min VALUES(19, -19);
|
||||
-- test INSERT to multi-column partitioned table where no suitable partition exists
|
||||
INSERT INTO multi_column_partitioning VALUES(20, -20);
|
||||
ERROR: no partition of relation "multi_column_partitioning_1660097" found for row
|
||||
ERROR: no partition of relation "multi_column_partitioning_1660101" found for row
|
||||
DETAIL: Partition key of the failing row contains (c1, c2) = (20, -20).
|
||||
CONTEXT: while executing command on localhost:57637
|
||||
-- see data is loaded to multi-column partitioned table
|
||||
|
|
@ -1490,9 +1582,9 @@ SELECT * FROM partitioning_hash_test JOIN partitioning_hash_join_test USING (id,
|
|||
-> Sort (cost=563.15..580.10 rows=6780 width=8)
|
||||
Sort Key: partitioning_hash_join_test.id, partitioning_hash_join_test.subid
|
||||
-> Append (cost=0.00..131.70 rows=6780 width=8)
|
||||
-> Seq Scan on partitioning_hash_join_test_0_1660129 partitioning_hash_join_test (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Seq Scan on partitioning_hash_join_test_1_1660133 partitioning_hash_join_test_1 (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Seq Scan on partitioning_hash_join_test_2_1660137 partitioning_hash_join_test_2 (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Seq Scan on partitioning_hash_join_test_0_1660133 partitioning_hash_join_test (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Seq Scan on partitioning_hash_join_test_1_1660137 partitioning_hash_join_test_1 (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Seq Scan on partitioning_hash_join_test_2_1660141 partitioning_hash_join_test_2 (cost=0.00..32.60 rows=2260 width=8)
|
||||
(18 rows)
|
||||
|
||||
-- set partition-wise join on
|
||||
|
|
@ -1524,7 +1616,7 @@ SELECT * FROM partitioning_hash_test JOIN partitioning_hash_join_test USING (id,
|
|||
-> Append (cost=1.02..367.91 rows=130 width=8)
|
||||
-> Hash Join (cost=1.02..50.59 rows=1 width=8)
|
||||
Hash Cond: ((partitioning_hash_join_test.id = partitioning_hash_test.id) AND (partitioning_hash_join_test.subid = partitioning_hash_test.subid))
|
||||
-> Seq Scan on partitioning_hash_join_test_0_1660129 partitioning_hash_join_test (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Seq Scan on partitioning_hash_join_test_0_1660133 partitioning_hash_join_test (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Hash (cost=1.01..1.01 rows=1 width=8)
|
||||
-> Seq Scan on partitioning_hash_test_0_1660016 partitioning_hash_test (cost=0.00..1.01 rows=1 width=8)
|
||||
-> Merge Join (cost=158.66..266.09 rows=128 width=8)
|
||||
|
|
@ -1532,10 +1624,10 @@ SELECT * FROM partitioning_hash_test JOIN partitioning_hash_join_test USING (id,
|
|||
-> Index Only Scan using partitioning_hash_test_1_1660020_pkey on partitioning_hash_test_1_1660020 partitioning_hash_test_1 (cost=0.15..78.06 rows=2260 width=8)
|
||||
-> Sort (cost=158.51..164.16 rows=2260 width=8)
|
||||
Sort Key: partitioning_hash_join_test_1.id, partitioning_hash_join_test_1.subid
|
||||
-> Seq Scan on partitioning_hash_join_test_1_1660133 partitioning_hash_join_test_1 (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Seq Scan on partitioning_hash_join_test_1_1660137 partitioning_hash_join_test_1 (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Hash Join (cost=1.02..50.59 rows=1 width=8)
|
||||
Hash Cond: ((partitioning_hash_join_test_2.id = partitioning_hash_test_2.id) AND (partitioning_hash_join_test_2.subid = partitioning_hash_test_2.subid))
|
||||
-> Seq Scan on partitioning_hash_join_test_2_1660137 partitioning_hash_join_test_2 (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Seq Scan on partitioning_hash_join_test_2_1660141 partitioning_hash_join_test_2 (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Hash (cost=1.01..1.01 rows=1 width=8)
|
||||
-> Seq Scan on partitioning_hash_test_2_1660032 partitioning_hash_test_2 (cost=0.00..1.01 rows=1 width=8)
|
||||
(22 rows)
|
||||
|
|
@ -1562,9 +1654,9 @@ SELECT * FROM partitioning_hash_test JOIN partitioning_hash_join_test USING (id)
|
|||
-> Sort (cost=563.15..580.10 rows=6780 width=8)
|
||||
Sort Key: partitioning_hash_join_test.id
|
||||
-> Append (cost=0.00..131.70 rows=6780 width=8)
|
||||
-> Seq Scan on partitioning_hash_join_test_0_1660129 partitioning_hash_join_test (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Seq Scan on partitioning_hash_join_test_1_1660133 partitioning_hash_join_test_1 (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Seq Scan on partitioning_hash_join_test_2_1660137 partitioning_hash_join_test_2 (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Seq Scan on partitioning_hash_join_test_0_1660133 partitioning_hash_join_test (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Seq Scan on partitioning_hash_join_test_1_1660137 partitioning_hash_join_test_1 (cost=0.00..32.60 rows=2260 width=8)
|
||||
-> Seq Scan on partitioning_hash_join_test_2_1660141 partitioning_hash_join_test_2 (cost=0.00..32.60 rows=2260 width=8)
|
||||
(18 rows)
|
||||
|
||||
-- reset partition-wise join
|
||||
|
|
@ -1732,4 +1824,5 @@ DROP TABLE IF EXISTS
|
|||
partitioning_hash_test,
|
||||
partitioning_hash_join_test,
|
||||
partitioning_test_failure,
|
||||
non_distributed_partitioned_table;
|
||||
non_distributed_partitioned_table,
|
||||
partitioning_test_foreign_key;
|
||||
|
|
|
|||
|
|
@ -716,6 +716,57 @@ ALTER TABLE partitioning_test ADD CONSTRAINT partitioning_reference_fkey FOREIGN
|
|||
ERROR: foreign key constraints are not supported on partitioned tables
|
||||
LINE 1: ALTER TABLE partitioning_test ADD CONSTRAINT partitioning_re...
|
||||
^
|
||||
CREATE TABLE partitioning_test_foreign_key(id int PRIMARY KEY, value int);
|
||||
SELECT create_distributed_table('partitioning_test_foreign_key', 'id');
|
||||
create_distributed_table
|
||||
--------------------------
|
||||
|
||||
(1 row)
|
||||
|
||||
INSERT INTO partitioning_test_foreign_key SELECT * FROM partitioning_test_reference;
|
||||
ALTER TABLE partitioning_hash_test ADD CONSTRAINT partitioning_reference_fk_test FOREIGN KEY (id) REFERENCES partitioning_test_foreign_key(id) ON DELETE CASCADE;
|
||||
ERROR: relation "partitioning_hash_test" does not exist
|
||||
-- check foreign keys on partitions
|
||||
SELECT
|
||||
table_name, constraint_name, constraint_type FROm information_schema.table_constraints
|
||||
WHERE
|
||||
table_name LIKE 'partitioning_hash_test%' AND
|
||||
constraint_type = 'FOREIGN KEY'
|
||||
ORDER BY
|
||||
1,2;
|
||||
table_name | constraint_name | constraint_type
|
||||
------------+-----------------+-----------------
|
||||
(0 rows)
|
||||
|
||||
-- check foreign keys on partition shards
|
||||
-- there is some text ordering issue regarding table name
|
||||
-- forcing integer sort by extracting shardid
|
||||
CREATE TYPE foreign_key_details AS (table_name text, constraint_name text, constraint_type text);
|
||||
SELECT right(table_name, 7)::int as shardid, * FROM (
|
||||
SELECT (json_populate_record(NULL::foreign_key_details,
|
||||
json_array_elements_text(result::json)::json )).*
|
||||
FROM run_command_on_workers($$
|
||||
SELECT
|
||||
COALESCE(json_agg(row_to_json(q)), '[]'::json)
|
||||
FROM (
|
||||
SELECT
|
||||
table_name, constraint_name, constraint_type
|
||||
FROM information_schema.table_constraints
|
||||
WHERE
|
||||
table_name LIKE 'partitioning_hash_test%' AND
|
||||
constraint_type = 'FOREIGN KEY'
|
||||
ORDER BY 1, 2, 3
|
||||
) q
|
||||
$$) ) w
|
||||
ORDER BY 1, 2, 3, 4;
|
||||
shardid | table_name | constraint_name | constraint_type
|
||||
---------+------------+-----------------+-----------------
|
||||
(0 rows)
|
||||
|
||||
DROP TYPE foreign_key_details;
|
||||
-- set replication factor back to 1 since it gots reset
|
||||
-- after connection re-establishment
|
||||
SET citus.shard_replication_factor TO 1;
|
||||
SELECT * FROM partitioning_test WHERE id = 11 or id = 12;
|
||||
id | time | new_column
|
||||
----+------------+------------
|
||||
|
|
@ -726,6 +777,11 @@ SELECT * FROM partitioning_test WHERE id = 11 or id = 12;
|
|||
(4 rows)
|
||||
|
||||
DELETE FROM partitioning_test_reference WHERE id = 11 or id = 12;
|
||||
SELECT * FROM partitioning_hash_test ORDER BY 1, 2;
|
||||
ERROR: relation "partitioning_hash_test" does not exist
|
||||
LINE 1: SELECT * FROM partitioning_hash_test ORDER BY 1, 2;
|
||||
^
|
||||
DELETE FROM partitioning_test_foreign_key WHERE id = 2 OR id = 9;
|
||||
-- see data is deleted from referencing table
|
||||
SELECT * FROM partitioning_test WHERE id = 11 or id = 12;
|
||||
id | time | new_column
|
||||
|
|
@ -736,6 +792,10 @@ SELECT * FROM partitioning_test WHERE id = 11 or id = 12;
|
|||
12 | 01-02-2012 |
|
||||
(4 rows)
|
||||
|
||||
SELECT * FROM partitioning_hash_test ORDER BY 1, 2;
|
||||
ERROR: relation "partitioning_hash_test" does not exist
|
||||
LINE 1: SELECT * FROM partitioning_hash_test ORDER BY 1, 2;
|
||||
^
|
||||
--
|
||||
-- Transaction tests
|
||||
--
|
||||
|
|
@ -891,10 +951,11 @@ DROP TABLE partitioning_test_reference;
|
|||
-- dropping the parent should CASCADE to the children as well
|
||||
SELECT table_name FROM information_schema.tables WHERE table_name LIKE 'partitioning_test%' ORDER BY 1;
|
||||
table_name
|
||||
---------------------------
|
||||
-------------------------------
|
||||
partitioning_test_2009
|
||||
partitioning_test_failure
|
||||
(2 rows)
|
||||
partitioning_test_foreign_key
|
||||
(3 rows)
|
||||
|
||||
-- test distributing partitioned table colocated with non-partitioned table
|
||||
CREATE TABLE partitioned_users_table (user_id int, time timestamp, value_1 int, value_2 int, value_3 float, value_4 bigint) PARTITION BY RANGE (time);
|
||||
|
|
@ -1138,7 +1199,7 @@ INSERT INTO multi_column_partitioning VALUES(1, 1);
|
|||
INSERT INTO multi_column_partitioning_0_0_10_0 VALUES(5, -5);
|
||||
-- test INSERT to multi-column partitioned table where no suitable partition exists
|
||||
INSERT INTO multi_column_partitioning VALUES(10, 1);
|
||||
ERROR: no partition of relation "multi_column_partitioning_1660073" found for row
|
||||
ERROR: no partition of relation "multi_column_partitioning_1660077" found for row
|
||||
DETAIL: Partition key of the failing row contains (c1, c2) = (10, 1).
|
||||
CONTEXT: while executing command on localhost:57637
|
||||
-- test with MINVALUE/MAXVALUE
|
||||
|
|
@ -1148,7 +1209,7 @@ INSERT INTO multi_column_partitioning VALUES(11, -11);
|
|||
INSERT INTO multi_column_partitioning_10_max_20_min VALUES(19, -19);
|
||||
-- test INSERT to multi-column partitioned table where no suitable partition exists
|
||||
INSERT INTO multi_column_partitioning VALUES(20, -20);
|
||||
ERROR: no partition of relation "multi_column_partitioning_1660073" found for row
|
||||
ERROR: no partition of relation "multi_column_partitioning_1660077" found for row
|
||||
DETAIL: Partition key of the failing row contains (c1, c2) = (20, -20).
|
||||
CONTEXT: while executing command on localhost:57637
|
||||
-- see data is loaded to multi-column partitioned table
|
||||
|
|
@ -1684,6 +1745,7 @@ DROP TABLE IF EXISTS
|
|||
partitioning_hash_test,
|
||||
partitioning_hash_join_test,
|
||||
partitioning_test_failure,
|
||||
non_distributed_partitioned_table;
|
||||
non_distributed_partitioned_table,
|
||||
partitioning_test_foreign_key;
|
||||
NOTICE: table "partitioning_hash_test" does not exist, skipping
|
||||
NOTICE: table "partitioning_hash_join_test" does not exist, skipping
|
||||
|
|
|
|||
|
|
@ -704,16 +704,76 @@ NOTICE: Copying data from local table...
|
|||
|
||||
ALTER TABLE partitioning_test ADD CONSTRAINT partitioning_reference_fkey FOREIGN KEY (id) REFERENCES partitioning_test_reference(id) ON DELETE CASCADE;
|
||||
ERROR: relation "partitioning_test" does not exist
|
||||
CREATE TABLE partitioning_test_foreign_key(id int PRIMARY KEY, value int);
|
||||
SELECT create_distributed_table('partitioning_test_foreign_key', 'id');
|
||||
create_distributed_table
|
||||
--------------------------
|
||||
|
||||
(1 row)
|
||||
|
||||
INSERT INTO partitioning_test_foreign_key SELECT * FROM partitioning_test_reference;
|
||||
ALTER TABLE partitioning_hash_test ADD CONSTRAINT partitioning_reference_fk_test FOREIGN KEY (id) REFERENCES partitioning_test_foreign_key(id) ON DELETE CASCADE;
|
||||
ERROR: relation "partitioning_hash_test" does not exist
|
||||
-- check foreign keys on partitions
|
||||
SELECT
|
||||
table_name, constraint_name, constraint_type FROm information_schema.table_constraints
|
||||
WHERE
|
||||
table_name LIKE 'partitioning_hash_test%' AND
|
||||
constraint_type = 'FOREIGN KEY'
|
||||
ORDER BY
|
||||
1,2;
|
||||
table_name | constraint_name | constraint_type
|
||||
------------+-----------------+-----------------
|
||||
(0 rows)
|
||||
|
||||
-- check foreign keys on partition shards
|
||||
-- there is some text ordering issue regarding table name
|
||||
-- forcing integer sort by extracting shardid
|
||||
CREATE TYPE foreign_key_details AS (table_name text, constraint_name text, constraint_type text);
|
||||
SELECT right(table_name, 7)::int as shardid, * FROM (
|
||||
SELECT (json_populate_record(NULL::foreign_key_details,
|
||||
json_array_elements_text(result::json)::json )).*
|
||||
FROM run_command_on_workers($$
|
||||
SELECT
|
||||
COALESCE(json_agg(row_to_json(q)), '[]'::json)
|
||||
FROM (
|
||||
SELECT
|
||||
table_name, constraint_name, constraint_type
|
||||
FROM information_schema.table_constraints
|
||||
WHERE
|
||||
table_name LIKE 'partitioning_hash_test%' AND
|
||||
constraint_type = 'FOREIGN KEY'
|
||||
ORDER BY 1, 2, 3
|
||||
) q
|
||||
$$) ) w
|
||||
ORDER BY 1, 2, 3, 4;
|
||||
shardid | table_name | constraint_name | constraint_type
|
||||
---------+------------+-----------------+-----------------
|
||||
(0 rows)
|
||||
|
||||
DROP TYPE foreign_key_details;
|
||||
-- set replication factor back to 1 since it gots reset
|
||||
-- after connection re-establishment
|
||||
SET citus.shard_replication_factor TO 1;
|
||||
SELECT * FROM partitioning_test WHERE id = 11 or id = 12;
|
||||
ERROR: relation "partitioning_test" does not exist
|
||||
LINE 1: SELECT * FROM partitioning_test WHERE id = 11 or id = 12;
|
||||
^
|
||||
DELETE FROM partitioning_test_reference WHERE id = 11 or id = 12;
|
||||
SELECT * FROM partitioning_hash_test ORDER BY 1, 2;
|
||||
ERROR: relation "partitioning_hash_test" does not exist
|
||||
LINE 1: SELECT * FROM partitioning_hash_test ORDER BY 1, 2;
|
||||
^
|
||||
DELETE FROM partitioning_test_foreign_key WHERE id = 2 OR id = 9;
|
||||
-- see data is deleted from referencing table
|
||||
SELECT * FROM partitioning_test WHERE id = 11 or id = 12;
|
||||
ERROR: relation "partitioning_test" does not exist
|
||||
LINE 1: SELECT * FROM partitioning_test WHERE id = 11 or id = 12;
|
||||
^
|
||||
SELECT * FROM partitioning_hash_test ORDER BY 1, 2;
|
||||
ERROR: relation "partitioning_hash_test" does not exist
|
||||
LINE 1: SELECT * FROM partitioning_hash_test ORDER BY 1, 2;
|
||||
^
|
||||
--
|
||||
-- Transaction tests
|
||||
--
|
||||
|
|
@ -858,10 +918,11 @@ DROP TABLE partitioning_test_reference;
|
|||
-- dropping the parent should CASCADE to the children as well
|
||||
SELECT table_name FROM information_schema.tables WHERE table_name LIKE 'partitioning_test%' ORDER BY 1;
|
||||
table_name
|
||||
------------------------
|
||||
-------------------------------
|
||||
partitioning_test_2012
|
||||
partitioning_test_2013
|
||||
(2 rows)
|
||||
partitioning_test_foreign_key
|
||||
(3 rows)
|
||||
|
||||
-- test distributing partitioned table colocated with non-partitioned table
|
||||
CREATE TABLE partitioned_users_table (user_id int, time timestamp, value_1 int, value_2 int, value_3 float, value_4 bigint) PARTITION BY RANGE (time);
|
||||
|
|
@ -1569,7 +1630,8 @@ DROP TABLE IF EXISTS
|
|||
partitioning_hash_test,
|
||||
partitioning_hash_join_test,
|
||||
partitioning_test_failure,
|
||||
non_distributed_partitioned_table;
|
||||
non_distributed_partitioned_table,
|
||||
partitioning_test_foreign_key;
|
||||
NOTICE: table "partitioning_hash_test" does not exist, skipping
|
||||
NOTICE: table "partitioning_hash_join_test" does not exist, skipping
|
||||
NOTICE: table "partitioning_test_failure" does not exist, skipping
|
||||
|
|
|
|||
|
|
@ -451,10 +451,58 @@ SELECT create_reference_table('partitioning_test_reference');
|
|||
|
||||
ALTER TABLE partitioning_test ADD CONSTRAINT partitioning_reference_fkey FOREIGN KEY (id) REFERENCES partitioning_test_reference(id) ON DELETE CASCADE;
|
||||
|
||||
CREATE TABLE partitioning_test_foreign_key(id int PRIMARY KEY, value int);
|
||||
SELECT create_distributed_table('partitioning_test_foreign_key', 'id');
|
||||
INSERT INTO partitioning_test_foreign_key SELECT * FROM partitioning_test_reference;
|
||||
|
||||
ALTER TABLE partitioning_hash_test ADD CONSTRAINT partitioning_reference_fk_test FOREIGN KEY (id) REFERENCES partitioning_test_foreign_key(id) ON DELETE CASCADE;
|
||||
|
||||
-- check foreign keys on partitions
|
||||
SELECT
|
||||
table_name, constraint_name, constraint_type FROm information_schema.table_constraints
|
||||
WHERE
|
||||
table_name LIKE 'partitioning_hash_test%' AND
|
||||
constraint_type = 'FOREIGN KEY'
|
||||
ORDER BY
|
||||
1,2;
|
||||
|
||||
-- check foreign keys on partition shards
|
||||
-- there is some text ordering issue regarding table name
|
||||
-- forcing integer sort by extracting shardid
|
||||
CREATE TYPE foreign_key_details AS (table_name text, constraint_name text, constraint_type text);
|
||||
SELECT right(table_name, 7)::int as shardid, * FROM (
|
||||
SELECT (json_populate_record(NULL::foreign_key_details,
|
||||
json_array_elements_text(result::json)::json )).*
|
||||
FROM run_command_on_workers($$
|
||||
SELECT
|
||||
COALESCE(json_agg(row_to_json(q)), '[]'::json)
|
||||
FROM (
|
||||
SELECT
|
||||
table_name, constraint_name, constraint_type
|
||||
FROM information_schema.table_constraints
|
||||
WHERE
|
||||
table_name LIKE 'partitioning_hash_test%' AND
|
||||
constraint_type = 'FOREIGN KEY'
|
||||
ORDER BY 1, 2, 3
|
||||
) q
|
||||
$$) ) w
|
||||
ORDER BY 1, 2, 3, 4;
|
||||
|
||||
DROP TYPE foreign_key_details;
|
||||
|
||||
-- set replication factor back to 1 since it gots reset
|
||||
-- after connection re-establishment
|
||||
SET citus.shard_replication_factor TO 1;
|
||||
|
||||
SELECT * FROM partitioning_test WHERE id = 11 or id = 12;
|
||||
DELETE FROM partitioning_test_reference WHERE id = 11 or id = 12;
|
||||
|
||||
SELECT * FROM partitioning_hash_test ORDER BY 1, 2;
|
||||
DELETE FROM partitioning_test_foreign_key WHERE id = 2 OR id = 9;
|
||||
-- see data is deleted from referencing table
|
||||
SELECT * FROM partitioning_test WHERE id = 11 or id = 12;
|
||||
SELECT * FROM partitioning_hash_test ORDER BY 1, 2;
|
||||
|
||||
|
||||
--
|
||||
-- Transaction tests
|
||||
|
|
@ -1077,5 +1125,5 @@ DROP TABLE IF EXISTS
|
|||
partitioning_hash_test,
|
||||
partitioning_hash_join_test,
|
||||
partitioning_test_failure,
|
||||
non_distributed_partitioned_table;
|
||||
|
||||
non_distributed_partitioned_table,
|
||||
partitioning_test_foreign_key;
|
||||
|
|
|
|||
Loading…
Reference in New Issue