事务及在SpringBoot项目中使用的两种方式

1.事务简介

事务(transaction)是访问并可能操作各种数据项的一个数据库操作序列,这些操作要么全部执行,要么全部不执行,是一个不可分割的工作单位。

事物的四大特性:

  1. 原子性(Atomicity)
    原子性指事务是一个不可分割的工作单位,事务中包括的操作要么全部完成,要么全部不完成,不可能结束在中间某个环节。事务中的所有操作要么全部提交成功,要么在发生错误时全部回滚,撤销对数据库的所有更改。这意味着事务内的操作如果失败了,那么会回滚到事务开始前的状态,就像这些操作从来没有发生过一样。
  2. 一致性(Consistency)
    一致性确保事务将数据库从一个一致的状态转变为另一个一致的状态。在事务开始之前和事务结束以后,数据库的完整性没有被破坏。这表示写入的任何数据都必须满足所有设置的规则,包括约束、触发器、级联更新等。例如,在转账事务中,无论进行多少次转账操作,所有用户的总金额应保持不变。
  3. 隔离性(Isolation)
    多个事务并发执行时,一个事务的操作不应影响其他事务。隔离性通过提供“单独”的环境来保证事务不受其他并发事务的影响。这意味着一个事务内部的操作及使用的数据对并发的其他事务是隔离的,反之亦然。这有助于防止数据在并发操作中产生不一致的问题。
  4. 持久性(Durability)
    一旦事务提交,则其结果永久保存在数据库中。即使系统崩溃、重启或发生故障,数据库还能恢复到事务成功结束时的状态。这意味着一旦事务被提交,它对数据库中数据的改变就应该是永久性的。

2.数据库中使用事务

需求:账号A向账号B转账,账户A更新余额后账户B也同时更新余额

初始数据:

操作语句:

update account set balance=1000 where account_number='A';update account set balance=3000 where account_number='B';

操作结果:

问题:当在执行B失败时,数据库数据异常,如下:

问题:A更新数据,B数据却未更新。

解决方案:事务引入,将这两个操作作为一个事务,两个事务必须同时成功才能写入数据库。

#开启事物
start transaction ;
update account set balance=1000 where account_number='A';update ;#抛出异常update account set balance=3000 where account_number='B';
#提交事物,如果执行成功则同时写入数据库
commit ;
#回滚事物,如果执行失败则返回到数据库执行开始状态
ROLLBACK ;

执行结果:

3.事物并发问题

在事务处理、数据库操作或任何需要确保数据一致性和完整性的系统中,并发问题特别重要。当多个事务(或用户)同时尝试访问和修改相同的数据时,可能会出现以下问题:

  1. 脏读(Dirty Read):一个事务读取了另一个尚未提交的事务的数据。如果未提交的事务在之后被回滚,那么之前读取的数据将是无效的。
  2. 不可重复读(Non-repeatable Read):在同一个事务内,由于其他事务的修改,导致多次读取同一数据返回的结果有所不同。
  3. 幻读(Phantom Read):一个事务在读取某些行的集合时,另一个事务插入了新的行,导致前一个事务在再次读取相同的范围时看到额外的“幻影”行。
  4. 丢失更新(Lost Update):两个事务都读取了同一数据,然后都对其进行了修改,但第二个事务的修改覆盖了第一个事务的修改,导致第一个事务的修改丢失。

为了解决这些问题,数据库管理系统(DBMS)通常提供事务隔离级别来控制并发事务之间的交互。这些隔离级别包括:

  • 读未提交(Read Uncommitted):允许读取尚未提交的事务的数据。这是隔离级别最低的情况,可能导致上述所有并发问题。
  • 读已提交(Read Committed):只允许读取已提交的事务的数据。这可以防止脏读,但可能仍然会出现不可重复读和幻读。
  • 可重复读(Repeatable Read):确保在同一个事务内多次读取同一数据返回的结果是一致的。这可以防止脏读和不可重复读,但可能仍然会出现幻读。
  • 串行化(Serializable):这是最高的隔离级别,它强制事务序列化执行,从而防止上述所有并发问题。但这也可能导致性能下降,因为事务需要等待其他事务完成。

4.springboot项目中使用声明式事务

在Spring框架中,声明式事务管理是一种更简洁和声明性的方法来管理事务,通常是通过注解来实现的。声明式事务将事务管理的逻辑与业务逻辑分开,使开发者无需关心事务的底层细节。在Spring Boot中,声明式事务管理主要通过@Transactional注解来实现。

下面是如何在Spring Boot中使用声明式事务的步骤:

1.启用事务管理

