Spring对事务的实现

Spring对事务的支持

  • 事务概述
    • 事务的四个处理过程
    • 事务的四个特性
  • 引入事务场景
  • Spring实现事务的两种方式
    • 声明式事务之注解实现方式

事务概述

  • 在一个业务流程当中，通常需要多条DML（insert delete update）语句共同联合才能完成，这多条DML语句必须同时成功，或者同时失败，这样才能保证数据的安全。
  • 多条DML要么同时成功，要么同时失败，这叫做事务。

事务的四个处理过程

第一步：开启事务 (start transaction)
第二步：执行核心业务代码
第三步：提交事务（如果核心业务处理过程中没有出现异常）
第四步：回滚事务（如果核心业务处理过程中出现异常）

事务的四个特性

原子性：事务是最小的工作单元，不可再分。
一致性：事务要求要么同时成功，要么同时失败。事务前和事务后的总量不变。
隔离性：事务和事务之间因为有隔离性，才可以保证互不干扰。
持久性：持久性是事务结束的标志。

引入事务场景

例：两个账户act-001和act-002。act-001账户向act-002账户转账10000，必须同时成功，或者同时失败。

新建模块：spring6-jdbc

连接数据库的技术采用Spring框架的JdbcTemplate

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.w</groupId><artifactId>spring6-jdbc</artifactId><version>1.0-SNAPSHOT</version><repositories><repository><id>repository.spring.milestone</id><name>Spring Milestone Repository</name><url>https://repo.spring.io/milestone</url></repository></repositories><dependencies><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>6.0.0-M2</version></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.13.2</version><scope>test</scope></dependency><!--新增的依赖:mysql驱动--><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.30</version></dependency><!--新增的依赖：spring jdbc，这个依赖中有JdbcTemplate--><dependency><groupId>org.springframework</groupId><artifactId>spring-jdbc</artifactId><version>6.0.0-M2</version></dependency><!--@Resource注解--><dependency><groupId>jakarta.annotation</groupId><artifactId>jakarta.annotation-api</artifactId><version>2.1.1</version></dependency><dependency><groupId>org.junit.jupiter</groupId><artifactId>junit-jupiter</artifactId><version>RELEASE</version><scope>test</scope></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid</artifactId><version>1.1.8</version></dependency></dependencies><properties><maven.compiler.source>17</maven.compiler.source><maven.compiler.target>17</maven.compiler.target></properties></project>

第一步：准备数据库表
t_act
表结构
在这里插入图片描述
表数据
在这里插入图片描述
第二步：创建包结构
com.w.spring6.bank.pojo
com.w.spring6.bank.service
com.w.spring6.bank.service.impl
com.w.spring6.bank.dao
com.w.spring6.bank.dao.impl

第三步：准备POJO类
Account.java

package com.w.spring6.bank.pojo;public class Account {private String actno;private Double balance;@Overridepublic String toString() {return "Account{" +"actno='" + actno + '\'' +", balance=" + balance +'}';}public Account() {}public Account(String actno, Double balance) {this.actno = actno;this.balance = balance;}public String getActno() {return actno;}public void setActno(String actno) {this.actno = actno;}public Double getBalance() {return balance;}public void setBalance(Double balance) {this.balance = balance;}
}

第四步：编写持久层
AccountDao接口

package com.w.spring6.bank.dao;import com.w.spring6.bank.pojo.Account;public interface AccountDao {/*** 根据账号查询余额* @param actno* @return*/Account selectByActno(String actno);/*** 更新账户* @param act* @return*/int update(Account act);}

AccountDaoImpl.java

package com.w.spring6.bank.dao.impl;import com.w.spring6.bank.dao.AccountDao;
import com.w.spring6.bank.pojo.Account;import jakarta.annotation.Resource;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;@Repository("accountDao")
public class AccountDaoImpl implements AccountDao {@Resource(name = "jdbcTemplate")private JdbcTemplate jdbcTemplate;@Overridepublic Account selectByActno(String actno) {String sql = "select actno, balance from t_act where actno = ?";Account account = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<>(Account.class), actno);return account;}@Overridepublic int update(Account act) {String sql = "update t_act set balance = ? where actno = ?";int count = jdbcTemplate.update(sql, act.getBalance(), act.getActno());return count;}
}

第五步：编写业务层
AccountService接口

