mirror of https://github.com/citusdata/citus.git
Fix broken isolation tests
We try to run our isolation tests paralles as much as possible. In some of those isolation tests we used same table name which causes problem while running them in paralles. This commit changes table names in those tests to ensure tests can run in parallel.pull/1525/head
Burak Yucesoy
parent
7769f1d012
commit
37b200a52e
|
|
@ -8,10 +8,10 @@ step s1-begin:
|
|||
BEGIN;
|
||||
|
||||
step s1-insert:
|
||||
INSERT INTO test_table VALUES(1);
|
||||
INSERT INTO test_concurrent_dml VALUES(1);
|
||||
|
||||
step s2-update:
|
||||
UPDATE test_table SET data = 'blarg' WHERE test_id = 1;
|
||||
UPDATE test_concurrent_dml SET data = 'blarg' WHERE test_id = 1;
|
||||
<waiting ...>
|
||||
step s1-commit:
|
||||
COMMIT;
|
||||
|
|
@ -23,8 +23,8 @@ master_create_worker_shards
|
|||
|
||||
|
||||
step s1-insert:
|
||||
INSERT INTO test_table VALUES(1);
|
||||
INSERT INTO test_concurrent_dml VALUES(1);
|
||||
|
||||
step s2-update:
|
||||
UPDATE test_table SET data = 'blarg' WHERE test_id = 1;
|
||||
UPDATE test_concurrent_dml SET data = 'blarg' WHERE test_id = 1;
|
||||
|
||||
|
|
|
|||
|
|
@ -2,16 +2,16 @@ Parsed test spec with 2 sessions
|
|||
|
||||
starting permutation: s1-load-cache s1-insert s1-begin s1-select s2-set-placement-inactive s2-begin s2-repair-placement s1-update s2-commit s1-commit s2-print-content
|
||||
step s1-load-cache:
|
||||
TRUNCATE test_table;
|
||||
TRUNCATE test_copy_placement_vs_modification;
|
||||
|
||||
step s1-insert:
|
||||
INSERT INTO test_table VALUES (5, 10);
|
||||
INSERT INTO test_copy_placement_vs_modification VALUES (5, 10);
|
||||
|
||||
step s1-begin:
|
||||
BEGIN;
|
||||
|
||||
step s1-select:
|
||||
SELECT count(*) FROM test_table WHERE x = 5;
|
||||
SELECT count(*) FROM test_copy_placement_vs_modification WHERE x = 5;
|
||||
|
||||
count
|
||||
|
||||
|
|
@ -29,7 +29,7 @@ master_copy_shard_placement
|
|||
|
||||
|
||||
step s1-update:
|
||||
UPDATE test_table SET y = 5 WHERE x = 5;
|
||||
UPDATE test_copy_placement_vs_modification SET y = 5 WHERE x = 5;
|
||||
<waiting ...>
|
||||
step s2-commit:
|
||||
COMMIT;
|
||||
|
|
@ -42,7 +42,7 @@ step s2-print-content:
|
|||
SELECT
|
||||
nodeport, success, result
|
||||
FROM
|
||||
run_command_on_placements('test_table', 'select y from %s WHERE x = 5')
|
||||
run_command_on_placements('test_copy_placement_vs_modification', 'select y from %s WHERE x = 5')
|
||||
WHERE
|
||||
shardid IN (SELECT * FROM selected_shard)
|
||||
ORDER BY
|
||||
|
|
@ -55,16 +55,16 @@ nodeport success result
|
|||
|
||||
starting permutation: s1-load-cache s1-insert s1-begin s1-select s2-set-placement-inactive s2-begin s2-repair-placement s1-delete s2-commit s1-commit s2-print-content
|
||||
step s1-load-cache:
|
||||
TRUNCATE test_table;
|
||||
TRUNCATE test_copy_placement_vs_modification;
|
||||
|
||||
step s1-insert:
|
||||
INSERT INTO test_table VALUES (5, 10);
|
||||
INSERT INTO test_copy_placement_vs_modification VALUES (5, 10);
|
||||
|
||||
step s1-begin:
|
||||
BEGIN;
|
||||
|
||||
step s1-select:
|
||||
SELECT count(*) FROM test_table WHERE x = 5;
|
||||
SELECT count(*) FROM test_copy_placement_vs_modification WHERE x = 5;
|
||||
|
||||
count
|
||||
|
||||
|
|
@ -82,7 +82,7 @@ master_copy_shard_placement
|
|||
|
||||
|
||||
step s1-delete:
|
||||
DELETE FROM test_table WHERE x = 5;
|
||||
DELETE FROM test_copy_placement_vs_modification WHERE x = 5;
|
||||
<waiting ...>
|
||||
step s2-commit:
|
||||
COMMIT;
|
||||
|
|
@ -95,7 +95,7 @@ step s2-print-content:
|
|||
SELECT
|
||||
nodeport, success, result
|
||||
FROM
|
||||
run_command_on_placements('test_table', 'select y from %s WHERE x = 5')
|
||||
run_command_on_placements('test_copy_placement_vs_modification', 'select y from %s WHERE x = 5')
|
||||
WHERE
|
||||
shardid IN (SELECT * FROM selected_shard)
|
||||
ORDER BY
|
||||
|
|
@ -108,13 +108,13 @@ nodeport success result
|
|||
|
||||
starting permutation: s1-load-cache s1-begin s1-select s2-set-placement-inactive s2-begin s2-repair-placement s1-insert s2-commit s1-commit s2-print-content
|
||||
step s1-load-cache:
|
||||
TRUNCATE test_table;
|
||||
TRUNCATE test_copy_placement_vs_modification;
|
||||
|
||||
step s1-begin:
|
||||
BEGIN;
|
||||
|
||||
step s1-select:
|
||||
SELECT count(*) FROM test_table WHERE x = 5;
|
||||
SELECT count(*) FROM test_copy_placement_vs_modification WHERE x = 5;
|
||||
|
||||
count
|
||||
|
||||
|
|
@ -132,7 +132,7 @@ master_copy_shard_placement
|
|||
|
||||
|
||||
step s1-insert:
|
||||
INSERT INTO test_table VALUES (5, 10);
|
||||
INSERT INTO test_copy_placement_vs_modification VALUES (5, 10);
|
||||
<waiting ...>
|
||||
step s2-commit:
|
||||
COMMIT;
|
||||
|
|
@ -145,7 +145,7 @@ step s2-print-content:
|
|||
SELECT
|
||||
nodeport, success, result
|
||||
FROM
|
||||
run_command_on_placements('test_table', 'select y from %s WHERE x = 5')
|
||||
run_command_on_placements('test_copy_placement_vs_modification', 'select y from %s WHERE x = 5')
|
||||
WHERE
|
||||
shardid IN (SELECT * FROM selected_shard)
|
||||
ORDER BY
|
||||
|
|
@ -158,13 +158,13 @@ nodeport success result
|
|||
|
||||
starting permutation: s1-load-cache s1-begin s1-select s2-set-placement-inactive s2-begin s2-repair-placement s1-copy s2-commit s1-commit s2-print-content
|
||||
step s1-load-cache:
|
||||
TRUNCATE test_table;
|
||||
TRUNCATE test_copy_placement_vs_modification;
|
||||
|
||||
step s1-begin:
|
||||
BEGIN;
|
||||
|
||||
step s1-select:
|
||||
SELECT count(*) FROM test_table WHERE x = 5;
|
||||
SELECT count(*) FROM test_copy_placement_vs_modification WHERE x = 5;
|
||||
|
||||
count
|
||||
|
||||
|
|
@ -182,7 +182,7 @@ master_copy_shard_placement
|
|||
|
||||
|
||||
step s1-copy:
|
||||
COPY test_table FROM PROGRAM 'echo "1,1\n2,2\n3,3\n4,4\n5,5"' WITH CSV;
|
||||
COPY test_copy_placement_vs_modification FROM PROGRAM 'echo "1,1\n2,2\n3,3\n4,4\n5,5"' WITH CSV;
|
||||
<waiting ...>
|
||||
step s2-commit:
|
||||
COMMIT;
|
||||
|
|
@ -195,7 +195,7 @@ step s2-print-content:
|
|||
SELECT
|
||||
nodeport, success, result
|
||||
FROM
|
||||
run_command_on_placements('test_table', 'select y from %s WHERE x = 5')
|
||||
run_command_on_placements('test_copy_placement_vs_modification', 'select y from %s WHERE x = 5')
|
||||
WHERE
|
||||
shardid IN (SELECT * FROM selected_shard)
|
||||
ORDER BY
|
||||
|
|
@ -208,13 +208,13 @@ nodeport success result
|
|||
|
||||
starting permutation: s1-load-cache s1-begin s1-select s2-set-placement-inactive s2-begin s2-repair-placement s1-ddl s2-commit s1-commit s2-print-index-count
|
||||
step s1-load-cache:
|
||||
TRUNCATE test_table;
|
||||
TRUNCATE test_copy_placement_vs_modification;
|
||||
|
||||
step s1-begin:
|
||||
BEGIN;
|
||||
|
||||
step s1-select:
|
||||
SELECT count(*) FROM test_table WHERE x = 5;
|
||||
SELECT count(*) FROM test_copy_placement_vs_modification WHERE x = 5;
|
||||
|
||||
count
|
||||
|
||||
|
|
@ -232,7 +232,7 @@ master_copy_shard_placement
|
|||
|
||||
|
||||
step s1-ddl:
|
||||
CREATE INDEX test_table_index ON test_table(x);
|
||||
CREATE INDEX test_copy_placement_vs_modification_index ON test_copy_placement_vs_modification(x);
|
||||
<waiting ...>
|
||||
step s2-commit:
|
||||
COMMIT;
|
||||
|
|
@ -245,7 +245,7 @@ step s2-print-index-count:
|
|||
SELECT
|
||||
nodeport, success, result
|
||||
FROM
|
||||
run_command_on_placements('test_table', 'select count(*) from pg_indexes WHERE schemaname || ''.'' || tablename = ''%s''')
|
||||
run_command_on_placements('test_copy_placement_vs_modification', 'select count(*) from pg_indexes WHERE schemaname || ''.'' || tablename = ''%s''')
|
||||
ORDER BY
|
||||
nodeport;
|
||||
|
||||
|
|
@ -258,13 +258,13 @@ nodeport success result
|
|||
|
||||
starting permutation: s1-insert s1-begin s1-select s2-set-placement-inactive s2-begin s2-repair-placement s1-update s2-commit s1-commit s2-print-content
|
||||
step s1-insert:
|
||||
INSERT INTO test_table VALUES (5, 10);
|
||||
INSERT INTO test_copy_placement_vs_modification VALUES (5, 10);
|
||||
|
||||
step s1-begin:
|
||||
BEGIN;
|
||||
|
||||
step s1-select:
|
||||
SELECT count(*) FROM test_table WHERE x = 5;
|
||||
SELECT count(*) FROM test_copy_placement_vs_modification WHERE x = 5;
|
||||
|
||||
count
|
||||
|
||||
|
|
@ -282,7 +282,7 @@ master_copy_shard_placement
|
|||
|
||||
|
||||
step s1-update:
|
||||
UPDATE test_table SET y = 5 WHERE x = 5;
|
||||
UPDATE test_copy_placement_vs_modification SET y = 5 WHERE x = 5;
|
||||
<waiting ...>
|
||||
step s2-commit:
|
||||
COMMIT;
|
||||
|
|
@ -295,7 +295,7 @@ step s2-print-content:
|
|||
SELECT
|
||||
nodeport, success, result
|
||||
FROM
|
||||
run_command_on_placements('test_table', 'select y from %s WHERE x = 5')
|
||||
run_command_on_placements('test_copy_placement_vs_modification', 'select y from %s WHERE x = 5')
|
||||
WHERE
|
||||
shardid IN (SELECT * FROM selected_shard)
|
||||
ORDER BY
|
||||
|
|
@ -308,13 +308,13 @@ nodeport success result
|
|||
|
||||
starting permutation: s1-insert s1-begin s1-select s2-set-placement-inactive s2-begin s2-repair-placement s1-delete s2-commit s1-commit s2-print-content
|
||||
step s1-insert:
|
||||
INSERT INTO test_table VALUES (5, 10);
|
||||
INSERT INTO test_copy_placement_vs_modification VALUES (5, 10);
|
||||
|
||||
step s1-begin:
|
||||
BEGIN;
|
||||
|
||||
step s1-select:
|
||||
SELECT count(*) FROM test_table WHERE x = 5;
|
||||
SELECT count(*) FROM test_copy_placement_vs_modification WHERE x = 5;
|
||||
|
||||
count
|
||||
|
||||
|
|
@ -332,7 +332,7 @@ master_copy_shard_placement
|
|||
|
||||
|
||||
step s1-delete:
|
||||
DELETE FROM test_table WHERE x = 5;
|
||||
DELETE FROM test_copy_placement_vs_modification WHERE x = 5;
|
||||
<waiting ...>
|
||||
step s2-commit:
|
||||
COMMIT;
|
||||
|
|
@ -345,7 +345,7 @@ step s2-print-content:
|
|||
SELECT
|
||||
nodeport, success, result
|
||||
FROM
|
||||
run_command_on_placements('test_table', 'select y from %s WHERE x = 5')
|
||||
run_command_on_placements('test_copy_placement_vs_modification', 'select y from %s WHERE x = 5')
|
||||
WHERE
|
||||
shardid IN (SELECT * FROM selected_shard)
|
||||
ORDER BY
|
||||
|
|
@ -361,7 +361,7 @@ step s1-begin:
|
|||
BEGIN;
|
||||
|
||||
step s1-select:
|
||||
SELECT count(*) FROM test_table WHERE x = 5;
|
||||
SELECT count(*) FROM test_copy_placement_vs_modification WHERE x = 5;
|
||||
|
||||
count
|
||||
|
||||
|
|
@ -379,7 +379,7 @@ master_copy_shard_placement
|
|||
|
||||
|
||||
step s1-insert:
|
||||
INSERT INTO test_table VALUES (5, 10);
|
||||
INSERT INTO test_copy_placement_vs_modification VALUES (5, 10);
|
||||
<waiting ...>
|
||||
step s2-commit:
|
||||
COMMIT;
|
||||
|
|
@ -392,7 +392,7 @@ step s2-print-content:
|
|||
SELECT
|
||||
nodeport, success, result
|
||||
FROM
|
||||
run_command_on_placements('test_table', 'select y from %s WHERE x = 5')
|
||||
run_command_on_placements('test_copy_placement_vs_modification', 'select y from %s WHERE x = 5')
|
||||
WHERE
|
||||
shardid IN (SELECT * FROM selected_shard)
|
||||
ORDER BY
|
||||
|
|
@ -408,7 +408,7 @@ step s1-begin:
|
|||
BEGIN;
|
||||
|
||||
step s1-select:
|
||||
SELECT count(*) FROM test_table WHERE x = 5;
|
||||
SELECT count(*) FROM test_copy_placement_vs_modification WHERE x = 5;
|
||||
|
||||
count
|
||||
|
||||
|
|
@ -426,7 +426,7 @@ master_copy_shard_placement
|
|||
|
||||
|
||||
step s1-copy:
|
||||
COPY test_table FROM PROGRAM 'echo "1,1\n2,2\n3,3\n4,4\n5,5"' WITH CSV;
|
||||
COPY test_copy_placement_vs_modification FROM PROGRAM 'echo "1,1\n2,2\n3,3\n4,4\n5,5"' WITH CSV;
|
||||
<waiting ...>
|
||||
step s2-commit:
|
||||
COMMIT;
|
||||
|
|
@ -439,7 +439,7 @@ step s2-print-content:
|
|||
SELECT
|
||||
nodeport, success, result
|
||||
FROM
|
||||
run_command_on_placements('test_table', 'select y from %s WHERE x = 5')
|
||||
run_command_on_placements('test_copy_placement_vs_modification', 'select y from %s WHERE x = 5')
|
||||
WHERE
|
||||
shardid IN (SELECT * FROM selected_shard)
|
||||
ORDER BY
|
||||
|
|
@ -455,7 +455,7 @@ step s1-begin:
|
|||
BEGIN;
|
||||
|
||||
step s1-select:
|
||||
SELECT count(*) FROM test_table WHERE x = 5;
|
||||
SELECT count(*) FROM test_copy_placement_vs_modification WHERE x = 5;
|
||||
|
||||
count
|
||||
|
||||
|
|
@ -473,7 +473,7 @@ master_copy_shard_placement
|
|||
|
||||
|
||||
step s1-ddl:
|
||||
CREATE INDEX test_table_index ON test_table(x);
|
||||
CREATE INDEX test_copy_placement_vs_modification_index ON test_copy_placement_vs_modification(x);
|
||||
<waiting ...>
|
||||
step s2-commit:
|
||||
COMMIT;
|
||||
|
|
@ -486,7 +486,7 @@ step s2-print-index-count:
|
|||
SELECT
|
||||
nodeport, success, result
|
||||
FROM
|
||||
run_command_on_placements('test_table', 'select count(*) from pg_indexes WHERE schemaname || ''.'' || tablename = ''%s''')
|
||||
run_command_on_placements('test_copy_placement_vs_modification', 'select count(*) from pg_indexes WHERE schemaname || ''.'' || tablename = ''%s''')
|
||||
ORDER BY
|
||||
nodeport;
|
||||
|
||||
|
|
|
|||
|
|
@ -5,16 +5,16 @@ master_create_worker_shards
|
|||
|
||||
|
||||
step s2-invalidate-57637:
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57637;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57637;
|
||||
|
||||
step s1-begin:
|
||||
BEGIN;
|
||||
|
||||
step s1-insertone:
|
||||
INSERT INTO test_table VALUES(1, 1);
|
||||
INSERT INTO test_dml_vs_repair VALUES(1, 1);
|
||||
|
||||
step s2-repair:
|
||||
SELECT master_copy_shard_placement((SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass), 'localhost', 57638, 'localhost', 57637);
|
||||
SELECT master_copy_shard_placement((SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass), 'localhost', 57638, 'localhost', 57637);
|
||||
<waiting ...>
|
||||
step s1-commit:
|
||||
COMMIT;
|
||||
|
|
@ -29,19 +29,19 @@ master_create_worker_shards
|
|||
|
||||
|
||||
step s1-insertone:
|
||||
INSERT INTO test_table VALUES(1, 1);
|
||||
INSERT INTO test_dml_vs_repair VALUES(1, 1);
|
||||
|
||||
step s2-invalidate-57637:
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57637;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57637;
|
||||
|
||||
step s1-begin:
|
||||
BEGIN;
|
||||
|
||||
step s1-insertall:
|
||||
INSERT INTO test_table SELECT test_id, data+1 FROM test_table;
|
||||
INSERT INTO test_dml_vs_repair SELECT test_id, data+1 FROM test_dml_vs_repair;
|
||||
|
||||
step s2-repair:
|
||||
SELECT master_copy_shard_placement((SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass), 'localhost', 57638, 'localhost', 57637);
|
||||
SELECT master_copy_shard_placement((SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass), 'localhost', 57638, 'localhost', 57637);
|
||||
<waiting ...>
|
||||
step s1-commit:
|
||||
COMMIT;
|
||||
|
|
@ -56,41 +56,41 @@ master_create_worker_shards
|
|||
|
||||
|
||||
step s2-invalidate-57637:
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57637;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57637;
|
||||
|
||||
step s2-begin:
|
||||
BEGIN;
|
||||
|
||||
step s2-repair:
|
||||
SELECT master_copy_shard_placement((SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass), 'localhost', 57638, 'localhost', 57637);
|
||||
SELECT master_copy_shard_placement((SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass), 'localhost', 57638, 'localhost', 57637);
|
||||
|
||||
master_copy_shard_placement
|
||||
|
||||
|
||||
step s1-insertone:
|
||||
INSERT INTO test_table VALUES(1, 1);
|
||||
INSERT INTO test_dml_vs_repair VALUES(1, 1);
|
||||
<waiting ...>
|
||||
step s2-commit:
|
||||
COMMIT;
|
||||
|
||||
step s1-insertone: <... completed>
|
||||
step s2-invalidate-57638:
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57638;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57638;
|
||||
|
||||
step s1-display:
|
||||
SELECT * FROM test_table WHERE test_id = 1;
|
||||
SELECT * FROM test_dml_vs_repair WHERE test_id = 1;
|
||||
|
||||
test_id data
|
||||
|
||||
1 1
|
||||
step s2-invalidate-57637:
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57637;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57637;
|
||||
|
||||
step s2-revalidate-57638:
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '1' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57638;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '1' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57638;
|
||||
|
||||
step s1-display:
|
||||
SELECT * FROM test_table WHERE test_id = 1;
|
||||
SELECT * FROM test_dml_vs_repair WHERE test_id = 1;
|
||||
|
||||
test_id data
|
||||
|
||||
|
|
@ -101,7 +101,7 @@ master_create_worker_shards
|
|||
|
||||
|
||||
step s2-invalidate-57637:
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57637;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57637;
|
||||
|
||||
step s1-prepared-insertone:
|
||||
EXECUTE insertone;
|
||||
|
|
@ -110,7 +110,7 @@ step s2-begin:
|
|||
BEGIN;
|
||||
|
||||
step s2-repair:
|
||||
SELECT master_copy_shard_placement((SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass), 'localhost', 57638, 'localhost', 57637);
|
||||
SELECT master_copy_shard_placement((SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass), 'localhost', 57638, 'localhost', 57637);
|
||||
|
||||
master_copy_shard_placement
|
||||
|
||||
|
|
@ -124,22 +124,22 @@ step s2-commit:
|
|||
step s1-prepared-insertone: <... completed>
|
||||
error in steps s2-commit s1-prepared-insertone: ERROR: prepared modifications cannot be executed on a shard while it is being copied
|
||||
step s2-invalidate-57638:
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57638;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57638;
|
||||
|
||||
step s1-display:
|
||||
SELECT * FROM test_table WHERE test_id = 1;
|
||||
SELECT * FROM test_dml_vs_repair WHERE test_id = 1;
|
||||
|
||||
test_id data
|
||||
|
||||
1 1
|
||||
step s2-invalidate-57637:
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57637;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57637;
|
||||
|
||||
step s2-revalidate-57638:
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '1' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57638;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '1' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57638;
|
||||
|
||||
step s1-display:
|
||||
SELECT * FROM test_table WHERE test_id = 1;
|
||||
SELECT * FROM test_dml_vs_repair WHERE test_id = 1;
|
||||
|
||||
test_id data
|
||||
|
||||
|
|
@ -150,10 +150,10 @@ master_create_worker_shards
|
|||
|
||||
|
||||
step s2-invalidate-57637:
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57637;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57637;
|
||||
|
||||
step s1-insertone:
|
||||
INSERT INTO test_table VALUES(1, 1);
|
||||
INSERT INTO test_dml_vs_repair VALUES(1, 1);
|
||||
|
||||
step s1-prepared-insertall:
|
||||
EXECUTE insertall;
|
||||
|
|
@ -162,7 +162,7 @@ step s2-begin:
|
|||
BEGIN;
|
||||
|
||||
step s2-repair:
|
||||
SELECT master_copy_shard_placement((SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass), 'localhost', 57638, 'localhost', 57637);
|
||||
SELECT master_copy_shard_placement((SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass), 'localhost', 57638, 'localhost', 57637);
|
||||
|
||||
master_copy_shard_placement
|
||||
|
||||
|
|
@ -176,23 +176,23 @@ step s2-commit:
|
|||
step s1-prepared-insertall: <... completed>
|
||||
error in steps s2-commit s1-prepared-insertall: ERROR: prepared modifications cannot be executed on a shard while it is being copied
|
||||
step s2-invalidate-57638:
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57638;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57638;
|
||||
|
||||
step s1-display:
|
||||
SELECT * FROM test_table WHERE test_id = 1;
|
||||
SELECT * FROM test_dml_vs_repair WHERE test_id = 1;
|
||||
|
||||
test_id data
|
||||
|
||||
1 1
|
||||
1 2
|
||||
step s2-invalidate-57637:
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57637;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57637;
|
||||
|
||||
step s2-revalidate-57638:
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '1' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57638;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '1' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57638;
|
||||
|
||||
step s1-display:
|
||||
SELECT * FROM test_table WHERE test_id = 1;
|
||||
SELECT * FROM test_dml_vs_repair WHERE test_id = 1;
|
||||
|
||||
test_id data
|
||||
|
||||
|
|
|
|||
|
|
@ -5,7 +5,8 @@ test: isolation_add_node_vs_reference_table_operations
|
|||
# that come later can be parallelized
|
||||
test: isolation_cluster_management
|
||||
|
||||
test: isolation_dml_vs_repair isolation_copy_placement_vs_copy_placement isolation_cancellation
|
||||
test: isolation_dml_vs_repair
|
||||
test: isolation_copy_placement_vs_copy_placement isolation_cancellation
|
||||
test: isolation_concurrent_dml isolation_data_migration
|
||||
test: isolation_drop_shards isolation_copy_placement_vs_modification
|
||||
test: isolation_insert_vs_vacuum isolation_transaction_recovery
|
||||
|
|
|
|||
|
|
@ -1,13 +1,13 @@
|
|||
setup
|
||||
{
|
||||
CREATE TABLE test_table (test_id integer NOT NULL, data text);
|
||||
SELECT master_create_distributed_table('test_table', 'test_id', 'hash');
|
||||
SELECT master_create_worker_shards('test_table', 4, 2);
|
||||
CREATE TABLE test_concurrent_dml (test_id integer NOT NULL, data text);
|
||||
SELECT master_create_distributed_table('test_concurrent_dml', 'test_id', 'hash');
|
||||
SELECT master_create_worker_shards('test_concurrent_dml', 4, 2);
|
||||
}
|
||||
|
||||
teardown
|
||||
{
|
||||
DROP TABLE IF EXISTS test_table CASCADE;
|
||||
DROP TABLE IF EXISTS test_concurrent_dml CASCADE;
|
||||
}
|
||||
|
||||
session "s1"
|
||||
|
|
@ -19,7 +19,7 @@ step "s1-begin"
|
|||
|
||||
step "s1-insert"
|
||||
{
|
||||
INSERT INTO test_table VALUES(1);
|
||||
INSERT INTO test_concurrent_dml VALUES(1);
|
||||
}
|
||||
|
||||
step "s1-commit"
|
||||
|
|
@ -31,7 +31,7 @@ session "s2"
|
|||
|
||||
step "s2-update"
|
||||
{
|
||||
UPDATE test_table SET data = 'blarg' WHERE test_id = 1;
|
||||
UPDATE test_concurrent_dml SET data = 'blarg' WHERE test_id = 1;
|
||||
}
|
||||
|
||||
# verify that an in-progress insert blocks concurrent updates
|
||||
|
|
|
|||
|
|
@ -4,15 +4,15 @@ setup
|
|||
{
|
||||
SET citus.shard_count TO 2;
|
||||
SET citus.shard_replication_factor TO 2;
|
||||
CREATE TABLE test_table (x int, y int);
|
||||
SELECT create_distributed_table('test_table', 'x');
|
||||
CREATE TABLE test_copy_placement_vs_modification (x int, y int);
|
||||
SELECT create_distributed_table('test_copy_placement_vs_modification', 'x');
|
||||
|
||||
SELECT get_shard_id_for_distribution_column('test_table', 5) INTO selected_shard;
|
||||
SELECT get_shard_id_for_distribution_column('test_copy_placement_vs_modification', 5) INTO selected_shard;
|
||||
}
|
||||
|
||||
teardown
|
||||
{
|
||||
DROP TABLE test_table;
|
||||
DROP TABLE test_copy_placement_vs_modification;
|
||||
DROP TABLE selected_shard;
|
||||
}
|
||||
|
||||
|
|
@ -23,41 +23,41 @@ step "s1-begin"
|
|||
BEGIN;
|
||||
}
|
||||
|
||||
# since test_table has rep > 1 simple select query doesn't hit all placements
|
||||
# since test_copy_placement_vs_modification has rep > 1 simple select query doesn't hit all placements
|
||||
# hence not all placements are cached
|
||||
step "s1-load-cache"
|
||||
{
|
||||
TRUNCATE test_table;
|
||||
TRUNCATE test_copy_placement_vs_modification;
|
||||
}
|
||||
|
||||
step "s1-insert"
|
||||
{
|
||||
INSERT INTO test_table VALUES (5, 10);
|
||||
INSERT INTO test_copy_placement_vs_modification VALUES (5, 10);
|
||||
}
|
||||
|
||||
step "s1-update"
|
||||
{
|
||||
UPDATE test_table SET y = 5 WHERE x = 5;
|
||||
UPDATE test_copy_placement_vs_modification SET y = 5 WHERE x = 5;
|
||||
}
|
||||
|
||||
step "s1-delete"
|
||||
{
|
||||
DELETE FROM test_table WHERE x = 5;
|
||||
DELETE FROM test_copy_placement_vs_modification WHERE x = 5;
|
||||
}
|
||||
|
||||
step "s1-select"
|
||||
{
|
||||
SELECT count(*) FROM test_table WHERE x = 5;
|
||||
SELECT count(*) FROM test_copy_placement_vs_modification WHERE x = 5;
|
||||
}
|
||||
|
||||
step "s1-ddl"
|
||||
{
|
||||
CREATE INDEX test_table_index ON test_table(x);
|
||||
CREATE INDEX test_copy_placement_vs_modification_index ON test_copy_placement_vs_modification(x);
|
||||
}
|
||||
|
||||
step "s1-copy"
|
||||
{
|
||||
COPY test_table FROM PROGRAM 'echo "1,1\n2,2\n3,3\n4,4\n5,5"' WITH CSV;
|
||||
COPY test_copy_placement_vs_modification FROM PROGRAM 'echo "1,1\n2,2\n3,3\n4,4\n5,5"' WITH CSV;
|
||||
}
|
||||
|
||||
step "s1-commit"
|
||||
|
|
@ -92,7 +92,7 @@ step "s2-print-content"
|
|||
SELECT
|
||||
nodeport, success, result
|
||||
FROM
|
||||
run_command_on_placements('test_table', 'select y from %s WHERE x = 5')
|
||||
run_command_on_placements('test_copy_placement_vs_modification', 'select y from %s WHERE x = 5')
|
||||
WHERE
|
||||
shardid IN (SELECT * FROM selected_shard)
|
||||
ORDER BY
|
||||
|
|
@ -104,7 +104,7 @@ step "s2-print-index-count"
|
|||
SELECT
|
||||
nodeport, success, result
|
||||
FROM
|
||||
run_command_on_placements('test_table', 'select count(*) from pg_indexes WHERE schemaname || ''.'' || tablename = ''%s''')
|
||||
run_command_on_placements('test_copy_placement_vs_modification', 'select count(*) from pg_indexes WHERE schemaname || ''.'' || tablename = ''%s''')
|
||||
ORDER BY
|
||||
nodeport;
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,13 +1,13 @@
|
|||
setup
|
||||
{
|
||||
CREATE TABLE test_table (test_id integer NOT NULL, data int);
|
||||
SELECT master_create_distributed_table('test_table', 'test_id', 'hash');
|
||||
SELECT master_create_worker_shards('test_table', 1, 2);
|
||||
CREATE TABLE test_dml_vs_repair (test_id integer NOT NULL, data int);
|
||||
SELECT master_create_distributed_table('test_dml_vs_repair', 'test_id', 'hash');
|
||||
SELECT master_create_worker_shards('test_dml_vs_repair', 1, 2);
|
||||
}
|
||||
|
||||
teardown
|
||||
{
|
||||
DROP TABLE IF EXISTS test_table CASCADE;
|
||||
DROP TABLE IF EXISTS test_dml_vs_repair CASCADE;
|
||||
}
|
||||
|
||||
session "s1"
|
||||
|
|
@ -15,9 +15,9 @@ session "s1"
|
|||
setup
|
||||
{
|
||||
DEALLOCATE all;
|
||||
TRUNCATE test_table;
|
||||
PREPARE insertone AS INSERT INTO test_table VALUES(1, 1);
|
||||
PREPARE insertall AS INSERT INTO test_table SELECT test_id, data+1 FROM test_table;
|
||||
TRUNCATE test_dml_vs_repair;
|
||||
PREPARE insertone AS INSERT INTO test_dml_vs_repair VALUES(1, 1);
|
||||
PREPARE insertall AS INSERT INTO test_dml_vs_repair SELECT test_id, data+1 FROM test_dml_vs_repair;
|
||||
}
|
||||
|
||||
step "s1-begin"
|
||||
|
|
@ -27,7 +27,7 @@ step "s1-begin"
|
|||
|
||||
step "s1-insertone"
|
||||
{
|
||||
INSERT INTO test_table VALUES(1, 1);
|
||||
INSERT INTO test_dml_vs_repair VALUES(1, 1);
|
||||
}
|
||||
|
||||
step "s1-prepared-insertone"
|
||||
|
|
@ -37,7 +37,7 @@ step "s1-prepared-insertone"
|
|||
|
||||
step "s1-insertall"
|
||||
{
|
||||
INSERT INTO test_table SELECT test_id, data+1 FROM test_table;
|
||||
INSERT INTO test_dml_vs_repair SELECT test_id, data+1 FROM test_dml_vs_repair;
|
||||
}
|
||||
|
||||
step "s1-prepared-insertall"
|
||||
|
|
@ -47,7 +47,7 @@ step "s1-prepared-insertall"
|
|||
|
||||
step "s1-display"
|
||||
{
|
||||
SELECT * FROM test_table WHERE test_id = 1;
|
||||
SELECT * FROM test_dml_vs_repair WHERE test_id = 1;
|
||||
}
|
||||
|
||||
step "s1-commit"
|
||||
|
|
@ -65,27 +65,27 @@ step "s2-begin"
|
|||
|
||||
step "s2-invalidate-57637"
|
||||
{
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57637;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57637;
|
||||
}
|
||||
|
||||
step "s2-revalidate-57637"
|
||||
{
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '1' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57637;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '1' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57637;
|
||||
}
|
||||
|
||||
step "s2-invalidate-57638"
|
||||
{
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57638;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '3' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57638;
|
||||
}
|
||||
|
||||
step "s2-revalidate-57638"
|
||||
{
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '1' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass) AND nodeport = 57638;
|
||||
UPDATE pg_dist_shard_placement SET shardstate = '1' WHERE shardid = (SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass) AND nodeport = 57638;
|
||||
}
|
||||
|
||||
step "s2-repair"
|
||||
{
|
||||
SELECT master_copy_shard_placement((SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_table'::regclass), 'localhost', 57638, 'localhost', 57637);
|
||||
SELECT master_copy_shard_placement((SELECT shardid FROM pg_dist_shard WHERE logicalrelid = 'test_dml_vs_repair'::regclass), 'localhost', 57638, 'localhost', 57637);
|
||||
}
|
||||
|
||||
step "s2-commit"
|
||||
|
|
|
|||
Loading…
Reference in New Issue