数据库中的几种锁

数据库锁

image-20240103202955494

1.数据库锁的种类

以 mysql innoDB 为例,数据库的锁有 排他锁,共享锁,意向锁,自增锁,间隙锁,锁的范围有包括,行锁,表锁 ,区间锁。

从应用研发的视角,我们需要关注的主要是 排他锁,共享锁,以及锁的范围。其他如意向锁,自增所,间隙锁是mysql 内部在处理某些逻辑是自己处理的锁。

平时还有提到的悲观锁,乐观锁,在数据库层面上没有这个锁的概念,如果要做简单映射,悲观锁可以映射成排他锁,乐观锁是由应用层面保障的,和 DB 的锁概念无关。

排他锁

2.1. 介绍

排他锁是应用研发中用的最多的数据库锁了,收单、支付、金融,几乎任何一个系统都会使用到排他锁。

我们平常锁说的加锁,悲观锁,说的也就是数据库中的排他锁,排他锁也称为 X 锁(共享锁是 S 锁)如

<operation name="lock" paramtype="primitive" multiplicity="one" rawsql="true"><sql><![CDATA[select  xxx from table where id = ? for update]]></sql>
</operation>

select * from table where ? for update 会对于一条记录 / 一个区间 / 整表进行加锁。

在加锁之前,必须要开启事务,只有在事务中的 for update 语句才是有效的,对于一个事务,如果成功的获取了锁,那意味其他事务无法对于这条记录记录进行加排他锁、共享锁,无法更新,删除操作。不过可以做无锁查询。

所以如收单对于 iaqc_base 进行加锁之后,正常没有 for update 的查询是依旧可以进行的。

2.2. 使用场景

排他锁的使用场景在于,保证一张表的一致性,举例说明,以账务为例,用户A余额有 200 块,用户A支付了100块,余额 -100,与此同时,用户B给用户A转账50块,余额 +50,期望用户余额是 200 - 100 + 50 = 150。

期望是

如果在没有锁的情况下,结果是不确定的,可能是 250元,可能是 100元,也可能是 150 元。

事务1 用户支付 100 元,余额 -100线程3 用户收到转账 50 元,余额 + 50
select * from account where user = A返回用户余额为 200 元
判断余额是否足够,内存计算 200 - 100 = 100select * from account where user = A返回用户余额为 200 元
update account set balance = 100 where user = A更新余额为 100 元内存计算 200 + 50 = 250
commit;update account set balance = 250 where user = A更新余额为 250 元
commit;

如果增加了悲观锁,可以保证结果的一致性。

事务1 用户支付 100 元,余额 -100线程3 用户收到转账 50 元,余额 + 50
select * from account where user = A for update返回用户余额为 200 元
判断余额是否足够,内存计算 200 - 100 = 100select * from account where user = A for update
update account set balance = 100 where user = A更新余额为 100 元等待
commit;等待
返回用户余额为 100 元
内存计算 100 + 50 = 150
update account set balance = 150 where user = A更新余额为 150 元
commit;

悲观锁除了这个案例意外,在收单,支付等各种系统中都有使用,比如

  1. 收单:一个用户创建了一笔单据,进行了支付,支付回执比较慢,用户等的不耐烦了,关闭了订单。
  2. 支付:用户某一时刻对于一笔订单发起了多次退款

3.共享锁

3.1. 介绍

共享锁,S 锁,相对于悲观锁来说,是低一级的锁,若有事务对于某一条数据加了共享锁后,其他事务依旧可以增加共享锁,但是不能增加排他锁。

select * from table lock in share mode
共享锁(S)排它锁(X)
共享锁(S)允许不允许
排它锁(X)不允许不允许

3.2. 使用场景

共享锁的使用场景不多,在蚂蚁我没有找到使用共享锁的代码,只要是数据修改都是排他锁。

在 mysql 的官方文档中,排他锁是用来保证一张表中数据的一致性的,那共享锁是用来保证主从表的一致性的,举例:有用户表和用户联系人表,我们可以认为用户表示主表,联系人表示从表,在写入联系人的时候需要对用户表进行加锁,以免在写入的时候,联系人主记录被删除了。(在 ipay 用的排他锁)

这里排他锁和共享锁最大的区别在于如果对于用户表加的是排他锁,表示同一时刻只能一个事务写入联系人表,如果是共享锁,则同时可以多个事务写入联系人表。

共享锁案例:用户张三写入联系人李四和王五的两条记录。

事务1 写入联系人 李四写入联系人王五删除用户张三
select * from user lock in share mode where user id = ‘张三’select * from user lock in share mode where user id = ‘张三’delete from user where user_id = ‘张三’
insert into user_relation values(‘李四’)insert into user_relation values(‘王五’)等待
commit;commit;等待
commit;

3.3. 共享锁升级导致死锁

