欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

mysql 行级锁的使用

程序员文章站 2024-01-13 14:53:52
...
先上测试代码,使用jdbc连接,
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进行事务回滚