确保在启动类或配置类上添加了@EnableTransactionManagement注解,以启用Spring的事务管理功能。


import org.springframework.boot.SpringApplication;  
import org.springframework.boot.autoconfigure.SpringBootApplication;  
import org.springframework.transaction.annotation.EnableTransactionManagement;  @SpringBootApplication  
@EnableTransactionManagement  
public class MyApplication {  public static void main(String[] args) {  SpringApplication.run(MyApplication.class, args);  }  }
2.使用@Transactional注解

在需要事务管理的方法或类上使用@Transactional注解。这个注解告诉Spring该方法需要在事务的上下文中执行。


import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.stereotype.Service;  
import org.springframework.transaction.annotation.Transactional;  @Service  
public class MyService {  // ... 依赖注入和数据访问层代码  @Transactional  public void performTransactionalTask() {  // 在这里执行你的业务逻辑  // 如果抛出运行时异常,事务会自动回滚  }  
}

@Transactional注解可以应用于方法或类级别。当应用于类级别时,它会影响类中的所有公共方法。

3.配置事务属性

@Transactional注解支持多种属性,用于定义事务的传播行为、隔离级别、超时和只读属性。


@Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.DEFAULT, timeout = 30, readOnly = false)  
public void performTransactionalTask() {  // ...  
}
  • propagation:定义事务的传播行为,例如Propagation.REQUIRED表示当前方法必须在一个事务中运行,如果当前存在事务,则加入该事务;如果当前没有事务,则创建一个新的事务。
  • isolation:定义事务的隔离级别,如Isolation.DEFAULT使用数据库默认的事务隔离级别。
  • timeout:定义事务的超时时间,单位是秒。
  • readOnly:指定事务是否只读。如果设置为true,则事务只读取数据而不修改数据。
4.异常处理

默认情况下,如果在事务方法内部抛出了运行时异常(RuntimeException),Spring会触发事务回滚。对于已检查的异常(checked exceptions),Spring不会触发回滚,除非明确指定了@Transactional注解的rollbackFor属性。

@Transactional(rollbackFor = Exception.class)  
public void performTransactionalTask() throws Exception {  // 如果抛出Exception或其子类,事务会回滚  
}
5.事务的传播行为(Propagation Behavior)

定义了当事务方法被另一个事务方法调用时,应如何使用事务。这主要涉及到如何处理嵌套事务的情况。Spring框架提供了多种传播行为选项,这些选项可以通过@Transactional注解的propagation属性来设置。以下是Spring框架中定义的事务传播行为:

  1. PROPAGATION_REQUIRED:如果当前存在事务,则加入该事务;如果当前没有事务,则创建一个新的事务。这是最常见的选择,通常作为默认的事务传播行为。

  1. PROPAGATION_SUPPORTS:如果当前存在事务,则加入该事务;如果当前没有事务,则以非事务的方式继续运行。这意味着方法可以在事务中运行,也可以不在事务中运行,取决于调用它的代码是否处于事务中。
  2. PROPAGATION_MANDATORY:如果当前存在事务,则加入该事务;如果当前没有事务,则抛出异常。这要求调用方法必须在一个事务中运行。
  3. PROPAGATION_REQUIRES_NEW:总是开启一个新的事务。如果当前存在事务,则将其挂起。这意味着无论调用方法是否处于事务中,被调用方法都将在一个新的事务中运行。
  4. PROPAGATION_NOT_SUPPORTED:以非事务方式执行操作,如果当前存在事务,则将其挂起。这意味着方法将不会在一个事务中运行,即使调用它的代码处于事务中。
  5. PROPAGATION_NEVER:以非事务方式执行,如果当前存在事务,则抛出异常。这要求调用方法不能在一个事务中运行。
  6. PROPAGATION_NESTED:如果当前存在事务,则嵌套事务作为当前事务的一个子事务运行;如果当前没有事务,则执行PROPAGATION_REQUIRED行为。这意味着如果在一个事务中调用该方法,那么该方法将在嵌套事务中运行,嵌套事务可以独立回滚而不影响外部事务。

6.事务的回滚

在Java中,使用JDBC或ORM框架(如Hibernate、MyBatis等)时,开发者可以通过调用相应的API来触发事务回滚。例如,在使用JDBC时,可以通过调用Connection对象的rollback()方法来回滚事务。而在使用Spring框架时,可以通过在方法上添加@Transactional注解,并指定rollbackFor属性来指定需要触发回滚的异常类型。

7.实例:

描述: 将用户预约id为1的车位预约信息存入数据库并更新该车位状态,在预约信息存入数据库后抛出错误,观察事务是否成功。

