hibernate 乐观锁和悲观锁

1、什么是事务?
事务就是被绑定在一起作为一个逻辑工作单元的sql语句组。事务具有四个特性
ACID特性。
原子性:是一个逻辑工作单位,要么都成功,要么都失败。
一致性:数据库数据必须从一个一致状态,到另外一个一致的状态。(逻辑上不能有错,结果正确)
隔离性:一个事务与其他事务间不能互相干扰。
持久性:事务一旦提交,对数据的更改就是永久性的。

原子性与一致性理解
转账:张三给李四转账100元。那数据库假设需要 张三扣100,李四加100,记录一条流水。
如果流水没记录成功,那整体回滚,张三也没转账成功,李四也没多钱。这就是原子性的体现。

而张三必须扣100,李四必须加100,这个就是一致性了,如果因为某些逻辑原因,导致张三扣了100,流水记录100转账,而李四只加了60。然后这3条操作都成功了,那原子性就符合了,但是一致性就不符合了~~~
2、并发存在的问题?
在多线程的情况下,多个用户同时对一条数据做操作,那就可能产生并发问题。使数据库操作的结果不正确。常见的问题有三个:
1)脏读:A事务读取到B事务没有提交的数据,如果B事务回滚了,那么A读取到的就是脏数据(不正确的数据),我们称这种情况为脏读。

2)不可重复读:在同一个事务中,对同一份数据多次读取的结果不一致。
原因是在读取间隙,其他事务改变了该数据。事务并发修改记录导致

3)幻读:在同一个事务中,多次同样的查询返回的记录条数不同。原因是在执行间隙,其他事务增加或删除了对应的记录。

为了解决这些问题,提出了事务的隔离级别,主要有四个
1)读未提交:级别最低,任何情况不能避免
2)读已提交:可以避免脏读
3)可重复读:可以避免脏读,不可重复读
4)串行化:可以避免脏读,不可重复读,幻读

3、hibernate 事务锁机制
1)悲观锁:从加载对象就开始锁定,直到事务提交。通过数据库本身的机制来实现。

 /**
     * 悲观锁
     */
    @Test
    public void lockTest(){
        Transaction transaction = session.beginTransaction();
//        HUser user = (HUser) session.get(HUser.class, 9);
        HUser user = (HUser) session.load(HUser.class, 9,LockOptions.UPGRADE);
        try {
            Thread.sleep(35000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("锁1:"+user.getName());
        transaction.commit();
    }

    @Test
    public void lockTestGet(){
        Transaction transaction = session.beginTransaction();
        HUser user = (HUser) session.get(HUser.class, 9,LockOptions.UPGRADE);
        System.out.println("锁2:"+user.getName());
        transaction.commit();
    }

2)乐观锁
前面讲的悲观锁同一时间只能处理一个请求,并发处理能力太差,所以hibernate 提供了另外一种锁机制,要乐观锁。主要通过在表中增加Version(版本号)或时间戳来实现。(每次开启事物会去获取表的版本号,并在提交的时候同样会去再查询一遍,如果两次版本号一致,则会提交事务,否则判定为不合法的数据,不与提交。)
具体实现:

1)在数据库表和对应实体类中加入version 版本号
2)在映射文件中加入版本号 配置

  
        

3)然后就是测试啦

 /**
     * 乐观锁机制
     * 基于version实现
     *
     */
    @Test
    public void haddyLock(){
        Session session1 = sessionFactory.openSession();
        Transaction tr1 = session1.beginTransaction();

        Session session2 = sessionFactory.openSession();
        Transaction tr2 = session2.beginTransaction();
        //-------逻辑代码分割线
        HUser user1 = (HUser) session1.get(HUser.class, 9);
        HUser user2 = (HUser) session2.get(HUser.class, 9);
        // s1  -- >2 , s2 --> 2
        System.out.println("1s1:"+user1.getVersion()+",s2:"+user2.getVersion());
        user1.setPassword("111");
        tr1.commit();
        System.out.println("2s1:"+user1.getVersion()+",s2:"+user2.getVersion());
        session1.close();
        // s1  -- >3 , s2 --> 2


        user2.setPassword("222");
        //-------逻辑代码分割线
        tr2.commit();
        System.out.println("3s1:"+user1.getVersion()+",s2:"+user2.getVersion());
        session2.close();
    }

你可能感兴趣的