3.3.1. 共享锁升级

共享锁前面提到主要的使用场景在保持主表和从表之间的一致性,所以不建议在获得共享锁之后对于获得锁的数据进行更新操作,如果有更新操作的话,共享锁会升级成排他锁,可能会导致死锁。

3.3.2. 共享锁升级导致死锁

因为共享锁是可能会被多个事务同时获得的,如果在获得之后同时进行 update 则会产生死锁,举例:

2个事务同事获得用户余额的共享锁,并且进行金额操作

事务1 用户支付 100 元,余额 -100线程3 用户支付 50 元,余额 -50
select * from account where ? lock in share mode返回用户余额为 200 元
判断余额是否足够,内存计算 200 - 100 = 100select * from account where ? lock in share mode返回用户余额为 200 元
update account set balance = 100 where user = A更新余额为 100 元判断余额是否足够,内存计算 200 - 100 = 100
尝试锁升级成排他锁 等待事务 T2 共享锁释放update account set balance = 150 where user = A更新余额为 100 元
等待尝试锁升级成排他锁 等待事务 T1 释放
等待检测出死锁,事务失败,roll back
获得锁成功,更新成功
commit

3. 意向锁

意向锁 intention lock,分为 IS 共享意向锁 和 IX 排他意向锁。意向锁表示该表中有某一条记录被锁了,如果某条记录被加了排他锁,则该表上有 IX 锁,如果某条记录被加了共享锁,则该表上有 IS 锁,需要注意,意向锁是表级别的锁。

3.1. 意向锁要解决的问题

因为mysql 支持行锁和表锁,假设一张表中有一条记录被 T1 事务加了排他锁,T2 事务来加表锁的时候,应该是被阻塞。如果没有意向锁的情况下,mysql 需要循环该表的每一条记录,判断是否有加锁,最后才能得出能否加表锁,这个效率非常低。所以就有了意向锁。

当某一条记录被加锁的时候,会在表上先加意向锁,代表这个表中的某条记录被加锁了,那当其他事务来对表进行加锁的时候,只需要判断表上是否有意向锁,就可以判断出是否可以对表进行加锁。

3.2. 意向锁的互斥性

意向锁的互斥性IX 意向排他锁IS 意向共享锁
IX 意向排他锁兼容兼容
IS 意向共享锁兼容兼容

因为意向锁是代表这个表中的记录是否有增加排他锁和共享锁,所以对于意向锁之间是不会互斥的。

举例:

-- 在 user 表上增加 IX 锁 意向排他锁
-- 在 1 的聚簇索引上增加 X锁 排他锁
select * from user where id = 1 for update-- 在 user 表上增加 IX 锁 意向排他锁
-- 在 2 的聚簇索引上增加 X锁 排他锁
select * from user where id = 2 for update
意向锁的互斥性IX 意向排他锁IS 意向共享锁
X 排他锁 表级别阻塞阻塞
S 共享锁 表级别阻塞兼容

4. 间隙锁

4.1. 介绍

间隙锁,主要是解决 mysql 在可重复读的级别下部分幻读的问题。

间隙锁在范围查询加锁,或者查询不存在值加锁的时候会使用,用于锁定一定范围内的数据,防止其他事务写入,以来解决幻读的问题。

4.2. 间隙锁解决幻读原理

场景:假设有如下数据

1100105110120200

当我们开启事务 T1 执行 sql select * from table where id = 102 for update; 的时候,如果没有间隙锁,此事务不会加锁,如果此时 T2 事务写入了 id = 102 数据,T1 可能会出现如下问题

  1. 在写入同样的 id 会出现主键冲突(但是之前明明查过了没有数据)
  2. 在T2事务提交之后,再次执行查询会查到数据

这些都是幻读的体现。

mysql 默认在可重复读下通过间隙锁解决了这个问题,当执行上述 sql 时,会对 102 这个间隙加锁,加锁是左开右闭,为 (100, 105] (新版本的mysql 好像优化了这个细节,是左开右开,即 (100, 105) ) . 加了区间锁之后,其他的事务则无法写入或者修改这个区间之内的数据。举例:

在我们执行 select * from table where id = 102 for update; 之后,查看数据库中的锁,产生间隙锁,这个时候锁的范围 (100, 105)

在这里插入图片描述

产生间隙锁之后,我们期望是 (100, 105),所以 100 和 105 不会加锁,范围内的会加锁,下面的例子操作了 105 的 update 和 103 的写入,可以看到 105 的 update 可以成功,103 的写入会阻塞。

在这里插入图片描述

5. 自增锁

5.1. 介绍

自增锁是一种特殊的表级别锁(table-level lock),专门针对事务插入AUTO_INCREMENT 自增类型的列。最简单的情况,如果一个事务正在往表中插入记录,所有其他事务的插入必须等待,以便第一个事务插入的行,是连续的主键值。

