mirror of
https://github.com/MariaDB/server.git
synced 2025-01-29 02:05:57 +01:00
MDEV-16690 node hang due to conflicting inserts in FK child table
Add the test case. The actual bug was fixed in MDEV-17541. Closes #811
This commit is contained in:
sjaakola
Marko Mäkelä
parent
662217a592
commit
61b600079b
2 changed files with 541 additions and 0 deletions
|
|
@ -0,0 +1,380 @@
|
|||
CREATE TABLE user(id int primary key, j int) ENGINE=InnoDB;
|
||||
CREATE TABLE user_session(id int primary key, fk1 int, fk2 int) ENGINE=InnoDB;
|
||||
alter table user_session add foreign key (fk1) references user(id);
|
||||
INSERT INTO user values (1,0), (2,0), (3,0), (4,0);
|
||||
INSERT INTO user_session values (1,1,1);
|
||||
connect node_1_u, 127.0.0.1, root, , test, $NODE_MYPORT_1;
|
||||
connect node_1_i, 127.0.0.1, root, , test, $NODE_MYPORT_1;
|
||||
connect node_2_i, 127.0.0.1, root, , test, $NODE_MYPORT_2;
|
||||
"Phase 1: plain SQL statements"
|
||||
connection node_1;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
update user set j = j + 1 WHERE id > 0;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 2);
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 3);
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
update user set j = j + 1 WHERE id > 0;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 2);
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 3);
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
update user set j = j + 1 WHERE id > 0;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 2);
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 3);
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
update user set j = j + 1 WHERE id > 0;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 2);
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 3);
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
update user set j = j + 1 WHERE id > 0;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 2);
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 3);
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
update user set j = j + 1 WHERE id > 0;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 2);
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 3);
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
update user set j = j + 1 WHERE id > 0;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 2);
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 3);
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
update user set j = j + 1 WHERE id > 0;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 2);
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 3);
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
update user set j = j + 1 WHERE id > 0;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 2);
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 3);
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
update user set j = j + 1 WHERE id > 0;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 2);
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 3);
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
"Phase 2: prepared statements"
|
||||
connection node_1_u;
|
||||
prepare upd from 'update user set j = j + 1 WHERE id > 0';
|
||||
connection node_1_i;
|
||||
prepare ins1 from 'insert into user_session(id,fk1,fk2) values (2, 2, 2)';
|
||||
connection node_2_i;
|
||||
prepare ins2 from 'insert into user_session(id,fk1,fk2) values (2, 2, 3)';
|
||||
connection node_1;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
execute upd;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
execute ins1;
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
execute ins2;
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
execute upd;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
execute ins1;
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
execute ins2;
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
execute upd;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
execute ins1;
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
execute ins2;
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
execute upd;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
execute ins1;
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
execute ins2;
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
execute upd;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
execute ins1;
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
execute ins2;
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
execute upd;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
execute ins1;
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
execute ins2;
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
execute upd;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
execute ins1;
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
execute ins2;
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
execute upd;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
execute ins1;
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
execute ins2;
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
execute upd;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
execute ins1;
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
execute ins2;
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1_u;
|
||||
begin;
|
||||
execute upd;
|
||||
connection node_1_i;
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
execute ins1;
|
||||
connection node_1;
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
connection node_2_i;
|
||||
execute ins2;
|
||||
connection node_1;
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
connection node_1_i;
|
||||
connection node_1_u;
|
||||
commit;
|
||||
connection node_1;
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
connection node_1;
|
||||
drop table user_session,user;
|
||||
161
mysql-test/suite/galera/t/galera_FK_duplicate_client_insert.test
Normal file
161
mysql-test/suite/galera/t/galera_FK_duplicate_client_insert.test
Normal file
|
|
@ -0,0 +1,161 @@
|
|||
--source include/have_innodb.inc
|
||||
--source include/have_debug.inc
|
||||
--source include/have_debug_sync.inc
|
||||
--source include/galera_cluster.inc
|
||||
#
|
||||
# This test will reproduce regressions of bugs
|
||||
# https://github.com/codership/mysql-wsrep/issues/335
|
||||
# https://github.com/codership/mysql-wsrep/issues/336
|
||||
#
|
||||
# The test will issue duplicate inserts into a table, which has foreign key
|
||||
# constraint for a parent table.
|
||||
# The inserts happen in separate nodes, and the
|
||||
# The test outline is as follows:
|
||||
# 1. in node 1, an update is done for the FK parent row, in a transaction,
|
||||
# which is left open. The purpose of this is just to establish a X lock on
|
||||
# the parent row.
|
||||
# 2. in node 1, an insert for the child table is sent. The insert will have to wait
|
||||
# for the parent row X lock, because it needs S lock on the same row.
|
||||
# However, we have set an DBUG sync point just before the insert will call for
|
||||
# innodb suspend
|
||||
# 3. in node 2, a similar insert is issued. This will replicate to node 1 and try to
|
||||
# abort the conflicting update and blocked insert
|
||||
# 4. the inserts dbug sync point is relased, and insert should continue and abort
|
||||
# gracefully
|
||||
# 5. update is continued to commit, and it should also observe the deadlock
|
||||
#
|
||||
# This test is run in 3 phases:
|
||||
#
|
||||
# 1. with plain SQL statement
|
||||
# 2. as SQL prepared statements
|
||||
# 3. as SQl stored procedures
|
||||
#
|
||||
# The test phase 3 is for reproducing the issue in bug #336 specifically
|
||||
#
|
||||
|
||||
#
|
||||
# create the test tables and foreign key constraint between them
|
||||
#
|
||||
CREATE TABLE user(id int primary key, j int) ENGINE=InnoDB;
|
||||
CREATE TABLE user_session(id int primary key, fk1 int, fk2 int) ENGINE=InnoDB;
|
||||
alter table user_session add foreign key (fk1) references user(id);
|
||||
|
||||
# populate a few initial rows
|
||||
INSERT INTO user values (1,0), (2,0), (3,0), (4,0);
|
||||
INSERT INTO user_session values (1,1,1);
|
||||
|
||||
#
|
||||
# prepare test connections, for:
|
||||
# update of parent row in node1
|
||||
# insert of child row in node1
|
||||
# insert of child row in node2
|
||||
|
||||
--connect node_1_u, 127.0.0.1, root, , test, $NODE_MYPORT_1
|
||||
--connect node_1_i, 127.0.0.1, root, , test, $NODE_MYPORT_1
|
||||
--connect node_2_i, 127.0.0.1, root, , test, $NODE_MYPORT_2
|
||||
|
||||
|
||||
#
|
||||
# test phase 1: plain SQL statements
|
||||
#
|
||||
--echo "Phase 1: plain SQL statements"
|
||||
|
||||
|
||||
--connection node_1
|
||||
let $counter=10;
|
||||
let $sleep_period=1;
|
||||
|
||||
while($counter > 0)
|
||||
{
|
||||
--connection node_1_u
|
||||
begin;
|
||||
update user set j = j + 1 WHERE id > 0;
|
||||
|
||||
--connection node_1_i
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
send insert into user_session(id,fk1,fk2) values (2, 2, 2);
|
||||
|
||||
--connection node_1
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
|
||||
--connection node_2_i
|
||||
insert into user_session(id,fk1,fk2) values (2, 2, 3);
|
||||
|
||||
--connection node_1
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
|
||||
--connection node_1_i
|
||||
--error 0,ER_LOCK_DEADLOCK,ER_DUP_ENTRY
|
||||
reap;
|
||||
|
||||
--connection node_1_u
|
||||
--error 0,ER_LOCK_DEADLOCK
|
||||
commit;
|
||||
|
||||
--connection node_1
|
||||
--error 0,ER_LOCK_DEADLOCK
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
|
||||
dec $counter;
|
||||
}
|
||||
|
||||
#
|
||||
# test phase 2: prepared statements
|
||||
#
|
||||
--echo "Phase 2: prepared statements"
|
||||
|
||||
--connection node_1_u
|
||||
prepare upd from 'update user set j = j + 1 WHERE id > 0';
|
||||
|
||||
--connection node_1_i
|
||||
prepare ins1 from 'insert into user_session(id,fk1,fk2) values (2, 2, 2)';
|
||||
|
||||
--connection node_2_i
|
||||
prepare ins2 from 'insert into user_session(id,fk1,fk2) values (2, 2, 3)';
|
||||
|
||||
--connection node_1
|
||||
let $counter=10;
|
||||
let $sleep_period=1;
|
||||
|
||||
while($counter > 0)
|
||||
{
|
||||
--connection node_1_u
|
||||
begin;
|
||||
execute upd;
|
||||
#update user set j = j + 1 WHERE id > 0;
|
||||
|
||||
--connection node_1_i
|
||||
set debug_sync='lock_wait_suspend_thread_enter SIGNAL ins_waiting WAIT_FOR cont_ins';
|
||||
send execute ins1;
|
||||
|
||||
--connection node_1
|
||||
set debug_sync='now WAIT_FOR ins_waiting';
|
||||
|
||||
--connection node_2_i
|
||||
execute ins2;
|
||||
|
||||
--connection node_1
|
||||
set debug_sync='now SIGNAL cont_ins';
|
||||
|
||||
--connection node_1_i
|
||||
--error 0,ER_LOCK_DEADLOCK,ER_DUP_ENTRY
|
||||
reap;
|
||||
|
||||
--connection node_1_u
|
||||
--error 0,ER_LOCK_DEADLOCK
|
||||
commit;
|
||||
|
||||
--connection node_1
|
||||
|
||||
--error 0,ER_LOCK_DEADLOCK
|
||||
truncate user_session;
|
||||
set debug_sync = reset;
|
||||
|
||||
dec $counter;
|
||||
}
|
||||
|
||||
|
||||
--connection node_1
|
||||
|
||||
drop table user_session,user;
|
||||
Loading…
Add table
Reference in a new issue