首页 > 软件编程 > java > SpringBoot声明式事务

SpringBoot中的声明式事务详解

2023-08-10 09:03:07 作者：ycfxhsw

这篇文章主要介绍了SpringBoot中的声明式事务详解,Spring采用统一的机制来处理不同的数据访问技术的事务， Spring的事务提供一个PlatformTransactionManager的接口，不同的数据访问技术使用不同的接口实现,需要的朋友可以参考下

事务

所有数据访问技术都有事务机制，这些技术提供了API来开启事务、提交事务完成数据操作，或者在发生错误的时候回滚数据。

Spring采用统一的机制来处理不同的数据访问技术的事务， Spring的事务提供一个 PlatformTransactionManager 的接口，不同的数据访问技术使用不同的接口实现。

Data Tech	实现
JDBC	DataSourceTransactionManager
JPA	JPATransactionManager
Hibernate	HibernateTransactionManager
JDO	JDOTransactionManager
分布式事务	JtaTransactionManager

Mybatis-Spring依赖于 DataSourceTransactionManager ，没有自己实现 PlatformTransactionManager。

而得益于SpringBoot的自动配置机制，为我们自动开启了声明式事务支持，我们无需添加注解 @EnableTransactionManagement 。

事务基础

Spring提供一个 @EnableTransactionManagement 注解在配置类上开启声明式事务支持，自动扫描加了 @Transactional 注解的类和方法，加入事务支持。

@Transactional 的配置项：

配置项	含义	备注
value	定义事务管理器	它是 SpringIOC 容器的一个Bean id，这个Bean需要实现接口 PlatformTransactionManager
transactionManager	定义事务管理器	它是 SpringIOC 容器的一个Bean id，这个Bean需要实现接口 PlatformTransactionManager
isolation	隔离级别	这是一个数据库在多个事务同时存在时的概念。默认值是数据库默认隔离级别
propagation	传播行为	传播行为是方法之间调用的问题。默认值为Progation.REQUIRED
timeout	超时时间	单位为秒，当超时时，会引发异常，默认会导致事务回滚
readOnly	是否开启只读事务	默认 false
rollbackFor	回滚事务的异常类定义	只有当方法产生所定义的异常时，才会回滚事务，否则提交事务
rollbackForClassName	回滚事务的异常类名定义	同 rollbackFor，只是使用类名称定义
noRollbackFor	当产生哪些异常不回滚事务	当产生所定义异常时，Spring将继续提交事务
noRollbackForClassName	当产生哪些异常不回滚事务	同 noRollbackFor，只是使用类名称定义

propagation

事务的传播机制，主要有以下几种，默认是 REQUIRED：

REQUIRED - 方法A调用时候没有事务新建一个事务，在方法A中调用方法B，将使用相同的事务，如果方法B发生异常需要回滚，整个事务回滚。
REQUIRES_NEW - 方法A调用方法B时，无论是否存在事务都开启一个新事务，这样B方法异常不会导致A的数据回滚。
NESTED - 和REQUIRES_NEW类似，但是只支持JDBC，不支持JPA或Hibernate
SUPPORTS - 方法调用时有事务就用事务，没事务就不用事务
NOT_SUPPORTED - 强制方法不在事务中执行，若有事务，在方法调用到结束阶段先挂起事务。
NEVER - 强制不能有事务，若有事务就抛出异常
MANDATORY - 强制必须有事务，如果没有事务就抛出异常

isolation

事务的隔离级别，决定了事务的完整性，主要一下几种，默认是DEFAULT：

READ_UNCOMMITTED - A事务修改记录但没提交，B事务可读取到修改后的值。可导致脏读、不可重复读、幻读。
READ_COMMITTED - A事务修改并提交后，B事务才能读取到修改后的值，阻止了脏读，但可能导致不可重复读和幻读。
REPEATABLE_READ - A事务读取了一条记录，B事务将不能修改这条记录，阻止脏读和不可重复读，但是可能出现幻读。
SERIALIZABLE - 事务是顺序执行的，可避免所有缺陷，但是开销很大。
DEFAULT - 使用当前数据库默认隔离级别，入Oracle、SQL Server是READ_COMMITTED，MySQL是REPEATABLE_READ

timeout

事务过期时间，默认是当前数据库默认事务过期时间。

readOnly

指定是否为只读事务，默认是false。

如果你一次执行单条查询语句，则没有必要启用事务支持，数据库默认支持SQL执行期间的读一致性。

如果你一次执行多条查询语句，例如统计查询，报表查询，在这种场景下，多条查询SQL必须保证整体的读一致性，否则，在前条SQL查询之后，后条SQL查询之前，数据被其他用户改变，则该次整体的统计查询将会出现读数据不一致的状态，此时，应该启用只读事务支持。

只读事务与读写事务区别：

对于只读查询，可以指定事务类型为 readonly，即只读事务。

由于只读事务不存在数据的修改，因此数据库将会为只读事务提供一些优化手段，例如Oracle对于只读事务，不启动回滚段，不记录回滚log。

rollbackFor

指定哪些异常可以导致事务回滚，默认是 Throwable 的子类。

noRollbackFor

执行哪些异常不可用引起事务回滚，默认是 Throwable 的子类。

实战篇

实际项目中，使用SpringBoot的默认配置就已经足够满足我们的需求了。本篇将通过几个例子来演示如何使用@Transactional注解，在出现异常时候回滚或不回滚数据。

使用的DAO技术是MyBatis进行数据访问，使用druid数据库连接池，另外配合mybatis-plus，实现数据访问层。

引入依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>${mysql-connector.version}</version>
    <scope>runtime</scope>
