事务属性包括哪些
事务中的重点属性:
- 事务传播行为
- 事务隔离级别
- 事务超时
- 只读事务
- 设置出现哪些异常回滚事务
- 设置出现哪些异常不回滚事务
事务传播行为
什么是事务的传播行为?
在service类中有a()方法和b()方法,a()方法上有事务,b()方法上也有事务,当a()方法执行过程中调用了b()方法,事务是如何传递的?合并到一个事务里?还是开启一个新的事务?这就是事务传播行为。
事务传播行为在spring框架中被定义为枚举类型:
一共有七种传播行为:
- REQUIRED:支持当前事务,如果不存在就新建一个(默认)【没有就新建,有就加入】
- SUPPORTS:支持当前事务,如果当前没有事务,就以非事务方式执行**【有就加入,没有就不管了】**
- MANDATORY:必须运行在一个事务中,如果当前没有事务正在发生,将抛出一个异常**【有就加入,没有就抛异常】**
- REQUIRES_NEW:开启一个新的事务,如果一个事务已经存在,则将这个存在的事务挂起**【不管有没有,直接开启一个新事务,开启的新事务和之前的事务不存在嵌套关系,之前事务被挂起】**
- NOT_SUPPORTED:以非事务方式运行,如果有事务存在,挂起当前事务**【不支持事务,存在就挂起】**
- NEVER:以非事务方式运行,如果有事务存在,抛出异常**【不支持事务,存在就抛异常】**
- NESTED:如果当前正有一个事务在进行中,则该方法应当运行在一个嵌套式事务中。被嵌套的事务可以独立于外层事务进行提交或回滚。如果外层事务不存在,行为就像REQUIRED一样。【有事务的话,就在这个事务里再嵌套一个完全独立的事务,嵌套的事务可以独立的提交和回滚。没有事务就和REQUIRED一样。】
在代码中设置事务的传播行为:
@Transactional(propagation=Propagation.REQUIRED)可以编写程序测试一下传播行为:
@Transactional(propagation=Propagation.REQUIRED)publicvoidsave(Accountact){// 这里调用dao的insert方法。accountDao.insert(act);// 保存act-003账户// 创建账户对象Accountact2=newAccount("act-004",1000.0);try{accountService.save(act2);// 保存act-004账户}catch(Exceptione){}// 继续往后进行我当前1号事务自己的事儿。}@Override//@Transactional(propagation = Propagation.REQUIRED)@Transactional(propagation=Propagation.REQUIRES_NEW)publicvoidsave(Accountact){accountDao.insert(act);// 模拟异常Strings=null;s.toString();// 事儿没有处理完,这个大括号当中的后续也许还有其他的DML语句。}一定要集成Log4j2日志框架,在日志信息中可以看到更加详细的信息。
事务隔离级别
事务隔离级别类似于教室A和教室B之间的那道墙,隔离级别越高表示墙体越厚。隔音效果越好。
数据库中读取数据存在的三大问题:(三大读问题)
- 脏读:读取到没有提交到数据库的数据,叫做脏读。
- 不可重复读:在同一个事务当中,第一次和第二次读取的数据不一样。
- 幻读:读到的数据是假的。
事务隔离级别包括四个级别:
- 读未提交:READ_UNCOMMITTED
- 这种隔离级别,存在脏读问题,所谓的脏读(dirty read)表示能够读取到其它事务未提交的数据。
- 读提交:READ_COMMITTED
- 解决了脏读问题,其它事务提交之后才能读到,但存在不可重复读问题。
- 可重复读:REPEATABLE_READ
- 解决了不可重复读,可以达到可重复读效果,只要当前事务不结束,读取到的数据一直都是一样的。但存在幻读问题。
- 序列化:SERIALIZABLE
- 解决了幻读问题,事务排队执行。不支持并发。
大家可以通过一个表格来记忆:
| 隔离级别 | 脏读 | 不可重复读 | 幻读 |
|---|---|---|---|
| 读未提交 | 有 | 有 | 有 |
| 读提交 | 无 | 有 | 有 |
| 可重复读 | 无 | 无 | 有 |
| 序列化 | 无 | 无 | 无 |
在Spring代码中如何设置隔离级别?
隔离级别在spring中以枚举类型存在:
@Transactional(isolation=Isolation.READ_COMMITTED)测试事务隔离级别:READ_UNCOMMITTED 和 READ_COMMITTED
怎么测试:一个service负责插入,一个service负责查询。负责插入的service要模拟延迟。
packagecom.powernode.bank.service.impl;importcom.powernode.bank.dao.AccountDao;importcom.powernode.bank.pojo.Account;importjakarta.annotation.Resource;importorg.springframework.stereotype.Service;importorg.springframework.transaction.annotation.Isolation;importorg.springframework.transaction.annotation.Transactional;/** * @author 动力节点 * @version 1.0 * @className IsolationService1 * @since 1.0 **/@Service("i1")publicclassIsolationService1{@Resource(name="accountDao")privateAccountDaoaccountDao;// 1号// 负责查询// 当前事务可以读取到别的事务没有提交的数据。//@Transactional(isolation = Isolation.READ_UNCOMMITTED)// 对方事务提交之后的数据我才能读取到。@Transactional(isolation=Isolation.READ_COMMITTED)publicvoidgetByActno(Stringactno){Accountaccount=accountDao.selectByActno(actno);System.out.println("查询到的账户信息:"+account);}}packagecom.powernode.bank.service.impl;importcom.powernode.bank.dao.AccountDao;importcom.powernode.bank.pojo.Account;importjakarta.annotation.Resource;importorg.springframework.stereotype.Service;importorg.springframework.transaction.annotation.Transactional;/** * @author 动力节点 * @version 1.0 * @className IsolationService2 * @since 1.0 **/@Service("i2")publicclassIsolationService2{@Resource(name="accountDao")privateAccountDaoaccountDao;// 2号// 负责insert@Transactionalpublicvoidsave(Accountact){accountDao.insert(act);// 睡眠一会try{Thread.sleep(1000*20);}catch(InterruptedExceptione){e.printStackTrace();}}}测试程序
@TestpublicvoidtestIsolation1(){ApplicationContextapplicationContext=newClassPathXmlApplicationContext("spring.xml");IsolationService1i1=applicationContext.getBean("i1",IsolationService1.class);i1.getByActno("act-004");}@TestpublicvoidtestIsolation2(){ApplicationContextapplicationContext=newClassPathXmlApplicationContext("spring.xml");IsolationService2i2=applicationContext.getBean("i2",IsolationService2.class);Accountact=newAccount("act-004",1000.0);i2.save(act);}通过执行结果可以清晰的看出隔离级别不同,执行效果不同。
事务超时
代码如下:
@Transactional(timeout=10)以上代码表示设置事务的超时时间为10秒。
表示超过10秒如果该事务中所有的DML语句还没有执行完毕的话,最终结果会选择回滚。
默认值-1,表示没有时间限制。
这里有个坑,事务的超时时间指的是哪段时间?
在当前事务当中,最后一条DML语句执行之前的时间。如果最后一条DML语句后面很有很多业务逻辑,这些业务代码执行的时间不被计入超时时间。
@Transactional(timeout=10)// 设置事务超时时间为10秒。publicvoidsave(Accountact){accountDao.insert(act);// 睡眠一会try{Thread.sleep(1000*15);}catch(InterruptedExceptione){e.printStackTrace();}}@Transactional(timeout=10)// 设置事务超时时间为10秒。publicvoidsave(Accountact){// 睡眠一会try{Thread.sleep(1000*15);}catch(InterruptedExceptione){e.printStackTrace();}accountDao.insert(act);}当然,如果想让整个方法的所有代码都计入超时时间的话,可以在方法最后一行添加一行无关紧要的DML语句。
只读事务
代码如下:
@Transactional(readOnly=true)将当前事务设置为只读事务,在该事务执行过程中只允许select语句执行,delete insert update均不可执行。
该特性的作用是:启动spring的优化策略。提高select语句执行效率。
如果该事务中确实没有增删改操作,建议设置为只读事务。
设置哪些异常回滚事务
代码如下:
@Transactional(rollbackFor=RuntimeException.class)表示只有发生RuntimeException异常或该异常的子类异常才回滚。
设置哪些异常不回滚事务
代码如下:
@Transactional(noRollbackFor=NullPointerException.class)表示发生NullPointerException或该异常的子类异常不回滚,其他异常则回滚。