自增锁的分配有传统模式,连续模式,和交叉模式

image-20240103203611898

5.2. 自增锁可能不连续的情况

举例:有 user 表,有2个字段,1. id 自增列 2. name varchar

事务1事务2
begin;
insert into user values (‘A’);begin;
select * from user; | id | name|| 1 | A |insert into user values (‘B’);
insert into user values (‘C’);comit;
select * from user; | id | name || 1 | A || 3 | C |
commit;
select * from user;| id | name | | 1 | A || 2 | B || 3 | C |select * from user;| id | name | | 1 | A || 2 | B || 3 | C |

6.行级锁

行级锁是一种排他锁,防止其他事务修改此行;在使用以下语句时,Oracle 会自动应用行级锁:

  1. INSERT、UPDATE、DELETE、SELECT … FOR UPDATE [OF columns] [WAIT n | NOWAIT];
  2. SELECT … FOR UPDATE 语句允许用户一次锁定多条记录进行更新
  3. 使用 COMMIT 或 ROLLBACK 语句释放锁。

7.表级锁

表示对当前操作的整张表加锁,它实现简单,资源消耗较少,被大部分 MySQL 引擎支持。最常使用的 MYISAM 与 INNODB 都支持表级锁定。表级锁定分为表共享读锁(共享锁)与表独占写锁(排他锁)。

8.页级锁

页级锁是 MySQL 中锁定粒度介于行级锁和表级锁中间的一种锁。表级锁速度快,但冲突多,行级冲突少,但速度慢。所以取了折衷的页级,一次锁定相邻的一组记录。BDB 支持页级锁

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/594541.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

C++:第十一讲DFS深搜

Everyday English Your optimal career is simply this: Share the real you with physical world through th e process of creative self-expression. 你的最佳职业很简单&#xff0c;就是这样&#xff1a;通过创造性自我表达的途径和世界分享真实的你。 前言 今天带着大家…

