MySQL锁应用详解(下)

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
云数据库 RDS MySQL,高可用系列 2核4GB
简介: MySQL锁应用详解

对表进行事务操作

同理,那么当我去执行shop_product这个表的更新操作时肯定是不会成功的。此时我Java程序中写锁还没有释放,所以在Navicat中执行的对表的操作就不会被执行,只能等到Java程序中的事务提交才会释放锁。


获取表的读锁

在事务1获取到shop_product这个表的写锁后,其它事务想要获取这个表的读锁时也是不能获取的。


对表进行查询操作

这也体现写锁的排它性了,某一时刻只能有一个事务获取这张表的使用权。


2. 行级锁


行级锁适用于对特定行进行锁定,限制对行的访问和修改。MySQL 提供了共享锁和排他锁,用于实现更细粒度的并发控制。

package com.example.onlystudent.mysql.锁;
/**
 * @BelongsProject: OnlyStudent
 * @BelongsPackage: com.example.onlystudent.mysql.锁
 * @Author: gepengjun
 * @CreateTime: 2023-05-15  21:06
 * @Description: 行级锁示例
 * @Version: 1.0
 */
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class RowLevelLockExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/shop";
        String username = "root";
        String mima= "password";
        try (Connection connection = DriverManager.getConnection(url, username, password)) {
            connection.setAutoCommit(false);
            // 事务1获取行级排他锁
            PreparedStatement stmt1 = connection.prepareStatement("SELECT * FROM shop_product WHERE pid = ? FOR UPDATE");
            stmt1.setInt(1, 1);
            ResultSet rs1 = stmt1.executeQuery();
            rs1.next();
            System.out.println(rs1.getString("pname"));
            // 事务2尝试获取行级共享锁,需要等待事务1释放排他锁
            PreparedStatement stmt2 = connection.prepareStatement("SELECT * FROM shop_product WHERE pid = ? LOCK IN SHARE MODE");
            stmt2.setInt(1, 1);
            ResultSet rs2 = stmt2.executeQuery();
            rs2.next();
            System.out.println(rs2.getString("pname"));
            // 处理数据
            // ...
            connection.commit();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}


2.1 共享锁


共享锁允许多个会话同时获取共享锁,其他会话可以读取同一行的数据,但无法获取排他锁。共享锁适用于多个会话并发读取同一行数据的场景。


示例代码:

-- 获取共享锁
SELECT * FROM table_name WHERE condition LOCK IN SHARE MODE;

在我们java程序中事务1执行共享锁的时候,在Navicat中使用排它锁获取pid=1的数据时就获取不到,也就是说在当一个事务对一行数据开启共享锁时,其他事务就不可以使用排它锁来获取这条数据


2.2 排他锁


排他锁只允许一个会话获取排他锁,其他会话无法同时获取共享锁或排他锁。排他锁适用于需要修改特定行数据的场景。


示例代码:

-- 获取排他锁
SELECT * FROM table_name WHERE condition FOR UPDATE;

这里进行验证,当事务一执行后通过,再去Navicat中执行修改pid为1的数据时,这个SQL语句就一直处于等待中,直到我们上述的代码中提交事物后在Navicat中执行的SQL语句才会被执行否则将会一直等待到超时。

并且在使用排它锁的时间内,其它线程并不能使用共享锁来获取这个数据,也就是说当一个事务使用排它锁锁定了一条数据,则其它的事务就不可以使用行级锁来去获取这条数据。


锁的应用场景


MySQL 锁机制在以下场景中发挥重要作用:


1.1 并发读取


在多个会话需要同时读取同一张表的数据时,在并发读取的场景中,可以使用共享锁来保证数据的一致性。多个会话可以同时获取共享锁,读取数据,并在读取完成后释放锁。


示例代码:

// 会话1
String query = "SELECT * FROM table_name WHERE condition LOCK IN SHARE MODE";
Statement statement1 = connection1.createStatement();
ResultSet resultSet1 = statement1.executeQuery(query);
while (resultSet1.next()) {
    // 读取数据
}
statement1.close();
// 会话2
String query = "SELECT * FROM table_name WHERE condition LOCK IN SHARE MODE";
Statement statement2 = connection2.createStatement();
ResultSet resultSet2 = statement2.executeQuery(query);
while (resultSet2.next()) {
    // 读取数据
}
statement2.close();


LOCK IN SHARE MODE 是 MySQL 中的一种锁定模式,用于在查询过程中获取共享锁。它适用于并发读取操作,允许多个事务同时读取相同的数据,而不会相互干扰或产生冲突。


当使用 SELECT 查询语句时,在需要获取共享锁的地方可以添加 LOCK IN SHARE MODE 子句。示例如下:

SELECT * FROM table_name WHERE column = 'value' LOCK IN SHARE MODE;

使用 LOCK IN SHARE MODE 的目的是为了防止在读取数据的同时,其他事务对该数据进行修改或删除操作,以确保数据的一致性。


LOCK IN SHARE MODE 的特点和行为如下:


共享锁(Shared Lock):在查询过程中获取共享锁,允许其他事务也获取共享锁并同时读取相同的数据。

共享冲突:共享锁与共享锁之间不存在冲突,多个事务可以同时获取共享锁。

排斥写入:共享锁与排它锁(Exclusive Lock)之间存在冲突。如果一个事务获取了共享锁,则其他事务无法获取排它锁并执行写入操作。

