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)在映射文件中加入版本号 配置
<!--设置版本号,用于乐观锁-->
<version name="version" column="version"></version>
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();
}