external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add isolation tests

fix/distributed_deadlock1
Sait Talha Nisanci 2021-08-06 13:23:54 +03:00
parent 7ca6794706
commit 5d51333ebc
3 changed files with 123 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

61
src/test/regress/expected/isolation_partition.out Normal file
View File

@ -0,0 +1,61 @@
Parsed test spec with 2 sessions
starting permutation: s1-begin s1-update s2-drop s1-commit
step s1-begin:
BEGIN;
step s1-update:
update test_9_1 set destination = 1;
step s2-drop:
drop table test_6_1;
<waiting ...>
step s1-commit:
COMMIT;
step s2-drop: <... completed>
starting permutation: s2-begin s2-drop s1-update s2-commit
step s2-begin:
BEGIN;
step s2-drop:
drop table test_6_1;
step s1-update:
update test_9_1 set destination = 1;
<waiting ...>
step s2-commit:
COMMIT;
step s1-update: <... completed>
starting permutation: s1-begin s1-update s2-create s1-commit
step s1-begin:
BEGIN;
step s1-update:
update test_9_1 set destination = 1;
step s2-create:
CREATE TABLE test_10_1 PARTITION OF test FOR VALUES FROM ('10', '2021-07-16') TO ('11', '2021-07-17');
<waiting ...>
step s1-commit:
COMMIT;
step s2-create: <... completed>
starting permutation: s2-begin s2-create s1-update s2-commit
step s2-begin:
BEGIN;
step s2-create:
CREATE TABLE test_10_1 PARTITION OF test FOR VALUES FROM ('10', '2021-07-16') TO ('11', '2021-07-17');
step s1-update:
update test_9_1 set destination = 1;
<waiting ...>
step s2-commit:
COMMIT;
step s1-update: <... completed>

1
src/test/regress/isolation_schedule
View File

@ -65,6 +65,7 @@ test: isolation_multiuser_locking
test: shared_connection_waits
test: isolation_cancellation
test: isolation_undistribute_table
test: isolation_partition
# Rebalancer
test: isolation_blocking_move_single_shard_commands

61
src/test/regress/spec/isolation_partition.spec Normal file
View File

@ -0,0 +1,61 @@
setup
{
SET citus.shard_replication_factor to 1;
CREATE TABLE test(
time date,
id bigint,
name character varying,
destination bigint) PARTITION BY RANGE (id, time);
SELECT create_distributed_table('test', 'name');
CREATE TABLE test_6_1 PARTITION OF test FOR VALUES FROM ('6', '2021-07-12') TO ('6', '2021-07-13');
CREATE TABLE test_7_1 PARTITION OF test FOR VALUES FROM ('7', '2021-07-13') TO ('8', '2021-07-14');
CREATE TABLE test_8_1 PARTITION OF test FOR VALUES FROM ('8', '2021-07-14') TO ('9', '2021-07-15');
CREATE TABLE test_9_1 PARTITION OF test FOR VALUES FROM ('9', '2021-07-15') TO ('10', '2021-07-16');
}
teardown
{
DROP TABLE IF EXISTS test CASCADE;
}
session "s1"
step "s1-begin" {
BEGIN;
}
step "s1-update" {
update test_9_1 set destination = 1;
}
step "s1-commit" {
COMMIT;
}
session "s2"
step "s2-begin" {
BEGIN;
}
step "s2-drop" {
drop table test_6_1;
}
step "s2-create" {
CREATE TABLE test_10_1 PARTITION OF test FOR VALUES FROM ('10', '2021-07-16') TO ('11', '2021-07-17');
}
step "s2-commit" {
COMMIT;
}
permutation "s1-begin" "s1-update" "s2-drop" "s1-commit"
permutation "s2-begin" "s2-drop" "s1-update" "s2-commit"
permutation "s1-begin" "s1-update" "s2-create" "s1-commit"
permutation "s2-begin" "s2-create" "s1-update" "s2-commit"