</dependency>
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>${druid.version}</version>
</dependency>
<!-- MyBatis plus增强和springboot的集成-->
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus</artifactId>
    <version>${mybatis-plus.version}</version>
</dependency>
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatisplus-spring-boot-starter</artifactId>
    <version>${mybatisplus-spring-boot-starter.version}</version>
</dependency>

配置数据库连接：

###################  spring配置  ###################
spring:
  profiles:
    active: dev
  datasource:
    url: jdbc:mysql://127.0.0.1:3306/test?useSSL=false&autoReconnect=true&tinyInt1isBit=false&useUnicode=true&characterEncoding=utf8
    username: root
    password: xxxxx

然后增加mybatis个性化配置：

###################  mybatis-plus配置  ###################
mybatis-plus:
  mapper-locations: classpath*:com/xncoding/trans/dao/repository/mapping/*.xml
  typeAliasesPackage: >
    com.dao.entity
  global-config:
    id-type: 0  # 0:数据库ID自增   1:用户输入id  2:全局唯一id(IdWorker)  3:全局唯一ID(uuid)
    db-column-underline: false
    refresh-mapper: true
  configuration:
    map-underscore-to-camel-case: true
    cache-enabled: true #配置的缓存的全局开关
    lazyLoadingEnabled: true #延时加载的开关
    multipleResultSetsEnabled: true #开启的话，延时加载一个属性时会加载该对象全部属性，否则按需加载属性

增加实体类User：

@TableName(value = "t_user")
public class User extends Model<User> {
    /**
     * 主键ID
     */
    @TableId(value="id", type= IdType.AUTO)
    private Integer id;
    private String username;
    private String password;
    // 省略 get/set 方法
    @Override
    protected Serializable pkVal() {
        return this.id;
    }
}

增加 UserMapper 类：

public interface UserMapper extends BaseMapper<User> {}

增加 Mybatis 配置类：

@Configuration
@EnableTransactionManagement(order = 2)
@MapperScan(basePackages = {"com.dao.repository"})
public class MybatisPlusConfig {
    @Resource
    private DruidProperties druidProperties;
    /**
     * 单数据源连接池配置
     */
    @Bean
    public DruidDataSource singleDatasource() {
        DruidDataSource dataSource = new DruidDataSource();
        druidProperties.config(dataSource);
        return dataSource;
    }
}

定义Service，并注入UserMapper：

@Service
public class UserService {
    @Resource
    private UserMapper userMapper;
}

增加Controller，注入Service，定义几个url来做测试用：

@RestController
public class UserController {
    @Resource
    private UserService userService;
}

到此为止项目初始化完成，可以在Service中添加方法进行声明式事务测试了。

异常回滚

@Transactional 注解可以放到类也可以放到方法上，如果放到类上面会对所有 public 方法添加注解，不过你仍然可以在方法上面加这个注解，会覆盖类上面声明的事务注解。

先实验一个抛出异常会回滚的方法：

/**
 * 增删改要写 ReadOnly=false 为可写
 * @param user 用户
 */
@Transactional(readOnly = false)
public void updateUserError(User user) {
    userMapper.updateById(user);
    errMethod(); // 执行一个会抛出异常的方法
}
private void errMethod() {
    System.out.println("error");
    throw new RuntimeException("runtime");
}

然后在Controller里面添加一个url调用此方法：

&#64;RequestMapping(&#34;/errorUpdate&#34;)    public Object first() {<!-- -->        User user &#61; new User();        user.setId(1);        user.setUsername(&#34;admin&#34;);        user.setPassword(&#34;admin&#34;);        userService.updateUserError(user);        return &#34;first controller&#34;;    }}

数据库里面先插入一条数据： 1|admin|123

启动应用后访问地址： //localhost:8092/errorUpdate

控制台打印异常：

@RequestMapping("/errorUpdate")
    public Object first() {
        User user = new User();
        user.setId(1);
        user.setUsername("admin");
        user.setPassword("admin");
        userService.updateUserError(user);
        return "first controller";
    }
}

查看数据库中记录： 1|admin|123 ，没有变动，说明回滚成功。

异常不回滚

你还可以指定特定异常不回滚，比如自定义一个MyException，抛出这个异常不回滚。

public class MyException extends RuntimeException {
    public MyException() {
        super();
    }
    public MyException(String runtime) {
        super(runtime);
    }
}

然后通过指定这个异常不回滚：

@Transactional(readOnly = false, noRollbackFor = {MyException.class})
public void updateUserError2(User user) {
    userMapper.updateById(user);
    errMethod2(); // 执行一个会抛出自定义异常的方法
}
private void errMethod2() {
    System.out.println("error");
    throw new MyException("runtime");
}

然后再定义一个url来验证：

@RequestMapping("/errorUpdate2")
public Object second() {
    User user = new User();
    user.setId(1);
    user.setUsername("admin");
    user.setPassword("admin");
    userService.updateUserError(user);
    return "second controller";
}

重启服务器，访问地址：//localhost:8092/errorUpdate2

控制台仍然报异常：

Caused by: com.xncoding.trans.exception.MyException: runtime
at com.xncoding.trans.service.UserService.errMethod2(UserService.java:43) ~[classes/:na]
at com.xncoding.trans.service.UserService.updateUserError2(UserService.java:34) ~[classes/:na]

看看数据库中记录：1|admin|admin，更改成功，说明抛出这个MyException异常后并不会回滚。

到此这篇关于SpringBoot中的声明式事务详解的文章就介绍到这了,更多相关SpringBoot声明式事务内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

SpringBoot中的声明式事务详解

事务

事务基础

实战篇

异常回滚

异常不回滚

您可能感兴趣的文章: