news 2026/3/1 20:37:22

(41)事务属性(建议在数据库深入学习)

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
(41)事务属性(建议在数据库深入学习)

事务属性包括哪些


事务中的重点属性:

  • 事务传播行为
  • 事务隔离级别
  • 事务超时
  • 只读事务
  • 设置出现哪些异常回滚事务
  • 设置出现哪些异常不回滚事务

事务传播行为

什么是事务的传播行为?
在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或该异常的子类异常不回滚,其他异常则回滚。

版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/2/27 20:12:44

YOLO训练成本太高?我们送你免费GPU token体验包

YOLO训练成本太高?我们送你免费GPU token体验包 在智能摄像头、工业质检线甚至无人机巡检的幕后,总能看到一个名字频繁出现:YOLO。它不是某个神秘缩写,而是“You Only Look Once”——一种将目标检测效率推向极致的设计哲学。今天…

作者头像 李华
网站建设 2026/2/26 20:43:06

YOLO模型支持InfluxDB时序数据库监控指标存储

YOLO 模型与 InfluxDB 时序数据库的监控集成实践 在智能制造车间的一条视觉检测产线上,工程师突然发现某台工控机的漏检率在下午三点开始持续上升。传统的排查方式需要手动登录设备、查看日志、运行诊断命令——整个过程耗时超过一小时。但如果这台设备已经将 YOLO …

作者头像 李华
网站建设 2026/2/23 9:02:16

2025最新!10个AI论文软件测评:研究生开题报告必备神器

2025最新!10个AI论文软件测评:研究生开题报告必备神器 2025年AI论文工具测评:精准匹配学术需求的高效助手 随着人工智能技术在学术领域的深入应用,越来越多的研究生开始依赖AI论文软件提升写作效率、优化研究流程。然而&#xff0…

作者头像 李华
网站建设 2026/3/1 13:43:05

YOLO模型训练支持Gradient Accumulation应对显存不足

YOLO模型训练支持Gradient Accumulation应对显存不足 在工业视觉系统日益复杂的今天,目标检测模型的部署需求正以前所未有的速度增长。从智能工厂的PCB缺陷识别,到城市交通中的多目标追踪,YOLO系列凭借其“一次前向、全图预测”的高效架构&a…

作者头像 李华