package com.w.spring6.bank.service;public interface AccountService {/*** 转账* @param fromActno* @param toActno* @param money*/void transfer(String fromActno, String toActno, double money);
}

AccountServiceImpl.java

package com.w.spring6.bank.service.impl;import com.w.spring6.bank.dao.AccountDao;
import com.w.spring6.bank.pojo.Account;
import com.w.spring6.bank.service.AccountService;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;@Service("accountService")
public class AccountServiceImpl implements AccountService {@Resource(name = "accountDao")private AccountDao accountDao;@Overridepublic void transfer(String fromActno, String toActno, double money) {// 查询账户余额是否充足Account fromAct = accountDao.selectByActno(fromActno);if (fromAct.getBalance() < money) {throw new RuntimeException("账户余额不足");}// 余额充足，开始转账Account toAct = accountDao.selectByActno(toActno);fromAct.setBalance(fromAct.getBalance() - money);toAct.setBalance(toAct.getBalance() + money);int count = accountDao.update(fromAct);count += accountDao.update(toAct);if (count != 2) {throw new RuntimeException("转账失败，请联系银行");}}
}

第六步：编写Spring配置文件
Spring-bank.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:context="http://www.springframework.org/schema/context"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd"><context:component-scan base-package="com.w.spring6.bank"/><bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"><property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/><property name="url" value="jdbc:mysql://localhost:3307/idea-spring-test"/><property name="username" value="root"/><property name="password" value="123456"/></bean><bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"><property name="dataSource" ref="dataSource"/></bean>
</beans>

第七步：编写表示层（测试程序）
BankTest.java

package com.w.spring6.test;import com.w.spring6.bank.service.AccountService;
import org.junit.jupiter.api.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;public class BankTest {@Testpublic void testTransfer(){ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");AccountService accountService = applicationContext.getBean("accountService", AccountService.class);try {accountService.transfer("act-001", "act-002", 10000);System.out.println("转账成功");} catch (Exception e) {e.printStackTrace();}}
}

运行结果：
在这里插入图片描述
在这里插入图片描述

模拟异常：
在这里插入图片描述
卧槽，少了10000
在这里插入图片描述

Spring实现事务的两种方式

  • 编程式事务：通过编写代码的方式来实现事务的管理。
  • 声明式事务：基于注解方式，基于XML配置方式

声明式事务之注解实现方式

第一步：在spring配置文件中配置事务管理器。
spring-bank.xml

<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"/>
</bean>

第二步：在spring配置文件中引入tx命名空间，在spring配置文件中配置“事务注解驱动器”，开始注解的方式控制事务。
<tx:annotation-driven transaction-manager=“transactionManager”/>

第三步：在service类上或方法上添加@Transactional注解
@Transactional
public class AccountServiceImpl implements AccountService {
}

接着继续运行测试
发现没有丢钱啦！
在这里插入图片描述

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

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

相关文章

YOLOv8-Seg改进：渐近特征金字塔网络（AFPN）

YOLOv8-Seg改进：渐近特征金字塔网络（AFPN）

🚀🚀🚀本文改进：AFPN通过融合两个相邻的Low-Level特征来启动的，并渐进地将High-Level特征纳入融合过程，提升分割能力。 🚀🚀🚀AFPN小目标分割首选，暴力涨点 🚀🚀🚀YOLOv8-seg创新专栏：http://t.csdnimg.cn/KLSdv 学姐带你学习YOLOv8，从入门到创新，轻…
阅读更多...
口袋参谋：一键下载任意买家秀图片、视频，是怎么做到的！

口袋参谋：一键下载任意买家秀图片、视频，是怎么做到的！

​对于淘宝商家来说&#xff0c;淘宝买家秀是非常的重要的。买家秀特别好看的话&#xff0c;对于提升商品的销量来说&#xff0c;会有一定的帮助&#xff0c;如何下载别人的买家秀图片&#xff0c;然后用到自己的店铺中呢&#xff1f; 这里我可以教叫你们一个办法&#xff01;那…
阅读更多...
C语言之for while语句详解

C语言之for while语句详解

C语言之for while语句详解 文章目录 C语言之for while语句详解简介1 while语句1.1while语句的格式1.2 while语句的实践 2 for2.1 for语句格式2.2 for循环的实践 3 do while3.1 do while语句格式3.2 do while循环的实践 3 循环中break和continue3.1 while语句中的break和continu…
阅读更多...
DGL如何表征一张图

DGL如何表征一张图

有关于DGL中图的构建 DGL 将有向图表示为一个 DGL 图对象。图中的节点编号连续&#xff0c;从0开始。我们一般通过指定图中的节点数&#xff0c;以及源节点和目标节点的列表&#xff0c;来构建这么一个图。 下面的代码构造了一个图&#xff0c;这个图有五个叶子节点。中心节点…
阅读更多...
java并发编程JUC：一、专栏配置+进程与线程+并行和并发+同步和异步+线程的创建、调用、查看、运行原理和相关API

java并发编程JUC：一、专栏配置+进程与线程+并行和并发+同步和异步+线程的创建、调用、查看、运行原理和相关API

专栏配置 pom.xml <properties><maven.compiler.source>1.8</maven.compiler.source><maven.compiler.target>1.8</maven.compiler.target> </properties> <dependencies><dependency><groupId>org.projectlombok<…
阅读更多...
Python与ArcGIS系列（九）自定义python地理处理工具

Python与ArcGIS系列（九）自定义python地理处理工具

目录 0 简述1 创建自定义地理处理工具2 创建python工具箱0 简述 在arcgis中可以进行自定义工具箱，将脚本嵌入到自定义的可交互窗口工具中。本篇将介绍如何利用arcpy实现创建自定义地理处理工具以及创建python工具箱。 1 创建自定义地理处理工具 在arctoolbox中的自定义工具箱…
阅读更多...
Java的IO流-缓冲流

Java的IO流-缓冲流

字节缓冲流 package com.itheima.d2;import java.io.*;public class Test1 {public static void main(String[] args) {try (InputStream is new FileInputStream("IO/src/itheima01.txt");//1、定义一个字节缓冲输入流包装原始的字节输入流InputStream bis new Bu…
阅读更多...
Flutter 3.16 中带来的更新

Flutter 3.16 中带来的更新

Flutter 3.16 中带来的更新 目 录 1. 概述2. 框架更新2.1 Material 3 成为新默认2.2 支持 Material 3 动画2.3 TextScaler2.4 SelectionArea 更新2.5 MatrixTransition 动画2.6 滚动更新2.7 在编辑菜单中添加附加选项2.8 PaintPattern 添加到 flutter_test 3. 引擎更新&#xf…
阅读更多...
97.qt qml-自定义Table之实现ctrl与shift多选

97.qt qml-自定义Table之实现ctrl与shift多选

我们之前实现了：93.qt qml-自定义Table优化(新增：水平拖拽/缩放自适应/选择使能/自定义委托)-CSDN博客 实现选择使能的时候，我们只能一行行去点击选中，非常麻烦，所以本章我们实现ctrl多选与shift多选、 所以在Table控件新增两个属性： 1.实现介绍 ctrl多选实现原理：当我…
阅读更多...
基于乌燕鸥算法优化概率神经网络PNN的分类预测 - 附代码

基于乌燕鸥算法优化概率神经网络PNN的分类预测 - 附代码

基于乌燕鸥算法优化概率神经网络PNN的分类预测 - 附代码 文章目录 基于乌燕鸥算法优化概率神经网络PNN的分类预测 - 附代码1.PNN网络概述2.变压器故障诊街系统相关背景2.1 模型建立 3.基于乌燕鸥优化的PNN网络5.测试结果6.参考文献7.Matlab代码 摘要&#xff1a;针对PNN神经网络…
阅读更多...
实用篇-ES-DSL查询文档

实用篇-ES-DSL查询文档

数据的存储不是目的&#xff0c;我们希望从海量的酒店数据中检索出需要的信息&#xff0c;这就是ES的搜索功能 官方文档: https://elastic.co/guide/en/elasticsearch/reference/current/query-dsl.html#query-dsl。DSL是用来查询文档的 Elasticsearch提供了基于JSON的DSL来定…
阅读更多...
大师学SwiftUI第18章Part1 - 图片选择器和相机

大师学SwiftUI第18章Part1 - 图片选择器和相机

如今&#xff0c;个人设备主要用于处理图片、视频和声音&#xff0c;苹果的设备也不例外。SwiftUI可以通过​​Image​​视图显示图片&#xff0c;但需要其它框架的支持来处理图片、在屏幕上展示视频或是播放声音。本章中我们将展示Apple所提供的这类工具。 图片选择器 Swift…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023