Spring17——Spring事务简介、使用事务实现模拟转账业务

news2024/11/24 13:10:02

38-Spring事务简介

相关概念

  • 事务作用：在数据层保障一系列的数据库操作同成功同失败
  • Spring事务作用：在数据层或业务层保障一系列的数据库操作同时成功或同时失败

数据层有事务我们可以理解，为什么业务层也需要处理事务呢？举个简单的例子

  • 转账业务会有两次数据层的调用，一次是加钱一次是减钱
  • 把事务放在数据层，加钱和减钱就有两个事务
  • 没办法保证加钱和减钱同时成功或者同时失败
  • 这个时候就需要将事务放在业务层进行处理。

Spring为了管理事务，提供了一个平台事务管理器PlatformTransactionManager

public interface PlatformTransactionManager extends TransactionManager {
    TransactionStatus getTransaction(@Nullable TransactionDefinition var1) throws TransactionException;

    void commit(TransactionStatus var1) throws TransactionException;

    void rollback(TransactionStatus var1) throws TransactionException;
}

commit是用来提交事务，rollback是用来回滚事务
PlatformTransactionManager只是一个接口，Spring还为其提供了一个具体的实现：DataSourceTransactionManager

public class DataSourceTransactionManager extends AbstractPlatformTransactionManager implements ResourceTransactionManager, InitializingBean {
    @Nullable
    private DataSource dataSource;
    private boolean enforceReadOnly;
···
···

}

从名称上可以看出，我们只需要给它一个DataSource对象，它就可以帮你去在业务层管理事务。其内部采用的是JDBC的事务。所以说如果你持久层采用的是JDBC相关的技术，就可以采用这个事务管理器来管理你的事务。而Mybatis内部采用的就是JDBC的事务，所以后期我们Spring整合Mybatis就采用的这个DataSourceTransactionManager事务管理器。

转账案例–需求分析

接下来通过一个案例来学习下Spring是如何来管理事务的。

先来分析下需求:

  • 需求: 实现任意两个账户间转账操作
  • 需求微缩: A账户减钱，B账户加钱

为了实现上述的业务需求，我们可以按照下面步骤来实现下:

  1. 数据层提供基础操作，指定账户减钱（outMoney），指定账户加钱（inMoney）
  2. 业务层提供转账操作（transfer），调用减钱与加钱的操作
  3. 提供2个账号和操作金额执行转账操作
  4. 基于Spring整合MyBatis环境搭建上述操作

转账案例–环境搭建

  • 步骤一：准备数据表
    Tom和Jerry初始金额都是1000
CREATE DATABASE spring_db CHARACTER SET utf8;
USE spring_db;
CREATE TABLE tbl_account(
    id INT PRIMARY KEY AUTO_INCREMENT,
    NAME VARCHAR(35),
    money DOUBLE
);
INSERT INTO tbl_account(`name`,money) VALUES('Tom',1000),('Jerry',1000);
  • 步骤二：创建项目导入jar包
<dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.2.10.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.1.13</version>
        </dependency>

        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.5.6</version>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.33</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>5.2.3.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis-spring</artifactId>
            <version>1.3.0</version>
        </dependency>

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>test</scope>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>5.2.10.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.13.2</version>
        </dependency>
    </dependencies>
  • 步骤三：根据表创建模型类
public class Account {
    private Integer id;
    private String name;
    private Double money;

    public Account() {
    }

    public Account(Integer id, String name, Double money) {
        this.id = id;
        this.name = name;
        this.money = money;
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Double getMoney() {
        return money;
    }

    public void setMoney(Double money) {
        this.money = money;
    }

    @Override
    public String toString() {
        return "Account{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", money=" + money +
                '}';
    }
}
  • 步骤四：创建Dao接口
public interface AccountDao {

    @Update("update tbl_account set money = money + #{money} where name = #{name}")
    void inMoney(@Param("name") String name,@Param("money") Double money);

    @Update("update tbl_account set money = money - #{money} where name = #{name}")
    void outMoney(@Param("name") String name, @Param("money") Double money);
}
  • 步骤五：创建Service接口和实现类
@Service
public class AccountServiceImpl implements AccountService {
    @Autowired
    private AccountDao accountDao;

    @Override
    public void transfer(String out, String in, Double money) {
        accountDao.outMoney(out, money);
        accountDao.inMoney(in, money);
    }
}
  • 步骤六：添加jdbc.properties文件
jdbc.driver=com.mysql.cj.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/spring_db?useSSL=false
jdbc.username=root
jdbc.password=poassword.
  • 步骤七：创建JdbcConfig配置类
public class JdbcConfig {
    @Value("${jdbc.driver}")
    private String driver;
    @Value("${jdbc.url}")
    private String url;
    @Value("${jdbc.username}")
    private String username;
    @Value("${jdbc.password}")
    private String password;

