|
| 1 | +Bug #28733170 |
| 2 | +PERFORMANCE_SCHEMA.DATA_LOCKS DOES NOT HANDLE JOINS CORRECTLY |
| 3 | +CREATE TABLE t1( |
| 4 | +id INT PRIMARY KEY |
| 5 | +) Engine=InnoDB; |
| 6 | +BEGIN; |
| 7 | +INSERT INTO t1 VALUES (1),(2); |
| 8 | +SELECT * FROM t1 FOR UPDATE; |
| 9 | +id |
| 10 | +1 |
| 11 | +2 |
| 12 | +BEGIN; |
| 13 | +SET DEBUG_SYNC = 'lock_wait_will_wait SIGNAL C1_will_wait'; |
| 14 | +SELECT * FROM t1 WHERE id=1 FOR UPDATE; |
| 15 | +SET DEBUG_SYNC = 'now WAIT_FOR C1_will_wait'; |
| 16 | +CREATE TABLE t2 ( |
| 17 | +id INT PRIMARY KEY AUTO_INCREMENT, |
| 18 | +lock_id VARCHAR(200) NOT NULL |
| 19 | +) Engine=InnoDB; |
| 20 | +INSERT INTO t2 (lock_id) |
| 21 | +SELECT blocking_engine_lock_id |
| 22 | +FROM performance_schema.data_lock_waits; |
| 23 | +SELECT COUNT(*) FROM t2; |
| 24 | +COUNT(*) |
| 25 | +2 |
| 26 | +SELECT COUNT(t2.id) |
| 27 | +FROM t2 |
| 28 | +JOIN performance_schema.data_lock_waits dlw |
| 29 | +ON(dlw.blocking_engine_lock_id = t2.lock_id) |
| 30 | +ORDER BY t2.id; |
| 31 | +COUNT(t2.id) |
| 32 | +2 |
| 33 | +CREATE TABLE t3 ( |
| 34 | +id INT PRIMARY KEY AUTO_INCREMENT, |
| 35 | +lock_id VARCHAR(200) NOT NULL |
| 36 | +) Engine=InnoDB; |
| 37 | +INSERT INTO t3 (lock_id) |
| 38 | +SELECT requesting_engine_lock_id |
| 39 | +FROM performance_schema.data_lock_waits |
| 40 | +LIMIT 1; |
| 41 | +INSERT INTO t3 (lock_id) |
| 42 | +SELECT requesting_engine_lock_id |
| 43 | +FROM performance_schema.data_lock_waits |
| 44 | +LIMIT 1; |
| 45 | +SELECT COUNT(DISTINCT t3.id) |
| 46 | +FROM t3 |
| 47 | +JOIN performance_schema.data_lock_waits dlw |
| 48 | +ON(dlw.requesting_engine_lock_id = t3.lock_id) |
| 49 | +ORDER BY t3.id; |
| 50 | +COUNT(DISTINCT t3.id) |
| 51 | +2 |
| 52 | +SELECT COUNT(*) FROM performance_schema.data_lock_waits; |
| 53 | +COUNT(*) |
| 54 | +2 |
| 55 | +SELECT COUNT(*) |
| 56 | +FROM performance_schema.data_lock_waits |
| 57 | +JOIN performance_schema.data_locks r |
| 58 | +ON(r.engine_lock_id = requesting_engine_lock_id) |
| 59 | +JOIN performance_schema.data_locks b |
| 60 | +ON(b.engine_lock_id = blocking_engine_lock_id); |
| 61 | +COUNT(*) |
| 62 | +2 |
| 63 | +DROP TABLE t2; |
| 64 | +DROP TABLE t3; |
| 65 | +ROLLBACK; |
| 66 | +DROP TABLE t1; |
0 commit comments