mysql 悲观锁使用

2024-08-25 18:28
文章标签 mysql 使用 database 悲观

本文主要是介绍mysql 悲观锁使用,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

悲观锁是一种数据库锁定机制,它假设每次操作都会发生并发冲突,因此在执行任何需要读取或写入数据的操作之前,先获取锁,防止其他事务对该数据进行修改。悲观锁确保了操作的独占性,以防止数据被其他事务同时修改,从而保证数据的一致性。

悲观锁分为两种:
1、共享锁(S锁):允许多个事务同时读取数据,但不能修改数据。
2、排他锁(X锁):禁止其他事务读取或修改数据,只有获取锁的事务可以操作数据。
使用场景:适用于并发度较高的场景,尤其是在可能发生数据冲突的情况下。
MySQL中,悲观锁通常是通过 SELECT ... FOR UPDATESELECT ... LOCK IN SHARE MODE 来实现的

1、 排他锁(Exclusive Lock, X锁)

场景:你想读取某条记录并在后续操作中修改它,确保在此期间没有其他事务可以读取或修改这条记录。比如:银行转账、库存管理、订单系统中的竞价 、避免重复处理的任务调度

一、银行转账

在银行系统中,确保用户账户余额的正确性至关重要。例如,进行转账时需要确保读取的余额在更新之前不会被其他事务修改。
假设我们有一个 accounts 表,存储用户的账户信息,包括 id、balance 等字段。用户从一个账户转账到另一个账户。

START TRANSACTION;-- 查询并锁定源账户的余额
SELECT balance FROM accounts WHERE id = 1 FOR UPDATE;-- 确保余额足够
-- (在应用程序中检查)
-- 假设 balance > 100-- 执行扣款操作
UPDATE accounts SET balance = balance - 100 WHERE id = 1;-- 查询并锁定目标账户的余额
SELECT balance FROM accounts WHERE id = 2 FOR UPDATE;-- 执行存款操作
UPDATE accounts SET balance = balance + 100 WHERE id = 2;COMMIT;

FOR UPDATE 确保在读取源账户的余额后,该余额不会被其他事务修改,避免了在扣款操作中可能发生的并发问题。

二、 库存管理

在库存管理系统中,确保在查询库存和更新库存数量之间没有其他事务干扰,避免超卖或库存不足的情况。

场景:
一个电子商务网站在处理用户订单时,需要确保产品库存足够并且在处理订单时不被其他订单处理影响。

START TRANSACTION;-- 查询并锁定产品库存
SELECT stock FROM products WHERE product_id = 101 FOR UPDATE;-- 确保库存足够
-- (在应用程序中检查)
-- 假设 stock >= 1-- 执行减库存操作
UPDATE products SET stock = stock - 1 WHERE product_id = 101;COMMIT;

FOR UPDATE 确保在读取产品库存后,库存数据在减库存之前不会被其他事务改变,从而避免库存数据的不一致问题。

三、订单系统中的竞价

在竞价系统中,多个用户可能会同时对同一商品进行竞价。需要确保在读取当前最高竞价后进行更新时,竞价数据不会被其他竞价操作影响。

场景:

一个在线拍卖系统允许多个用户同时对一个商品进行竞价。系统需要确保在更新最高竞价时没有其他用户同时进行操作。

START TRANSACTION;-- 查询并锁定当前最高出价
SELECT max_bid FROM bids WHERE item_id = 123 FOR UPDATE;-- 确保当前出价超过了最高出价
-- (在应用程序中检查)
-- 假设 max_bid < 500-- 更新最高出价
UPDATE bids SET max_bid = 500, bidder_id = 10 WHERE item_id = 123;COMMIT;

FOR UPDATE 确保在读取当前最高出价后,没有其他竞价操作在此时更新该数据,避免了竞价结果的不一致性。

四、 避免重复处理的任务调度

在任务调度系统中,可能需要从任务表中选择一个待处理的任务并将其标记为已处理,避免多个调度器同时处理同一个任务。
有一个 tasks 表,存储了多个待处理的任务,多个调度器(或工作线程)从中获取任务来处理。

START TRANSACTION;-- 查询并锁定一个待处理任务
SELECT id FROM tasks WHERE status = 'pending' LIMIT 1 FOR UPDATE;-- 更新任务状态为处理中
UPDATE tasks SET status = 'processing' WHERE id = 1;COMMIT;

FOR UPDATE 确保在查询到待处理任务后,没有其他调度器在此时获取同一个任务并进行处理,避免了任务重复处理的情况。

2、共享锁(Shared Lock, S锁)

一、只读操作中的一致性保障

场景:

在报表生成或分析过程中,需要从多个表中读取数据,确保在读取期间数据不会被其他事务修改,以防止数据不一致。

START TRANSACTION;-- 对数据加共享锁,确保读取期间数据不被修改
SELECT balance FROM accounts WHERE id = 1 LOCK IN SHARE MODE;-- 执行其他读取操作或分析
SELECT * FROM transactions WHERE account_id = 1 LOCK IN SHARE MODE;COMMIT;

LOCK IN SHARE MODE 会对查询的数据行加共享锁,其他事务可以继续读取这些行,但不能修改这些行(不能加排他锁)。
适用于读取操作后不需要立即修改数据的场景,例如报表生成。

二、 避免读写冲突

有一个系统需要检查用户是否有权限访问某些资源。在权限检查过程中,必须确保权限数据不会被其他事务修改。

START TRANSACTION;-- 对权限数据加共享锁,确保读取期间权限数据不被修改
SELECT permission_level FROM user_permissions WHERE user_id = 42 LOCK IN SHARE MODE;-- 根据权限数据执行相应操作
-- 在应用程序中进行进一步的权限验证COMMIT;