一元函数微分学——刷题(14

目录 1.题目&#xff1a;2.解题思路和步骤&#xff1a;3.总结&#xff1a;小结&#xff1a; 1.题目&#xff1a; 2.解题思路和步骤&#xff1a; 只要知道反函数求导等于原函数的导数的倒数&#xff0c;那就很好求解了&#xff0c;这不过要先处理好x和y的对应关系&#xff0c;知…

本地套接字通信

本地套接字&#xff08;Unix域套接字&#xff09;是用于在同一台机器上的进程之间进行通信的一种方式。它不涉及网络协议&#xff0c;而是直接在文件系统中创建一个套接字文件&#xff0c;进程可以通过该文件进行通信。 本地套接字的作用&#xff1a;本地的进程间通信 有关系的…

语音AI小夜灯项目

一、项目简介 使用ESP32-S3N8R8模块作为主控芯片&#xff0c;S3内核增加了用于加速神经网络计算和信号处理等的指令&#xff0c;这使得我们可以使用它来快速解析训练好的语音模型进行语音识别的功能。 二、原理解析 本项目由四个部分组成&#xff0c;电源部分、LED照明部分、…

uniapp二维码有效期倒计时三分钟的效果是实现

需求&#xff1a; 会员码时效只有3分钟有效期&#xff0c;需要在页面倒计时3分钟&#xff0c;没有长按保存的效果实现 效果&#xff1a; 代码&#xff1a; <templete> <view> <uni-list> <view class"custom-list-item" click"onCode(c…

java代码规范(适合写程序之前先了解有助于开发协同)

目录 一、类定义 二、方法定义 三、接口定义 四、变量定义 1、命名规范&#xff1a; 2、类型规范&#xff1a; 3、常量规范&#xff1a; 五、static关键字 1、静态变量&#xff08;类变量&#xff09;&#xff1a; 2、静态方法&#xff08;类方法&#xff09;&#x…

AUTOSAR软件手册文档缩写描述,AUTOSAR_TR_PredefinedNames

由于AUTOSAR文档中的缩写太多&#xff0c;入门者看起开不方便。例如TR、SWS、SRS、EXP模块。 下载链接&#xff1a;https://www.autosar.org/fileadmin/standards/R21-11/FO/AUTOSAR_TR_PredefinedNames.pdf

android——自定义TextView

效果展示&#xff1a; 代码解析&#xff1a; 1、首先设置自定义属性&#xff08;res/values下新建一个attrs.xml文件&#xff09; <?xml version"1.0" encoding"utf-8"?> <resources><!-- name 自定义view的名字 CustomTextView--&…

Spring Bean的生命周期(钩子函数)

借鉴&#xff1a;https://www.cnblogs.com/liweimingbk/p/17843970.html https://blog.csdn.net/lxz352907839/article/details/128634404 一、Spring Bean生命周期 如果Spring配置文件中所定义的Bean类实现了ApplicationContextAware 接口&#xff0c;那么在加载Spring配置文…

Flood Fill算法总结

算法思想 从一个起点开始&#xff0c;每一次随机选择一个新加进来的格子&#xff0c;看一下它周围能否扩展新的格子。如果能扩展&#xff0c;那么就扩展进来&#xff0c;直到不能扩展新的格子为止。当然需要判重&#xff0c;同样一个格子只能覆盖一次&#xff0c;这样能够保证时…

DataLoader与Dataset

一、人民币二分类 二、DataLoader 与 Dataset DataLoader torch.utils.data.DataLoader 功能&#xff1a;构建可迭代的数据装载器 &#xff08;只标注了较为重要的&#xff09; • dataset: Dataset类&#xff0c;决定数据从哪读取及如何读取 • batchsize : 批大小 • num_…

机器学习异常值处理 逻辑汇总一

一 清除数据中恒定不变值 如果某个数据长时间不变&#xff0c;默认异常&#xff0c;清除掉该部分数据&#xff1a; # 使用 shift 和 cumsum 来创建一个分组键&#xff0c;每次值改变都会增加组号 g (df[沉淀池3号进水流量] ! df[沉淀池3号进水流量].shift()).cumsum()# 使用…

案例253:基于微信小程序的懂球短视频管理系统

文末获取源码 开发语言&#xff1a;Java 框架&#xff1a;SpringBoot JDK版本&#xff1a;JDK1.8 数据库&#xff1a;mysql 5.7 开发软件&#xff1a;eclipse/myeclipse/idea Maven包&#xff1a;Maven3.5.4 小程序框架&#xff1a;uniapp 小程序开发软件&#xff1a;HBuilder …

GC8549 大电流,双通道 12V,短地短电源保护等功能 可替代ONSEMI的LV8548/LV8549

GC8549 可以工作在 3.8~12V 的电源电压上&#xff0c;每 通道能提供高达 1.5A 持续输出电流或者 2.5A 峰值 电流&#xff0c;睡眠模式下功耗小于 1uA。具有 PWM&#xff08;IN/EN&#xff09;输入接口,与行业标 准器件兼容&#xff0c;并具有过温保护&#xff0c;欠压保护&…

【计算机网络】网络层

文章目录 网络层提供的服务虚电路数据报服务虚电路与数据报服务比较 虚拟互连网络IP地址IP层次结构IP地址分类特殊地址子网掩码 子网划分变长子网划分超网合并网络规律 IP地址与MAC地址ARP协议ARP欺骗的应用 数据包数据包首部 路由ICMP协议RIP动态路由协议OSPF协议BGP协议 VPNN…

进程等待(wait和wait函数)【Linux】

进程等待 wait和wait函数【Linux】 进程等待的概念进程等待的必要性进程等待的方法wait函数waitpid函数 非阻塞等待和阻塞等待的对比阻塞等待&#xff1a;非阻塞等待 进程等待的概念 进程等待就是通过 wait/waitpid的方式&#xff0c;让父进程对子进程进行等待子进程退出并且将…

【信号处理:小波包转换(WPT)/小波包分解(WPD) 】

【信号处理&#xff1a;小波包转换&#xff08;WPT&#xff09;/小波包分解&#xff08;WPD&#xff09; 】 小波包变换简介WPT/WPD的基础知识WPT/WPD的主要特点The Wavelet Packet Transform 小波包变换前向小波数据包变换最佳基础和成本函数数学中波纹的最佳基础其他成本函数…

酷狗高级Java面试真题

今年IT寒冬&#xff0c;大厂都裁员或者准备裁员&#xff0c;作为开猿节流主要目标之一&#xff0c;我们更应该时刻保持竞争力。为了抱团取暖&#xff0c;林老师开通了《知识星球》&#xff0c;并邀请我阿里、快手、腾讯等的朋友加入&#xff0c;分享八股文、项目经验、管理经验…

洛谷普及组P1044栈,题目讲解(无数论基础,纯打表找规律)

[NOIP2003 普及组] 栈 - 洛谷 我先写了个打表的代码&#xff0c;写了一个小时&#xff0c;o(╥﹏╥)o只能说我真不擅长dfs。 int n; std::unordered_map<std::string, int>map; void dfs(std::vector<int>&a, int step,std::stack<int>p, std::string …

Nginx中include配置文件,方便管理多域名

目录 1.加上include配置 2.配置 server 记录 一个网站对应一个server 记录&#xff0c;这样管理起来相对麻烦。我们可以将每个网站记录单独拆分出来即可&#xff0c;这就需要用到 nginx 中的 conf.d 文件 1.加上include配置 先进入到 nginx.conf 文件&#xff0c;然后将所有…