    @Bean
    public DataSource dataSource() {
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDriverClassName(driver);
        dataSource.setUrl(url);
        dataSource.setUsername(username);
        dataSource.setPassword(password);
        return dataSource;
    }
}
  • 步骤八：创建MybatisConfig配置类
public class MyBatisConfig {

    @Bean
    public SqlSessionFactoryBean sqlSessionFactoryBean(DataSource dataSource){
        SqlSessionFactoryBean factory = new SqlSessionFactoryBean();
        factory.setTypeAliasesPackage("com.yolo.domain");
        factory.setDataSource(dataSource);
        return factory;
    }

    @Bean
    public MapperScannerConfigurer mapperScannerConfigurer(){
        MapperScannerConfigurer msc = new MapperScannerConfigurer();
        msc.setBasePackage("com.yolo.dao");
        return msc;
    }
}
  • 步骤九:创建SpringConfig配置类
@Configuration
@ComponentScan("com.yolo")
@PropertySource("jdbc.properties")
@Import({JdbcConfig.class, MyBatisConfig.class})
public class SpringConfig {
}
  • 步骤十：编写测试类
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(classes = SpringConfig.class)
public class AccountServiceTest {
    @Autowired
    private AccountService accountService;

    @Test
    public void testTransfer() {
        accountService.transfer("Tom", "Jerry", 100);
    }
}

在这里插入图片描述

事务管理

上述环境，运行单元测试类，会执行转账操作，Tom的账户会减少100，Jerry的账户会加100。

这是正常情况下的运行结果，但是如果在转账的过程中出现了异常，如

@Service
public class AccountServiceImpl implements AccountService {
    @Autowired
    private AccountDao accountDao;

    @Override
    public void transfer(String out, String in, Double money) {
        accountDao.outMoney(out, money);
        int a = 1 / 0; //模拟异常
        accountDao.inMoney(in, money);
    }
}

这个时候就模拟了转账过程中出现异常的情况，此时进行转账，Tom的账户会减少100，而Jerry的账户却不会增加100
在这里插入图片描述

那我们来分析一下刚才的结果

  • 程序正常执行时，账户金额A减B加，没有问题
  • 程序出现异常后，转账失败，但是异常之前操作成功，异常之后操作失败，整体业务失败

当程序出问题后，我们需要让事务进行回滚，而且这个事务应该是加在业务层上，而Spring的事务管理就是用来解决这类问题的。

Spring事务管理具体的实现步骤如下

  • 步骤一：在需要被事务管理的方法上添加@Transactional注解（注意一般写在接口上而不是实现类上）
public interface AccountService {
    @Transactional
    public void transfer(String out, String in, Double money);
}
  • 步骤二：在JdbcConfig类中配置事务管理器
public class JdbcConfig {
    @Value("${jdbc.driver}")
    private String driver;
    @Value("${jdbc.url}")
    private String url;
    @Value("${jdbc.username}")
    private String username;
    @Value("${jdbc.password}")
    private String password;

    @Bean
    public DataSource dataSource() {
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDriverClassName(driver);
        dataSource.setUrl(url);
        dataSource.setUsername(username);
        dataSource.setPassword(password);
        return dataSource;
    }

    /**
     * 配置事务管理器，mybatis使用的是jdbc事务
     * 一个bean需要外部资源怎么办：将外部资源作为参数传入
     * @param dataSource
     */
    @Bean
    public PlatformTransactionManager transactionManager (DataSource dataSource){
        DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
        transactionManager.setDataSource(dataSource);
        return transactionManager;
    }
}
  • 步骤三：开启事务注解@EnableTransactionManagement
@Configuration
@ComponentScan("com.yolo")
@PropertySource("jdbc.properties")
@Import({JdbcConfig.class, MyBatisConfig.class})
@EnableTransactionManagement
public class SpringConfig {
}
  • 步骤四：运行测试类
    运行程序之后，我们去数据库查看Tom和Jerry的金额，发现没有变化
    那么说明在转换的业务出现错误后，事务就可以控制回滚，保证数据的正确性。

小结

知识点1：@EnableTransactionManagement
在这里插入图片描述
知识点2：@Transactional
在这里插入图片描述
注意：

