行级锁（悲观锁）的概念

清疚 2022-11-26 02:59 133阅读 0赞

**行级锁（悲观锁）的概念：**

怎么样才会产生行级锁？  
例如：select ename, job, sal from emp where job = ‘Manager’ for update;  
在后面加了for update就产生了行级锁。

行级锁有什么用？  
将查询结果集在表中的对应的记录，开始锁住，在当前事务结束前，别的事务根本修改不了锁住的数据。

行级锁也被称为悲观锁。  
有悲观锁，就对应有乐观锁，那什么是乐观锁？  
乐观锁会在数据后面添加一个隐藏的版本号，假设为version。  
只要事务读取到的版本号没有改变，事务就能对数据进行修改。

例如：  
假设有两个事务对表中的同一数据进行修改。  
事务A：读取到版本号为1.1。  
事务B：读取到的版本为1.1。  
事务A先修改了数据，并对应的把版本号修改为1.2。  
事务B再去修改数据，修改之后发现版本号变成了1.2，与原来读取到的版本不一致，放弃修改，事务回滚。

悲观锁（行级锁）：事务必须排队执行，数据被锁住，无法并发执行。  
乐观锁：支持并发，事务不需要排队，只不过需要版本号一致。

--------------------

（1）Test01和Test02共同演示行级锁：  
Test01开启一个事务，进行查询，并锁住相应的数据。

测试代码：

import jdbc_util.DBUtil;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    
    public class Test01 { 
        public static void main(String[] args) { 
    
            Connection conn = null;
            PreparedStatement ps = null;
            ResultSet rs = null;
    
            try { 
                // 1、注册驱动，2、获取连接
                conn = DBUtil.getConnection();
                // 关闭事务自动提交，开启一个事务
                conn.setAutoCommit(false);
    
                // 3、获取预编译数据库操作对象
                String sql = "select ename, job, sal from emp where job = ? for update";
                ps = conn.prepareStatement(sql);
    
                // 给占位符传值
                ps.setString(1, "Manager");
    
                // 4、执行sql语句
                rs = ps.executeQuery();
    
                // 将断点打在这，也就是提交事务之前，看Test02运行能否修改锁住的数据
                // 5、处理查询结果集
                while (rs.next()) { 
                    String ename = rs.getString("ename");
                    String job = rs.getString("job");
                    String sal = rs.getString("sal");
                    System.out.println(ename + "-" + job + "-" + sal);
                }
    
    
                // 手动提交事务，当前事务结束
                conn.commit();
    
            } catch (SQLException throwables) { 
                if (conn != null) { 
                    try { 
                        conn.rollback();  // 出现异常，事务回滚
                    } catch (SQLException e) { 
                        e.printStackTrace();
                    }
                }
                throwables.printStackTrace();
            } finally { 
                // 6、释放资源
                DBUtil.close(conn, ps, rs);
            }
        }
    }

--------------------

（2）Test02程序开启一个事务，去修改被Test01用行级锁（悲观锁）锁住的数据：

测试代码：

import jdbc_util.DBUtil;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    
    public class Test02 { 
        public static void main(String[] args) { 
            Connection conn = null;
            PreparedStatement ps = null;
    
            try { 
                // 1、注册驱动，2、获取连接
                conn = DBUtil.getConnection();
                // 关闭事务自动提交，开启一个事务
                conn.setAutoCommit(false);
    
                // 3、获取预编译的数据库操作对象
                String sql = "update emp set sal = sal + 10 where job = ?";
                ps = conn.prepareStatement(sql);
                ps.setString(1, "Manager");
    
                // 4、执行sql语句
                int line = ps.executeUpdate();
                System.out.println(line);
    
                // 5、无处理查询结果集
                // 手动提交事务，当前事务结束
                conn.commit();
    
            } catch (SQLException throwables) { 
                if (conn != null) { 
                    try { 
                        conn.rollback();  // 出现异常，事务回滚
                    } catch (SQLException e) { 
                        e.printStackTrace();
                    }
                }
                throwables.printStackTrace();
            } finally { 
                // 6、释放资源
                DBUtil.close(conn, ps, null);
            }
        }
    }

--------------------

测试结果：  
Test01事务结束之前，Test02事务无法修改被Test01用行级锁锁住的数据。