我正在运行一些简单的脚本来测试我正在解决的完整性问题的可能解决方案。假设我有一张桌子my_table
|foo |
|1 |
我有这两个片段：
// db_slow.php
<?php
$db = new PDO('mysql:host=localhost;dbname=my_playground;charset=utf8', 'root', '');
echo 'starting transaction<br />';
$db->beginTransaction();
$stmt = $db->query('select * from my_table for update');
$rows = $stmt->fetchAll();
echo 'count tables: ', count($rows), '<br />';
if (count($rows) == 1) {
sleep(10);
$db->query('insert into my_table(foo) VALUES(2)');
}
$db->commit();
echo 'done';
// db_fast.php
<?php
$db = new PDO('mysql:host=localhost;dbname=my_plyaground;charset=utf8', 'root', '');
echo 'starting transaction<br />';
$db->beginTransaction();
$stmt = $db->query('select * from my_table for update');
$rows = $stmt->fetchAll();
echo 'count tables: ', count($rows), '<br />';
if (count($rows) == 1) {
$db->query('insert into my_table(foo) VALUES(3)');
}
$db->commit();
echo 'done';
db_slow.php有 10 秒的延迟来模拟竞态条件。
据我了解，select ... for update锁定它选择的所有行。如果我运行db_slowthen db_fast，db_fast也会有 10 秒的延迟，因为它正在等待db_slow我的预期。
但是，我没有得到的是输出：
// db_slow.php
starting transaction
count tables: 1
done
// db_fast.php
starting transaction
count tables: 2
done
和my_table
|foo |
|1 |
|2 |
据我了解，select ... for update锁定为该事务选择的所有行。所以这就是我所期望的：
- db_slow：选择第 1 行并锁定它
- db_slow：看到它只有 1 行并等待
- db_fast：尝试选择第1行，看到它被锁定，等待
- db_slow: 插入带有 '2' 的行
- db_fast：继续，因为第 1 行已解锁
- db_fast：只选择了 1 行，所以它插入 '3'
- 以结束
foo: 1, 2, 3
上面描述的输出和延迟似乎确认了步骤 1、2、3、4。似乎db_fast是在尝试获取锁后运行 select？我以为它会选择一行，然后锁定或等待。
有点相关的问题：
当我运行这个时，select ... lock in share mode我最终得到
// db_slow.php
starting transaction
count tables: 1
done
// db_fast.php
starting transaction
count tables: 1
done
和my_table
|foo |
|1 |
|3 |
为什么db_slow即使它认为表中只有 1 行（插入行的条件）也不插入行“2”？