共享锁确保了在检查用户权限时,权限数据不会被其他事务修改,这样可以避免权限验证时的数据不一致问题。

三、 复杂查询中的数据一致性

在执行一个复杂的查询操作时,需要确保在查询的过程中,数据不会被其他事务修改。例如,统计某一段时间内的订单总数和金额。

START TRANSACTION;-- 对订单数据加共享锁,确保读取期间订单数据不被修改
SELECT COUNT(*) AS total_orders, SUM(amount) AS total_amount 
FROM orders 
WHERE order_date BETWEEN '2024-01-01' AND '2024-01-31' 
LOCK IN SHARE MODE;COMMIT;

在统计订单数据时,使用共享锁可以防止在查询过程中订单数据被其他事务修改,确保统计结果的准确性。

四、防止“脏读”的数据校验

在某些需要多次读取同一数据进行校验的场景下,可以使用共享锁来确保校验期间数据不会被其他事务修改,避免“脏读”。

START TRANSACTION;-- 第一次读取
SELECT stock FROM products WHERE product_id = 101 LOCK IN SHARE MODE;-- 假设在应用程序中有某些校验逻辑
-- 如果校验通过,再次读取SELECT stock FROM products WHERE product_id = 101 LOCK IN SHARE MODE;COMMIT;

共享锁确保在校验过程中的两次读取之间,数据不会被修改,避免了在两次读取之间发生“脏读”而导致的校验失败。

这篇关于mysql 悲观锁使用的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1106316

相关文章

如何使用 Python 读取 Excel 数据

《如何使用Python读取Excel数据》:本文主要介绍使用Python读取Excel数据的详细教程,通过pandas和openpyxl,你可以轻松读取Excel文件,并进行各种数据处理操... 目录使用 python 读取 Excel 数据的详细教程1. 安装必要的依赖2. 读取 Excel 文件3. 读

解决Maven项目idea找不到本地仓库jar包问题以及使用mvn install:install-file

《解决Maven项目idea找不到本地仓库jar包问题以及使用mvninstall:install-file》:本文主要介绍解决Maven项目idea找不到本地仓库jar包问题以及使用mvnin... 目录Maven项目idea找不到本地仓库jar包以及使用mvn install:install-file基

Windows 上如果忘记了 MySQL 密码 重置密码的两种方法

《Windows上如果忘记了MySQL密码重置密码的两种方法》:本文主要介绍Windows上如果忘记了MySQL密码重置密码的两种方法,本文通过两种方法结合实例代码给大家介绍的非常详细,感... 目录方法 1:以跳过权限验证模式启动 mysql 并重置密码方法 2:使用 my.ini 文件的临时配置在 Wi

MySQL重复数据处理的七种高效方法

《MySQL重复数据处理的七种高效方法》你是不是也曾遇到过这样的烦恼:明明系统测试时一切正常,上线后却频频出现重复数据,大批量导数据时,总有那么几条不听话的记录导致整个事务莫名回滚,今天,我就跟大家分... 目录1. 重复数据插入问题分析1.1 问题本质1.2 常见场景图2. 基础解决方案:使用异常捕获3.

Python使用getopt处理命令行参数示例解析(最佳实践)

《Python使用getopt处理命令行参数示例解析(最佳实践)》getopt模块是Python标准库中一个简单但强大的命令行参数处理工具,它特别适合那些需要快速实现基本命令行参数解析的场景,或者需要... 目录为什么需要处理命令行参数?getopt模块基础实际应用示例与其他参数处理方式的比较常见问http

SQL中redo log 刷⼊磁盘的常见方法

《SQL中redolog刷⼊磁盘的常见方法》本文主要介绍了SQL中redolog刷⼊磁盘的常见方法,将redolog刷入磁盘的方法确保了数据的持久性和一致性,下面就来具体介绍一下,感兴趣的可以了解... 目录Redo Log 刷入磁盘的方法Redo Log 刷入磁盘的过程代码示例(伪代码)在数据库系统中,r

C 语言中enum枚举的定义和使用小结

《C语言中enum枚举的定义和使用小结》在C语言里,enum(枚举)是一种用户自定义的数据类型,它能够让你创建一组具名的整数常量,下面我会从定义、使用、特性等方面详细介绍enum,感兴趣的朋友一起看... 目录1、引言2、基本定义3、定义枚举变量4、自定义枚举常量的值5、枚举与switch语句结合使用6、枚

mysql中的group by高级用法

《mysql中的groupby高级用法》MySQL中的GROUPBY是数据聚合分析的核心功能,主要用于将结果集按指定列分组,并结合聚合函数进行统计计算,下面给大家介绍mysql中的groupby用法... 目录一、基本语法与核心功能二、基础用法示例1. 单列分组统计2. 多列组合分组3. 与WHERE结合使

使用Python从PPT文档中提取图片和图片信息(如坐标、宽度和高度等)

《使用Python从PPT文档中提取图片和图片信息(如坐标、宽度和高度等)》PPT是一种高效的信息展示工具,广泛应用于教育、商务和设计等多个领域,PPT文档中常常包含丰富的图片内容,这些图片不仅提升了... 目录一、引言二、环境与工具三、python 提取PPT背景图片3.1 提取幻灯片背景图片3.2 提取

Mysql用户授权(GRANT)语法及示例解读

《Mysql用户授权(GRANT)语法及示例解读》:本文主要介绍Mysql用户授权(GRANT)语法及示例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录mysql用户授权(GRANT)语法授予用户权限语法GRANT语句中的<权限类型>的使用WITH GRANT