SpringBoot 系列教程之声明式事务 Transactional

时间  2020-01-21
标签 springboot 系列 教程 声明 事务 transactional 栏目 Spring 繁體版
原文   原文链接

200119-SpringBoot 系列教程之声明式事务 Transactional

当咱们但愿一组操做，要么都成功，要么都失败时，每每会考虑利用事务来实现这一点；以前介绍的 db 操做，主要在于单表的 CURD，本文将主要介绍声明式事务@Transactional的使用姿式html

<!-- more -->java

I. 配置

本篇主要介绍的是jdbcTemplate配合事务注解@Transactional的使用姿式，至于 JPA，mybatis 在实际的使用区别上，并不大，后面会单独说明mysql

建立一个 SpringBoot 项目，版本为2.2.1.RELEASE，使用 mysql 做为目标数据库，存储引擎选择Innodb，事务隔离级别为 RRgit

1. 项目配置

在项目pom.xml文件中，加上spring-boot-starter-jdbc，会注入一个DataSourceTransactionManager的 bean，提供了事务支持github

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>

2. 数据库配置

进入 spring 配置文件application.properties，设置一下 db 相关的信息spring

## DataSource
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/story?useUnicode=true&characterEncoding=UTF-8&useSSL=false
spring.datasource.username=root
spring.datasource.password=

3. 数据库

新建一个简单的表结构，用于测试sql

CREATE TABLE `money` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `name` varchar(20) NOT NULL DEFAULT '' COMMENT '用户名',
  `money` int(26) NOT NULL DEFAULT '0' COMMENT '钱',
  `is_deleted` tinyint(1) NOT NULL DEFAULT '0',
  `create_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '建立时间',
  `update_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
  PRIMARY KEY (`id`),
  KEY `name` (`name`)
) ENGINE=InnoDB AUTO_INCREMENT=551 DEFAULT CHARSET=utf8mb4;

II. 使用说明

1. 初始化

为了体现事务的特色，在不考虑 DDL 的场景下，DML 中的增长，删除 or 修改属于不可缺乏的语句了，因此咱们须要先初始化几个用于测试的数据数据库

@Service
public class SimpleDemo {
    @Autowired
    private JdbcTemplate jdbcTemplate;

    @PostConstruct
    public void init() {
        String sql = "replace into money (id, name, money) values (120, '初始化', 200)," +
                "(130, '初始化', 200)," +
                "(140, '初始化', 200)," +
                "(150, '初始化', 200)";
        jdbcTemplate.execute(sql);
    }
}

咱们使用replace into语句来初始化数据，每次 bean 建立以后都会执行，确保每次执行后面你的操做时，初始数据都同样mybatis

2. transactional

这个注解能够放在类上，也能够放在方法上；若是是标注在类上，则这个类的全部公共方法，都支持事务；app

若是类和方法上都有，则方法上的注解相关配置，覆盖类上的注解

下面是一个简单的事务测试 case

private boolean updateName(int id) {
    String sql = "update money set `name`='更新' where id=" + id;
    jdbcTemplate.execute(sql);
    return true;
}

public void query(String tag, int id) {
    String sql = "select * from money where id=" + id;
    Map map = jdbcTemplate.queryForMap(sql);
    System.out.println(tag + " >>>> " + map);
}

private boolean updateMoney(int id) {
    String sql = "update money set `money`= `money` + 10 where id=" + id;
    jdbcTemplate.execute(sql);
    return false;
}

/**
 * 运行异常致使回滚
 *
 * @return
 */
@Transactional
public boolean testRuntimeExceptionTrans(int id) {
    if (this.updateName(id)) {
        this.query("after updateMoney name", id);
        if (this.updateMoney(id)) {
            return true;
        }
    }

    throw new RuntimeException("更新失败，回滚!");
}

在咱们须要开启事务的公共方法上添加注解@Transactional，代表这个方法的正确调用姿式下，若是方法内部执行抛出运行异常，会出现事务回滚

注意上面的说法，正确的调用姿式，事务才会生效；换而言之，某些 case 下，不会生效

3. 测试

接下来，测试一下上面的方法事务是否生效，咱们新建一个 Bean

@Component
public class TransactionalSample {
    @Autowired
    private SimpleDemo simpleService;

    public void testSimpleCase() {
        System.out.println("============ 事务正常工做 start ========== ");
        simpleService.query("transaction before", 130);
        try {
            // 事务能够正常工做
            simpleService.testRuntimeExceptionTrans(130);
        } catch (Exception e) {
        }
        simpleService.query("transaction end", 130);
        System.out.println("============ 事务正常工做 end ========== \n");
    }
}

在上面的调用中，打印了修改以前的数据和修改以后的数据，若是事务正常工做，那么这两次输出应该是一致的

实际输出结果以下，验证了事务生效，中间的修改 name 的操做被回滚了