阻止修改:获取共享锁的事务只能读取数据,不能修改数据。

通过使用 LOCK IN SHARE MODE,可以实现多个事务并发读取相同的数据,提高并发性能,并确保数据的一致性。然而,需要注意在并发读取的情况下,读取的数据可能不是最新的,因为其他事务可能在查询过程中对数据进行了修改。


1.2 并发修改


在多个会话需要同时修改同一张表的数据时,需要使用写锁来保证数据的一致性。只有一个会话能够获取写锁,其他会话需要等待锁的释放。

这里可以使用行级排它锁或者表级排它锁获取这个表的使用权,然后进行修改操作。


示例代码:

// 会话1
String updateQuery = "UPDATE table_name SET column_name = value WHERE condition";
Statement statement1 = connection1.createStatement();
statement1.executeUpdate(updateQuery);
statement1.close();
// 会话2
String updateQuery = "UPDATE table_name SET column_name = value WHERE condition";
Statement statement2 = connection2.createStatement();
statement2.executeUpdate(updateQuery);
statement2.close();


需要注意的是,在使用锁时要避免死锁的发生。死锁是指多个会话相互等待对方持有的锁而无法继续执行的情况。为了避免死锁,可以按照固定的顺序获取锁,或者使用超时机制来放弃锁等待。


总结


MySQL 锁机制在并发访问和数据一致性控制中起着重要的作用。通过合理使用表级锁和行级锁,可以实现对数据的并发访问和修改控制。在实际应用中,需要根据具体场景选择合适的锁,并合理管理锁的释放和避免死锁的发生。了解和掌握 MySQL 锁的使用方法,对于开发高性能、稳定的数据库应用非常重要。

相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
1月前
|
SQL 关系型数据库 MySQL
MySQL 锁
MySQL里常见的几种锁
52 3
|
26天前
|
存储 关系型数据库 MySQL
MySQL在企业内部应用场景有哪些
【10月更文挑战第17天】MySQL在企业内部应用场景有哪些
38 0
|
26天前
|
存储 关系型数据库 MySQL
介绍一下MySQL的一些应用场景
【10月更文挑战第17天】介绍一下MySQL的一些应用场景
114 0
|
27天前
|
存储 关系型数据库 MySQL
优化 MySQL 的锁机制以提高并发性能
【10月更文挑战第16天】优化 MySQL 锁机制需要综合考虑多个因素,根据具体的应用场景和需求进行针对性的调整。通过不断地优化和改进,可以提高数据库的并发性能,提升系统的整体效率。
49 1
|
1月前
|
架构师 关系型数据库 MySQL
MySQL最左前缀优化原则:深入解析与实战应用
【10月更文挑战第12天】在数据库架构设计与优化中,索引的使用是提升查询性能的关键手段之一。其中,MySQL的最左前缀优化原则(Leftmost Prefix Principle)是复合索引(Composite Index)应用中的核心策略。作为资深架构师,深入理解并掌握这一原则,对于平衡数据库性能与维护成本至关重要。本文将详细解读最左前缀优化原则的功能特点、业务场景、优缺点、底层原理,并通过Java示例展示其实现方式。
71 1
|
1月前
|
关系型数据库 MySQL 数据库
MySQL数据库:基础概念、应用与最佳实践
一、引言随着互联网技术的快速发展,数据库管理系统在现代信息系统中扮演着核心角色。在众多数据库管理系统中,MySQL以其开源、稳定、可靠以及跨平台的特性受到了广泛的关注和应用。本文将详细介绍MySQL数据库的基本概念、特性、应用领域以及最佳实践,帮助读者更好地理解和应用MySQL数据库。二、MySQL
110 5
|
1月前
|
关系型数据库 MySQL Java
MySQL数据锁:Record Lock,Gap Lock 和 Next-Key Lock
本文基于 MySQL 8.0.30 版本及 InnoDB 引擎,深入解析三种行锁机制:记录锁(Record Lock)、间隙锁(Gap Lock)和临键锁(Next-key Lock)。记录锁锁定索引记录,确保事务唯一修改;间隙锁锁定索引间的间隙,防止新记录插入;临键锁结合两者,锁定范围并记录自身,有效避免幻读现象。通过具体示例展示了不同锁的作用机制及其在并发控制中的应用。
109 2
|
1月前
|
存储 关系型数据库 MySQL
MySQL数据库锁:共享锁和独占锁
本文详细介绍了`InnoDB`存储引擎中的两种行级别锁:共享锁(S锁)与排他锁(X锁)。通过具体示例展示了这两种锁的工作机制及其在`InnoDB`与`MyISAM`引擎中的表现差异。文章还提供了锁的兼容性矩阵,帮助读者更好地理解锁之间的互斥关系。最后总结了两种锁的特点及适用场景。适合希望深入了解`MySQL`并发控制机制的读者阅读。
41 1
|
27天前
|
存储 关系型数据库 MySQL
MySQL锁,锁的到底是什么?
【10月更文挑战第16天】MySQL 锁锁定的是与数据和资源相关的对象,其目的是为了保证数据的一致性、避免冲突,并在并发环境下合理协调事务或操作的执行。理解锁的对象和意义对于优化数据库性能、处理并发问题至关重要。
54 0
|
2月前
|
监控 关系型数据库 MySQL
MySQL锁机制与解决死锁问题
MySQL锁机制与解决死锁问题
270 5