  • Spring注解式事务通常添加在业务层接口中而不会添加到业务层实现类中，降低耦合
  • 注解式事务可以添加到业务方法上表示当前方法开启事务，也可以添加到接口上表示当前接口所有方法开启事务

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

黑马点评(更新中)

黑马点评(更新中)

黑马点评 1、短信登录 Session实现1.1 分析1.2、Session实现的缺点1.3、其中的问题1.3.1、session覆盖1.3.2、在拦截之后remove User的作用 2、用Redis实现短信登录2.1 分析2.2 代码以及问题2.2.1 String问题2.2.2 刷新问题2.2.3 注入对象问题2.2.4 拦截器order问题 3、缓存3.1…
阅读更多...
6个设计师都在用的样机素材网站

6个设计师都在用的样机素材网站

设计师都在哪里找样机素材&#xff1f;推荐6个样机素材网站&#xff0c;免费下载&#xff0c;赶紧收藏好&#xff01; 1、菜鸟图库 样机图片素材-样机图片模板免费下载 - 菜鸟图库 菜鸟图库有多种类型的设计素材&#xff0c;像平面、电商、UI、办公等素材这里面都能找到&#…
阅读更多...
若依-二级页面的跳转设计

若依-二级页面的跳转设计

配置二级路由页面&#xff0c;就是点击了某个按钮之后会跳转到一个页面中去&#xff0c;比如需要点击查看详情的时候就可以进行页面的跳转。 点击字典类型 进入到字典数据页面。这个页面在左侧是没有的&#xff0c;在导航栏会有展示出来。 在index.js中配置的代码 //path 当前的…
阅读更多...
从新手到专家，Tableau Agent 如何满足不同用户的分析需求？

从新手到专家，Tableau Agent 如何满足不同用户的分析需求？

为什么要构建 Tableau Agent&#xff1f;Tableau 对话式 AI 助理如何助你加速分析&#xff1f; 正在查询相关数据和现有仪表板&#xff0c;看看能否解答业务问题&#xff1f; 还在持续准备、管理和编辑数据&#xff0c;以确保企业数据的质量和可访问性&#xff1f; 希望快速创…
阅读更多...
SDH8323非隔离12V/15V/18V,300MA直插DIP7电源芯片

SDH8323非隔离12V/15V/18V,300MA直插DIP7电源芯片

SDH8323 是高压启动&#xff0c;内置高压MOSFET的电流模式PWMPFM控制器&#xff0c;适用于Buck及Buck-Boost拓扑。 SDH8323 在轻载条件下降频工作&#xff0c;优化轻载条件下的转换效率。在极轻载及空载条件下工作于打嗝模式&#xff0c;从而有效地降低系统的待机功耗。 SDH832…
阅读更多...
DIFY上使用多种大语言模型(MindCraft API)

DIFY上使用多种大语言模型(MindCraft API)

注册MindCraft并创建API KEY 首先我们在智匠MindCraft上注册账号并创建API KEY&#xff0c;参考接口调用文档&#xff0c;查看我们能调用哪些模型。我们可以看到这个开发平台上整合了主流的大语言模型&#xff0c;并且是兼容openai接口的。 进入DIFY的设置界面 然后我们在DIFY上…
阅读更多...
为何一个简单的线上商城 两年销售7000多万？

为何一个简单的线上商城 两年销售7000多万？

有一个销售百货的商城&#xff0c;他们的返现模式极为独特且富有吸引力。无论你消费多少&#xff0c;商城都会随机给你返还一定金额的钱&#xff0c;这个返还范围从10元到1000元不等&#xff0c;确实非常随意。 那么&#xff0c;这个商城采用如此随性的返现模式&#xff0c;业绩…
阅读更多...
软件性能测试有哪些测试指标?性能测试第三方软件测评中心推荐

软件性能测试有哪些测试指标?性能测试第三方软件测评中心推荐

作为衡量软件质量的重要指标之一&#xff0c;软件的性能是一种非功能特性&#xff0c;不关心系统是否可以完成特定的功能&#xff0c;而只关心软件系统在运行时的速度是否足够快、是否消耗足够少的资源&#xff0c;因此软件性能测试至关重要。性能测试是指软件测试人员根据产品…
阅读更多...
监控台操作台在哪些企业中应用比较广泛

监控台操作台在哪些企业中应用比较广泛

在现代企业管理中&#xff0c;监控台操作台作为一种集成了视频监控、音频监听、数据分析及远程控制等多种功能的综合性操作平台&#xff0c;正逐渐成为众多企业不可或缺的重要设备。其广泛的应用领域不仅提升了企业的运营效率&#xff0c;还极大地增强了企业的安全性能。 一、安…
阅读更多...
淘宝程序员没活硬整？在 Excel 和 VSCode 中购物！

淘宝程序员没活硬整？在 Excel 和 VSCode 中购物！

大家好&#xff0c;我是程序员鱼皮&#xff0c;最近某宝网站的改进&#xff0c;属实是有点 “新” 了。 你敢相信这是一个购物网站么&#xff1f; 你可以在 Excel 表格中挑选商品进行购物&#xff0c;还原度极高&#xff0c;这两个图表更是点睛之笔。哪个天才想出来的&#xf…
阅读更多...
C++Linux项目推荐-Web多人聊天+MySQL+Redis+Websocket+Json，可以写简历的C++项目

C++Linux项目推荐-Web多人聊天+MySQL+Redis+Websocket+Json，可以写简历的C++项目

1 项目地址 项目配套视频简介&#xff1a;程序员老廖的个人空间-程序员老廖个人主页-哔哩哔哩视频 (bilibili.com) 1.1 项目原有功能 https://github.com/anarthal/servertech-chat.git 功能&#xff1a; 支持HTTP请求&#xff0c;掌握HTTP API json的请求相应 支持Webso…
阅读更多...
如何使用ssm实现疫情居家办公OA系统

如何使用ssm实现疫情居家办公OA系统

TOC 10902ssm疫情居家办公OA系统 系统概述 进过系统的分析后&#xff0c;就开始记性系统的设计&#xff0c;系统设计包含总体设计和详细设计。总体设计只是一个大体的设计&#xff0c;经过了总体设计&#xff0c;我们能够划分出系统的一些东西&#xff0c;例如文件、文档、数…
阅读更多...
手机怎么玩荒野大镖客2？GameViewer远程助你手机随时随地畅玩大表哥2

手机怎么玩荒野大镖客2？GameViewer远程助你手机随时随地畅玩大表哥2

手机免费玩电脑游戏&#xff0c;原来手机也能随时随地玩荒野大镖客2&#xff1f;如果你想你手机随时随地畅玩大表哥2&#xff0c;可以使用网易GameViewer远程来实现。 GameViewer远程4K蓝光144帧的高画质&#xff0c;可以让你在玩荒野大镖客2时&#xff0c;体验到开放大世界的所…
阅读更多...
2024年11月软考准考证什么时候打印？

2024年11月软考准考证什么时候打印？

打印时间一览表&#xff1a; 北京&#xff1a;2024年11月5日至11月8日 上海&#xff1a;2024年11月6日10:00至11月8日16:00 天津&#xff1a;2024年11月5日9:00后 重庆&#xff1a;2024年11月4日9:00至10日9:05 广东&#xff1a;2024年11月5日9:00至8日17:00 深圳&#xf…
阅读更多...
靠“代工+营销”支撑，又突击分红10亿元，毛戈平冲刺上市为哪般

靠“代工+营销”支撑，又突击分红10亿元，毛戈平冲刺上市为哪般

撰稿|行星 来源|贝多财经 10月9日&#xff0c;毛戈平化妆品股份有限公司&#xff08;下称“毛戈平”或“毛戈平公司”&#xff09;在港交所更新招股书&#xff0c;继续推进港股上市进程。此前&#xff0c;毛戈平曾于4月8日向港交所递表&#xff0c;但因财务资料已过有效期而“…
阅读更多...
selenium：Select类操作复选框和下拉框（7）

selenium：Select类操作复选框和下拉框（7）

复选框/下拉框操作的Select类 主要使用selinium中的类Select来模拟选择网页上的下拉框或者复选框中的内容&#xff0c;使用前先导入 from selenium.webdriver.support.ui import Select 主要方法如下&#xff1a; 函数 功能 select_by_value 根据复选框/下拉框的值选择 se…
阅读更多...
openfeign解释及其应用

openfeign解释及其应用

文章目录 前言一、FeignClient详解注解使用范围注解属性说明value()name()contextId()qualifiers()configurationfallbackfallbackFactorypath 二、openfeign走网关gateway 前言 本文讨论的是springcloud分布式微服务架构下&#xff0c;如何让openfeign请求也走gateway网关 本…
阅读更多...
浏览器服务端文件下载控制(安全阻止、文件浏览器打开还是下载行为控制)

浏览器服务端文件下载控制(安全阻止、文件浏览器打开还是下载行为控制)

文章目录 简介Chrome已阻止不安全内容下载PDF直接打开txt、xml、js文件被自动打开了而不是下载阿里OSS设置response header阿里OSS修改metadata 简介 随着浏览器的发展&#xff0c;有很多安全方面的限制&#xff0c;对我们的文件下载行为产生了很大的影响。 在JavaScript下载…
阅读更多...
鸿蒙OS投票机制

鸿蒙OS投票机制

(基于openharmony5.0) 投票机制 param get | grep ohos.boot.time 图 投票机制参数图 只有当所有的投票完成&#xff0c;开机动画才会退出&#xff0c;整理需要投票的系统应用&#xff08;三方应用不参与投票&#xff09;如下图所示&#xff1a; 以进程foundation为例&…
阅读更多...
pytorh学习笔记——波士顿房价预测

pytorh学习笔记——波士顿房价预测

机器学习的“hello world”&#xff1a;波士顿房价预测 波士顿房价预测的背景不用提了&#xff0c;简单了解一下数据集的结构。 波士顿房价的数据集&#xff0c;共有506组数据&#xff0c;每组数据共14项&#xff0c;前13项是影响房价的各种因素&#xff0c;比如&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023