前面写过利用文件锁来处理高并发的问题的,现在我们说另外一个处理方式,利用MysqL的锁来解决高并发的问题
先看没有利用事务的时候并发的后果
创建库存管理表
创建订单管理表
测试代码
if($number>0)
{
$sql ="insert into order
VALUES (null,$number)";
$order_id = $pdo->query($sql);
if($order_id)
{
$<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>="update storage set `number`=`number`-1 WHERE id=1";
$pdo->query($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>);
}
}
我们预置库存是十个,然后执行ab测试查看结果
MysqL> select * from order
;
+----+--------+
| id | number |
+----+--------+
| 22 | 10 |
| 23 | 10 |
| 24 | 8 |
| 25 | 8 |
| 26 | 7 |
| 27 | 6 |
| 28 | 4 |
| 29 | 3 |
| 30 | 2 |
| 31 | 2 |
| 32 | 2 |
| 33 | 1 |
+----+--------+
12 rows in set (0.00 sec)
得到了订单共有12个,而库存表的库存也减到了-2,这显然不符合实际逻辑的;
if($number>0)
{
$sql ="insert into order
VALUES (null,$number)";
$order_id = $pdo->query($sql);
if($order_id)
{
$<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>="update storage set `number`=`number`-1 WHERE id=1";
if($pdo->query($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>))
{
$pdo->commit();//提交事务
}
else
{
$pdo->rollBack();//回滚
}
}
else
{
$pdo->rollBack();//回滚
}
}
查看结果
MysqL> select * from order
;
+----+--------+
| id | number |
+----+--------+
| 1 | 10 |
| 2 | 9 |
| 3 | 8 |
| 4 | 7 |
| 5 | 6 |
| 6 | 5 |
| 7 | 4 |
| 8 | 3 |
| 9 | 2 |
| 10 | 1 |
+----+--------+
10 rows in set (0.00 sec)