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();
}
网友评论