MySQL的锁应该怎么用(一)

先说重点:

  1. 锁是为了固化资源状态的,加锁之后一定会有状态判断(或加锁语句的条件里含有这个),只加锁不判断状态,那这个锁就没啥用。
  2. 如果你加了锁,但是后边并没有回滚机制,那你就要考虑下你代码的逻辑是不是有问题了。
  3. 代码要有自检的功能,第一不能相信用户,第二不能相信调用你函数的其它程序员。尽量保证你的代码在被重复执行时不会出现问题(要不你就保证你这段代码绝对不会遇到并发)。
  4. 写完任何一个函数或者脚本,都要想一个问题“如果这段代码被并发执行两次,会有问题么?”。

关于MySQL的锁和事务的基本概念,锁的种类和隔离级别等,大家都可以查到,我面试别人的时候,也常常问相关的问题,但是我发现有时候大家概念很熟,但是用起来却有诸多问题。

咱们从两个简单的问题开始:

  1. 事务的作用是什么?
  2. MySQL里怎么简单的锁一行(排他锁)?

这两个很基础的问题大家不妨先自己尝试回答一下。

1参考答案:事务的作用是为了保持一系列SQL执行的原子性,同一个事务中的SQL语句,要不就都执行,要不就都不执行。一般大家都会举银行转账的例子。

2参考答案:第一,须是innodb引擎;第二,开事务;第三 SELECT * FROM t WHERE id = 111 FOR UPDATE(行锁的条件必须为主键或者索引列,如果不是索引列,那将产生表锁。主键和唯一索引那就是锁一行)。

上边的问题很多人都清楚,或者查一查也能查出来,但是,在日常使用的时候,我总发现大家会犯各种各样的错误,综合原因,那就是“不能从逻辑上明白事务和锁到底要做哪些事情,资源竞争到底是应该怎么做”。

举个例子:
电商相关的项目有个最基本的问题,一件商品有一定的库存量,代码怎么写才能保证这个商品不超售。
比如product表结构是这样的:id, product_name, count,其中count为库存量。
当有人购买之后,需要更新这个表里的库存量,都执行这个SQL:

$sql = "SELECT * FROM product WHERE id = xxx";
$row = $connection->createCommand($sql)->queryRow();
if ($row[count] <= 0) {
  return false;
}

$sql = "UPDATE product SET count = count - 1 WHERE id = xxx";
$connection->createCommand($sql)->execute();
return true;

大家都知道,在没有锁的情况下,如果出现并发请求(别问我并发是怎么出现的),更新结果就会有问题,大家都知道加锁,但是我发现有人这这么加的

// 错误用法,请勿模仿
$sql = "SELECT * FROM product WHERE id = xxx";
$row = $connection->createCommand($sql)->queryRow();
if ($row[count] <= 0) {
  return false;
}

$transaction = $connection->beginTransaction(); // 开事务
$sql = "SELECT * FROM product WHERE id = xxx FOR UPDATE";
$row = $connection->createCommand($sql)->queryRow();
$sql = "UPDATE product SET count = count - 1 WHERE id = xxx";
$connection->createCommand($sql)->execute();
$transaction->commit(); // 提交事务
return true;

上边代码这个锁加的有什么意义么?并没有!!!
请记住:
状态判断一定要在加锁之后
所以正确的写法应该是:

// 1. 开事务
$transaction = $connection->beginTransaction(); 
// 2. 给要更新的资源加锁
$sql = "SELECT * FROM product WHERE id = xxx FOR UPDATE";
$row = $connection->createCommand($sql)->queryRow();
// 3. 判断资源状态
if ($row['count'] <= 0) {
  // 事务回滚
  $transaction->rollback();
  return false;
}
// 4. 更新数据
$sql = "UPDATE product SET count = count - 1 WHERE id = xxx";
$connection->createCommand($sql)->execute();
// 5. 提交事务
$transaction->commit(); // 提交事务
return true;

锁的存在是为了解决并发的,所谓并发就是多个请求要同时操作同一个资源,锁就是在这种资源竞争的环境中产生的,先给资源加上锁的请求,就优先完成自己的操作,在锁被释放之前,其它的请求都得等着,卡在加锁那一步。找准你要锁的资源是重中之重。

再举一个例子:在支付场景中,你创建了一条订单,在订单状态更新为成功之后,你同时要更新用户的余额,有时候有人犯错就会这么写:

// 错误示范,请勿模仿
// 开事务
$transaction = $connection->beginTransaction();
$sql = "SELECT * FROM order WHERE id = xxx";
$order = $connection->createCommand($sql)->queryRow();
// 判断订单状态
if ($order['status'] != 0) {
  $transaction->rollback();
  return false;
}
// 为要更新的 account 记录加锁
$sql = "SELECT * FROM account WHERE id = xxxxx FOR UPDATE";
$account = $connection->createCommand($sql)->queryRow();
// 更新account记录
$sql = "UPDATE account set balance = balance - 50 WHERE id = xxxxx";
$connection->createCommand($sql)->execute();
// 更新订单状态
$sql = "UPDATE order SET status = 1 WHERE id = xxx";
$connection->createCommand($sql)->execute();

// 提交事务
$transaction->commit();

上边代码的问题在哪儿?没有搞清楚你要竞争的资源是什么!虽然你要更新account表,但是你要竞争的资源其实是order表中的那一行。所以正确的做法应该是:

// 开事务
$transaction = $connection->beginTransaction();
// 为order记录加锁
$sql = "SELECT * FROM order WHERE id = xxx FOR UPDATE";
$order = $connection->createCommand($sql)->queryRow();
// 判断订单状态
if ($order['status'] != 0) {
  $transaction->rollback();
  return false;
}
// 更新订单状态
$sql = "UPDATE order SET status = 1 WHERE id = xxx";
$connection->createCommand($sql)->execute();
// 为要更新的 account 记录加锁(这一笔其实没有什么必要,不过有个小坑,下一篇文章里再讲)
$sql = "SELECT * FROM account WHERE id = xxxxx FOR UPDATE";
$account = $connection->createCommand($sql)->queryRow();
// 更新account记录
$sql = "UPDATE account set balance = balance - 50 WHERE id = xxxxx";
$connection->createCommand($sql)->execute();

// 提交事务
$transaction->commit();

综上,其实用好锁,就是要搞清楚整个资源竞争和状态判断的逻辑。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 202,607评论 5 476
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,047评论 2 379
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 149,496评论 0 335
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,405评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,400评论 5 364
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,479评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,883评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,535评论 0 256
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,743评论 1 295
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,544评论 2 319
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,612评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,309评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,881评论 3 306
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,891评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,136评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,783评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,316评论 2 342

推荐阅读更多精彩内容