【JDBC】笔记（5）

  • Z时代
  • 2024-01-10
  • 分类：综合

database

总结：在当前事务中，用行级锁锁住的记录，那么在此事务结束之前，其他事务将无法对“锁住的记录”进行操作（update/delete），但是select可以......

1.悲观锁和乐观锁的概念：


2.演示行级锁机制：

注意：DBUtil类 为博主之前自己写的类：【JDBC】编程（2）--- 写一个JDBC工具类；用 JDBC工具类 实现模糊查询

 

/*

演示行级锁机制

此程序先开启事务，并使用行级锁锁住“loginName = abc”的那条记录

*/

 

import java.sql.*;
public class JDBCLock01 {
    public static void main(String[] args) {
        Connection connection = null;
        PreparedStatement ps = null;
        ResultSet resultSet = null;
        try {
            connection = DBUtil.getConnection();
            connection.setAutoCommit(false);
            //锁住“loginName = abc”的这条记录
            String sql = "select loginName,loginPwd from t_user where loginName = ? for update";
            ps = connection.prepareStatement(sql);
            ps.setString(1,"abc");
            resultSet = ps.executeQuery();
            while (resultSet.next()){
                System.out.println("loginName = "+resultSet.getString("loginName")+
                        ",loginPwd = "+resultSet.getString("loginPwd"));
            }
            //添加断点，让此事务在此暂停10s后结束
            Thread.sleep(10000);//使当前线程暂停10000毫秒
            connection.commit();
        } catch (Exception e) {
            if (connection != null) {
                try {
                    connection.commit();
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
            e.printStackTrace();
        }finally {
            DBUtil.close(connection,ps,resultSet);
        }
    }
}

 

"JDBCLock01"控制台情况：

（暂停大约1000毫秒然后输出：）

loginName = abc,loginPwd = 123
Process finished with exit code 0

 

/*

演示行级锁机制

此程序后开启事务，负责修改被锁定的记录

*/

 

import java.sql.*;
public class JDBCLock02 {
    public static void main(String[] args) {
        Connection connection = null;
        PreparedStatement ps = null;
        try {
            connection = DBUtil.getConnection();
            connection.setAutoCommit(false);
            //修改“loginName = abc”的这条记录的密码
            String sql = "update t_user set loginPwd  = ? where loginName = ?";
            ps = connection.prepareStatement(sql);
            ps.setString(1,"888");
            ps.setString(2,"abc");
            int count = ps.executeUpdate();
            System.out.println("更新数据"+count+"条");
            connection.commit();
        } catch (SQLException e) {
            if (connection != null) {
                try {
                    connection.commit();
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
            e.printStackTrace();
        }finally {
            DBUtil.close(connection,ps,null);
        }
    }
}

 

"JDBCLock02"控制台输出结果：

（"JDBCLock01"程序结束后输出）

更新数据1条
Process finished with exit code 0

 

总结：在当前事务中，用行级锁锁住的记录，那么在此事务结束之前，其他事务将无法对“锁住的记录”进行操作（update/delete），但是select可以。

 

以上是 【JDBC】笔记（5） 的全部内容， 来源链接： utcz.com/z/536214.html

回到顶部