数据库初始状态:

关键代码

/*** 预约处理* @param model* @param request* @return*/@PostMapping("/car/orderDetail")@Transactional(propagation = Propagation.REQUIRED)public String orderDetail(Model model,HttpServletRequest request){String username = request.getParameter("username");String tel = request.getParameter("tel");String parkId = request.getParameter("id");//车位编号String location = request.getParameter("location");String date = request.getParameter("date");String time = request.getParameter("time");String totalprice = request.getParameter("totalprice");String type = request.getParameter("type");String duration = request.getParameter("duration");OrderParking orderParking=new OrderParking();// 拼接日期和时间字符串String datetime_str = date + " " + time;// 定义日期时间格式DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm");// 将拼接后的字符串转换为LocalDateTime对象LocalDateTime datetime_obj = LocalDateTime.parse(datetime_str, formatter);orderParking.setDate(datetime_obj);orderParking.setLocation(location);orderParking.setTel(tel);orderParking.setParkId(Integer.valueOf(parkId));orderParking.setTotalprice(Double.valueOf(totalprice));orderParking.setType(type);orderParking.setUsername(username);// 计算截止时间LocalDateTime endTime = datetime_obj.plusSeconds(Long.parseLong(duration)*3600L);orderParking.setDeadtime(endTime);orderParking.setDuration(Double.valueOf(duration));orderParking.setType(type);//判断是否可以预约int status1 = orderService.findStatus(Integer.parseInt(parkId));if(status1==1){model.addAttribute("msg", "该车位已预约");model.addAttribute("target", "http://"+address+":"+port+"/order/list");return "/operate-result";}//将预约表单存入数据库int i = orderService.addOrderParking(orderParking);//这里模拟异常String s=null;System.out.println(s.toString());//更新车位表状态int status = orderService.updateStatus(Integer.parseInt(parkId));if(status==1&&i==1){model.addAttribute("msg", "预约成功");model.addAttribute("target", "http://"+address+":"+port+"/order/list");return "/operate-result";}model.addAttribute("msg", "预约失败");model.addAttribute("target", "http://"+address+":"+port+"/order/list");return "/operate-result";}

执行结果

预约表中记录并为增添且车位状态并未更新(第二列为预约车位编号)

事务执行成功

5.编程式事务

编程式事务管理指的是在代码中显式地管理事务的边界和逻辑,而不是依赖于声明式的方式(如注解)。在编程式事务管理中,开发者需要手动开始、提交或回滚事务。Spring框架提供了TransactionTemplate和PlatformTransactionManager等API来支持编程式事务管理。

以下是使用编程式事务管理的基本步骤:

1.配置事务管理器

首先,你需要在Spring配置中定义一个PlatformTransactionManager的bean。这通常是基于你使用的数据源类型(如JDBC、Hibernate、JPA等)来决定的。

例如,对于JDBC,你可以这样配置一个DataSourceTransactionManager:

2.使用TransactionTemplate

TransactionTemplate是Spring提供的一个帮助类,它简化了编程式事务的使用。你可以创建一个TransactionTemplate的bean,并注入你的事务管理器。然后,你可以在你的服务代码中使用这个TransactionTemplate来执行需要事务管理的操作。

这里是转账的逻辑

@Autowired
OrderMapper orderMapper;
public void update(String A,int aBalance,String B,int bBalance){transactionTemplate.execute(new TransactionCallbackWithoutResult() {@Overrideprotected void doInTransactionWithoutResult(TransactionStatus status) {try {// 在这里执行你的业务逻辑orderMapper.updateAccount(A,aBalance);String s=null;System.out.println(s.toString());orderMapper.updateAccount(B, bBalance);// 如果抛出运行时异常,事务会自动回滚} catch (Exception e) {// 可以选择手动回滚status.setRollbackOnly();throw e;}}});}
3.手动管理事务

除了使用TransactionTemplate,你还可以直接使用PlatformTransactionManager来手动开始、提交和回滚事务。这通常是通过TransactionStatus对象来完成的。


import org.springframework.transaction.support.TransactionCallback;  
import org.springframework.transaction.support.TransactionTemplate;  
import org.springframework.transaction.TransactionStatus;  
import org.springframework.transaction.PlatformTransactionManager;  @Service  
public class MyService {  private final PlatformTransactionManager transactionManager;  public MyService(PlatformTransactionManager transactionManager) {  this.transactionManager = transactionManager;  }  public void performManualTransactionalTask() {  TransactionStatus status = transactionManager.getTransaction(new DefaultTransactionDefinition());  try {  // 在这里执行你的业务逻辑  // 如果抛出运行时异常,事务会自动回滚  transactionManager.commit(status);  } catch (Exception e) {  // 发生异常,手动回滚事务  transactionManager.rollback(status);  throw e;  }  }  
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/470555.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

OLED显示红外遥控键码

基本原理 本遥控器的编码是NEC编码,为PWM(脉冲宽度调制)。 发射红外载波的时间固定,通过改变不发射载波的时间来改变占空比。 逻辑“0”是由0.56ms的38KHZ载波和0.560ms的无载波间隔组成;逻辑“1”是由0.56ms的38KHZ…

【JAVA】计算机软件工程人工智能研究生复试资料整理

1、JAVA 2、计算机网络 3、计算机体系结构 4、数据库 5、计算机租场原理 6、软件工程 7、大数据 8、英文 自我介绍 1. Java 1. == 和 equals的区别 比较基本数据类型是比较的值,引用数据类型是比较两个是不是同一个对象,也就是引用是否指向同 一个对象,地址是否相同,equ…

代码随想录算法训练营第51天 | 139.单词拆分 + 多重背包理论基础 + 背包问题总结

今日任务 139.单词拆分 关于多重背包,你该了解这些! 背包问题总结篇! 139.单词拆分 - Medium 题目链接:力扣(LeetCode)官网 - 全球极客挚爱的技术成长平台 给你一个字符串 s 和一个字符串列表 wordDict …

Linux中sigaction函数和SIGCHLD信号的使用

sigaction函数: 函数说明:注册一个信号处理函数 函数原型:int sigaction(int signum, const struct sigaction *act, struct sigaction *oldact); 函数参数: signum:捕捉的信号act:传入参数,…

Flutter Android开发 梳理Google Material Design颜色体系

前言 做安卓开发(Kotlin语言),Flutter开发的人员应该都听说过谷歌一直推崇的Material Design,而Material Design Color是其推崇的颜色体系,具体来说,Material Design Color是一套旨在帮助设计师和开发者创…

洛谷_P1781 宇宙总统_python写法

这道题如果去比较数字的大小是不行的,因为位数太多了,所以就想到用字符串来比较,字符串比较也有讲究,比如说数字长度越长说明这个数字越大,对于相等长度的数字,我们只需要去比较每一位的数字,只…

Windows11通过SMB映射NAS网络驱动磁盘

环境 NAS:威联通TS-416 操作系统:Windows11 第一步 连接NAS winr 打开运行,输入NAS局域网IP地址,按照如下的格式输入 然后输入NAS的账号和密码就可以通过SMB连接到NAS了 第二步 映射网络驱动器 举个栗子:右键Stora…

【Linux系统编程】25.mmap、munmap

目录 mmap 参数addr 参数length 参数prot 参数flags 参数fd 参数offset 返回值 保险使用方式 munmap 参数addr 参数length 返回值 测试代码1 测试结果 使用注意事项 测试代码2 测试结果 测试代码3 测试结果 匿名映射 测试代码4 测试结果 mmap 将一个指…

可变参数(c/c++)

目录 一、C语言版本 二、C的实现方法 2.1数据包 2.2sizeof...运算符 2.3可变参数模板的使用 2.4emplace_back() 有时候我们在编写函数时,可能不知道要传入的参数个数,类型 。比如我们要实现一个叠加函数,再比如c语言中的printf,c中的emp…

Go语言每日一练——链表篇(九)

传送门 牛客面试笔试必刷101题 ----------------链表相加(二) 题目以及解析 题目 解题代码及解析 解析 这一道题主要是要对链表相加的过程进行模拟,虽然思路不难但是细节出比较多,这里博主的思路主要是先将两个链表反转过来然后以Head1为基础来模拟…

C语言:指针的基础详解

目录 1. 内存 2. 取地址& 3. 指针变量 4. 解引用 4.1 *解引用 4.2 []解引用 4.3 ->解引用 5. 指针变量的大小 5.1 结论 6. 指针运算 7. void* 指针 8. const修饰指针 8.1 const修饰变量 8.2 const修饰指针变量 8.3 结论 9. 野指针 9.1 为什么会出现野指…

[嵌入式系统-15]:RT-Thread -1- 简介与技术架构

目录 一、RT-Thread简介 1.1 简介 1.2 功能特点 1.3 发展历史 1.4 应用场合 1.5 与Linux的比较 1.6 ​​​​​​​RT-Thread优缺点 二、技术架构 2.1 分层架构​编辑 2.2 功能组件 2.3 应用程序接口RT-Thread API 2.4 应用程序接口:RT-Thread API、POS…