mysql 行级锁的使用
2017-11-17 17:45
106 查看
先上测试代码,使用jdbc连接,
以下内容中的线程可以理解为一次connection
数据库连接(必须是从连接到commit结束),或一次数据库事务处理
共享锁:
用法: SELECT
... LOCK IN SHARE MODE;
MySQL会对查询结果集中每行都添加共享锁。
排他锁:
用法: SELECT ... FOR UPDATE;
MySQL会对查询结果集中每行都添加排他锁,在事物操作中,任何对记录的更新与删除操作会自动加上排他锁。
总结一下自己的测试结果
1.使用共享锁线程获取锁时,普通线程、共享锁线程、排他锁线程可以获取被锁行记录,但不能修改该行记录
2.使用排他锁线程获取锁时,普通线程可以获取到被锁行记录,共享锁、排他锁线程不能获取到被锁行记录,且三种线程均不能对该行记录做update
获取锁的线程在事务commit前当前锁的行/表拥有增删改的权利,而其他线程只能等待该线程结束commit提交事务,
若当前线程过长时间不释放锁,
等待的线程可能回发生异常Lock wait timeout exceeded; try restarting transaction进行事务回滚
package com.hacker.jdbc.transactional; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import com.hacker.jdbc.Connecter; public class ThreadMain { public static void main(String args[]) { //t1线程 Thread t1 = new Thread(() ->{ Connection con = Connecter.getConnecion(); //connection连接的代码就不提供了注意不要使用单例 conn.setAutoCommit(false); // 默认不提交事务 方便看到阻塞结果 try { System.out.println("t1线程试图开启行级锁"); String sql = "select * from users where id = ? LOCK IN SHARE MODE";// 排他锁测试换FOR UPDATE PreparedStatement pst = con.prepareStatement(sql); pst.setInt(1, 1); ResultSet rs = pst.executeQuery(); if(rs.next()){ System.out.println("t1 :" + rs.getString(2)); //根据你自己定义的表获取结果 } try { System.out.println("t1开始等待3s"); //等待 synchronized (con) { con.wait(3000); } } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println("t1线程完成行级锁"); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } }); //用于测试在t1获得锁的情况下尝试 获取被锁或修改被锁行 Thread t2 = new Thread(() -> { Connection con = Connecter.getConnecion(); try { System.out.println("线程t2开始试图获取被锁行"); // String sql = "update users set password = ? where username = 1 "; String sql = "select * from users where username = ? LOCK IN SHARE MODE"; PreparedStatement pst = con.prepareStatement(sql); // pst.setString(2, "4566"); pst.setInt(1, 1); // System.out.println(pst.executeUpdate()); ResultSet rs = pst.executeQuery(); if(rs.next()){ System.out.println("t2 :" + rs.getString(2)); } con.commit(); System.out.println("t2线程完成,获取到被锁行"); // con.rollback(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } }); t1.start(); t2.start(); } }
以下内容中的线程可以理解为一次connection
数据库连接(必须是从连接到commit结束),或一次数据库事务处理
共享锁:
用法: SELECT
... LOCK IN SHARE MODE;
MySQL会对查询结果集中每行都添加共享锁。
排他锁:
用法: SELECT ... FOR UPDATE;
MySQL会对查询结果集中每行都添加排他锁,在事物操作中,任何对记录的更新与删除操作会自动加上排他锁。
总结一下自己的测试结果
1.使用共享锁线程获取锁时,普通线程、共享锁线程、排他锁线程可以获取被锁行记录,但不能修改该行记录
2.使用排他锁线程获取锁时,普通线程可以获取到被锁行记录,共享锁、排他锁线程不能获取到被锁行记录,且三种线程均不能对该行记录做update
获取锁的线程在事务commit前当前锁的行/表拥有增删改的权利,而其他线程只能等待该线程结束commit提交事务,
若当前线程过长时间不释放锁,
等待的线程可能回发生异常Lock wait timeout exceeded; try restarting transaction进行事务回滚
相关文章推荐
- mysql 行级锁的使用以及死锁的预防
- Mysql 行级锁的使用及死锁的预防方案
- mysql 行级锁的使用以及死锁的预防
- MySQL InnoDB 默认行级锁,行级锁都是基于索引,SQL 语句用不到索引是不会使用行级锁的,而会使用表级锁把整张表锁住
- Mysql 行级锁的使用及死锁的预防方案
- mysql 行级锁的使用以及死锁的预防
- mysql 行级锁的使用以及死锁的预防
- mysql 行级锁的使用以及死锁的预防
- MySQL 行级锁的使用以及死锁的预防
- 使用MySQL内建复制功能来最佳化可用性
- 使用Ruby的MySql模块(1)
- 在 MySQL 数据库中使用 C 执行 SQL 语句
- 在Spring中使用Mysql的一个小问题
- MYSQL初学者使用指南与介绍
- 在Linux下安装和使用MySQL
- 为MySQL Connector Net连接MySQL使用正确的连接字符串
- 在Linux下安装和使用MySQL
- MYSQL初学者使用指南与介绍
- mysql安装使用
- 在Linux下安装和使用MySQL