MySQL锁应用详解(下)

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
云数据库 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 锁的使用方法,对于开发高性能、稳定的数据库应用非常重要。

相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发,帮助IT从业者们通过“阿里云Web应用上云解决方案”,了解一个企业级Web应用上云的常见架构,了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。   相关的阿里云产品:云数据库RDS MySQL 版 阿里云关系型数据库RDS(Relational Database Service)是一种稳定可靠、可弹性伸缩的在线数据库服务,提供容灾、备份、恢复、迁移等方面的全套解决方案,彻底解决数据库运维的烦恼。 了解产品详情: https://www.aliyun.com/product/rds/mysql 
相关文章
|
1月前
|
SQL 监控 关系型数据库
MySQL事务处理:ACID特性与实战应用
本文深入解析了MySQL事务处理机制及ACID特性,通过银行转账、批量操作等实际案例展示了事务的应用技巧,并提供了性能优化方案。内容涵盖事务操作、一致性保障、并发控制、持久性机制、分布式事务及最佳实践,助力开发者构建高可靠数据库系统。
|
3月前
|
关系型数据库 MySQL 分布式数据库
安全可靠的PolarDB V2.0 (兼容MySQL)产品能力及应用场景
PolarDB分布式轻量版采用软件输出方式,能够部署在您的自主环境中。PolarDB分布式轻量版保留并承载了云原生数据库PolarDB分布式版技术团队深厚的内核优化成果,在保持高性能的同时,显著降低成本。
|
5月前
|
SQL AliSQL 关系型数据库
MYSQL的全局锁和表锁
本文介绍了MySQL中的锁机制,包括全局锁、表级锁及其应用场景。全局锁通过`Flush tables with read lock (FTWRL)`实现,主要用于全库逻辑备份,但会阻塞更新和结构变更操作。表级锁分为显式表锁(`lock tables`)和元数据锁(MDL),前者用于控制并发访问,后者自动加锁以确保读写正确性。文章还探讨了如何安全地为小表添加字段,建议通过设置DDL等待时间或使用MariaDB/AliSQL的NOWAIT/WAIT功能避免业务阻塞。这些方法有助于在高并发场景下优化数据库性能与安全性。
117 0
|
2月前
|
存储 关系型数据库 MySQL
MYSQL数据加密压缩函数应用实战指南。
总的来说,加密和压缩是维护MySQL数据库中数据安全性和效率的有效手段。使用时需权衡性能与安全,合理应用加密和压缩函数。在设计数据库架构时要考虑到加密字段的查询性能,因为加密可能使得一些索引失效。压缩数据能有效减少存储空间的占用,但在服务器负载较高时应避免实时压缩和解压,以免影响总体性能。
83 10
|
12月前
|
存储 关系型数据库 MySQL
MySQL在企业内部应用场景有哪些
【10月更文挑战第17天】MySQL在企业内部应用场景有哪些
435 0
|
12月前
|
存储 关系型数据库 MySQL
介绍一下MySQL的一些应用场景
【10月更文挑战第17天】介绍一下MySQL的一些应用场景
2486 0
|
8月前
|
关系型数据库 MySQL 网络安全
如何排查和解决PHP连接数据库MYSQL失败写锁的问题
通过本文的介绍,您可以系统地了解如何排查和解决PHP连接MySQL数据库失败及写锁问题。通过检查配置、确保服务启动、调整防火墙设置和用户权限,以及识别和解决长时间运行的事务和死锁问题,可以有效地保障应用的稳定运行。
327 25
|
9月前
|
存储 关系型数据库 MySQL
MySQL进阶突击系列(06)MySQL有几种锁?| 别背答案,现场演示一下
本文详细解析了MySQL InnoDB存储引擎的锁机制,涵盖读锁、写锁、意向锁、记录锁、间隙锁和临键锁等8种锁类型。重点探讨了不同锁类型的加锁与释放方式,以及事务并发场景下的实战验证。通过具体示例,展示了在不同情况下锁的行为及其对事务的影响。文章还特别强调了锁的作用范围主要是索引,并解释了锁如何影响数据的读写操作。最后总结了并发事务中加锁规则,帮助读者深入理解MySQL的锁机制。
|
11月前
|
关系型数据库 MySQL Java
MySQL索引优化与Java应用实践
【11月更文挑战第25天】在大数据量和高并发的业务场景下,MySQL数据库的索引优化是提升查询性能的关键。本文将深入探讨MySQL索引的多种类型、优化策略及其在Java应用中的实践,通过历史背景、业务场景、底层原理的介绍,并结合Java示例代码,帮助Java架构师更好地理解并应用这些技术。
269 2
|
12月前
|
存储 关系型数据库 MySQL
优化 MySQL 的锁机制以提高并发性能
【10月更文挑战第16天】优化 MySQL 锁机制需要综合考虑多个因素,根据具体的应用场景和需求进行针对性的调整。通过不断地优化和改进,可以提高数据库的并发性能,提升系统的整体效率。
599 1

推荐镜像

更多