============ 事务正常工做 start ==========
transaction before >>>> {id=130, name=初始化, money=200, is_deleted=false, create_at=2020-01-19 16:15:21.0, update_at=2020-01-19 16:15:21.0}
after updateMoney name >>>> {id=130, name=更新, money=200, is_deleted=false, create_at=2020-01-19 16:15:21.0, update_at=2020-01-19 16:15:22.0}
transaction end >>>> {id=130, name=初始化, money=200, is_deleted=false, create_at=2020-01-19 16:15:21.0, update_at=2020-01-19 16:15:21.0}
============ 事务正常工做 end ==========

4. 注意事项

a. 适用场景

在使用注解@Transactional声明式事务时，其主要是借助 AOP，经过代理来封装事务的逻辑，因此 aop 不生效的场景，也适用于这个事务注解不生效的场景

简单来说，下面几种 case，注解不生效

  • private 方法上装饰@Transactional，不生效

  • 内部调用，不生效

    • 举例如: 外部调用服务 A 的普通方法 m，而这个方法 m，调用本类中的声明有事务注解的方法 m2, 正常场景下，事务不生效

b. 异常类型

此外，注解@Transactional默认只针对运行时异常生效，以下面这种 case，虽然是抛出了异常，可是并不会生效

@Transactional
public boolean testNormalException(int id) throws Exception {
    if (this.updateName(id)) {
        this.query("after updateMoney name", id);
        if (this.updateMoney(id)) {
            return true;
        }
    }

    throw new Exception("声明异常");
}

若是须要它生效，能够借助rollbackFor属性来指明，触发回滚的异常类型

@Transactional(rollbackFor = Exception.class)
public boolean testSpecialException(int id) throws Exception {
    if (this.updateName(id)) {
        this.query("after updateMoney name", id);
        if (this.updateMoney(id)) {
            return true;
        }
    }

    throw new IllegalArgumentException("参数异常");
}

测试一下上面的两种 case

public void testSimpleCase() {
    System.out.println("============ 事务不生效 start ========== ");
    simpleService.query("transaction before", 140);
    try {
        // 由于抛出的是非运行异常，不会回滚
        simpleService.testNormalException(140);
    } catch (Exception e) {
    }
    simpleService.query("transaction end", 140);
    System.out.println("============ 事务不生效 end ========== \n");


    System.out.println("============ 事务生效 start ========== ");
    simpleService.query("transaction before", 150);
    try {
        // 注解中，指定全部异常都回滚
        simpleService.testSpecialException(150);
    } catch (Exception e) {
    }
    simpleService.query("transaction end", 150);
    System.out.println("============ 事务生效 end ========== \n");
}

输出结果以下，正好验证了上面提出的内容

============ 事务不生效 start ==========
transaction before >>>> {id=140, name=初始化, money=200, is_deleted=false, create_at=2020-01-19 16:15:21.0, update_at=2020-01-19 16:15:21.0}
after updateMoney name >>>> {id=140, name=更新, money=200, is_deleted=false, create_at=2020-01-19 16:15:21.0, update_at=2020-01-19 16:15:22.0}
transaction end >>>> {id=140, name=更新, money=210, is_deleted=false, create_at=2020-01-19 16:15:21.0, update_at=2020-01-19 16:15:22.0}
============ 事务不生效 end ==========

============ 事务生效 start ==========
transaction before >>>> {id=150, name=初始化, money=200, is_deleted=false, create_at=2020-01-19 16:15:21.0, update_at=2020-01-19 16:15:21.0}
after updateMoney name >>>> {id=150, name=更新, money=200, is_deleted=false, create_at=2020-01-19 16:15:21.0, update_at=2020-01-19 16:15:22.0}
transaction end >>>> {id=150, name=初始化, money=200, is_deleted=false, create_at=2020-01-19 16:15:21.0, update_at=2020-01-19 16:15:21.0}
============ 事务生效 end ==========

c. @Transactional 注解的属性信息

上面的内容，都属于比较基本的知识点，足以知足咱们通常的业务需求，若是须要进阶的话，有必要了解一下属性信息

如下内容来自: 透彻的掌握 Spring 中@transactional 的使用
属性名 说明
name 当在配置文件中有多个 TransactionManager , 能够用该属性指定选择哪一个事务管理器。
propagation 事务的传播行为，默认值为 REQUIRED。
isolation 事务的隔离度，默认值采用 DEFAULT。
timeout 事务的超时时间，默认值为-1。若是超过该时间限制但事务尚未完成，则自动回滚事务。
read-only 指定事务是否为只读事务，默认值为 false；为了忽略那些不须要事务的方法，好比读取数据，能够设置 read-only 为 true。
rollback-for 用于指定可以触发事务回滚的异常类型，若是有多个异常类型须要指定，各种型之间能够经过逗号分隔。
no-rollback- for 抛出 no-rollback-for 指定的异常类型，不回滚事务。

关于上面几个属性的使用实例，以及哪些状况下，会致使声明式事务不生效，会新开坑进行说明，敬请期待。。。

II. 其余

0. 系列博文&源码

系列博文

源码

1. 一灰灰 Blog

尽信书则不如，以上内容，纯属一家之言，因我的能力有限，不免有疏漏和错误之处，如发现 bug 或者有更好的建议，欢迎批评指正，不吝感激

下面一灰灰的我的博客，记录全部学习和工做中的博文，欢迎你们前去逛逛

一灰灰blog

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程