springboot mybatis 事务管理

r囧r小猫 2023-06-21 10:10 82阅读 0赞

本文主要讲述springboot提供的声明式的事务管理机制。

**一、一些概念**

声明式的事务管理是基于AOP的，在springboot中可以通过@Transactional注解的方式获得支持，这种方式的优点是：

1）非侵入式，业务逻辑不受事务管理代码的污染。

2）方法级别的事务回滚，合理划分方法的粒度可以做到符合各种业务场景的事务管理。

本文使用目前最常用的mybatis框架来配置springboot的事务管理机制。下面进入配置方法介绍。

**二、springboot mybatis事务配置**

**1、看一下pom依赖**

其中：

1）<parent></parent>标签引入springboot父依赖

2）使用了spring和mybatis集成包，整合spring和mybatis

3）mysql数据库驱动包

4）序列化支持fastjson

![复制代码][aHR0cHM6Ly9jb21tb24uY25ibG9ncy5jb20vaW1hZ2VzL2NvcHljb2RlLmdpZg]

<parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>1.4.3.RELEASE</version>
        </parent>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>1.1.1</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-jdbc</artifactId>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>fastjson</artifactId>
                <version>1.2.19</version>
            </dependency>
        </dependencies>

![复制代码][aHR0cHM6Ly9jb21tb24uY25ibG9ncy5jb20vaW1hZ2VzL2NvcHljb2RlLmdpZg]

**2、application.properties**

这个配置主要是实现配置mybatis数据源，这超出了本文的叙述范围，大家可以参照这篇博客。[http://www.cnblogs.com/kangoroo/p/7133543.html][http_www.cnblogs.com_kangoroo_p_7133543.html]

![复制代码][aHR0cHM6Ly9jb21tb24uY25ibG9ncy5jb20vaW1hZ2VzL2NvcHljb2RlLmdpZg]

# 主数据源 moonlight
    spring.datasource.moonlight.driverClassName = com.mysql.jdbc.Driver
    spring.datasource.moonlight.url=jdbc:mysql://10.93.84.53:3306/moonlight?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true&autoReconnect=true&failOverReadOnly=false
    spring.datasource.moonlight.username = root
    spring.datasource.moonlight.password = 1234
    spring.datasource.moonlight.poolMaximumActiveConnections=400
    spring.datasource.moonlight.poolMaximumIdleConnections=200
    spring.datasource.moonlight.poolMaximumCheckoutTime=20000

![复制代码][aHR0cHM6Ly9jb21tb24uY25ibG9ncy5jb20vaW1hZ2VzL2NvcHljb2RlLmdpZg]

之后你可以根据添加的数据源，写好mapper也就是dao层代码。

DAO层代码是使用XML配置方式，还是使用注解实现方式，对事务管理都是没有影响的。

**3、Service层**

在设计service层的时候，应该合理的抽象出方法包含的内容。

然后将方法用@Trasactional注解注释，默认的话在抛出Exception.class异常的时候，就会触发方法中所有数据库操作回滚，当然这指的是增、删、改。

当然，@Transational方法是可以带参数的，具体的参数解释如下：

<table>  &nbsp;  
 <thead> 
  <tr> 
   <th>属性</th> 
   <th>类型</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>value</td> 
   <td>String</td> 
   <td>可选的限定描述符，指定使用的事务管理器</td> 
  </tr> 
  <tr> 
   <td>propagation</td> 
   <td>enum: Propagation</td> 
   <td>可选的事务传播行为设置</td> 
  </tr> 
  <tr> 
   <td>isolation</td> 
   <td>enum: Isolation</td> 
   <td>可选的事务隔离级别设置</td> 
  </tr> 
  <tr> 
   <td>readOnly</td> 
   <td>boolean</td> 
   <td>读写或只读事务，默认读写</td> 
  </tr> 
  <tr> 
   <td>timeout</td> 
   <td>int (in seconds granularity)</td> 
   <td>事务超时时间设置</td> 
  </tr> 
  <tr> 
   <td>rollbackFor</td> 
   <td>Class对象数组，必须继承自Throwable</td> 
   <td>导致事务回滚的异常类数组</td> 
  </tr> 
  <tr> 
   <td>rollbackForClassName</td> 
   <td>类名数组，必须继承自Throwable</td> 
   <td>导致事务回滚的异常类名字数组</td> 
  </tr> 
  <tr> 
   <td>noRollbackFor</td> 
   <td>Class对象数组，必须继承自Throwable</td> 
   <td>不会导致事务回滚的异常类数组</td> 
  </tr> 
  <tr> 
   <td>noRollbackForClassName</td> 
   <td>类名数组，必须继承自Throwable</td> 
   <td>不会导致事务回滚的异常类名字数组</td> 
  </tr> 
 </tbody> 
</table>

给出一些示例代码

![复制代码][aHR0cHM6Ly9jb21tb24uY25ibG9ncy5jb20vaW1hZ2VzL2NvcHljb2RlLmdpZg]

@Service
    public class GeoFenceService {
    
        @Autowired
        private MoonlightMapper moonlightMapper;
    
        @Transactional
        public int addGeoFence(GeoFence geoFence) {
            String formatTime = TimeFunction.transTimeToFormatPerfect(System.currentTimeMillis());
            geoFence.setCreateTime(formatTime);
            geoFence.setUpdateTime(formatTime);
            return moonlightMapper.insertOne(geoFence);
        }
    
        @Transactional
        public int batchGeoFence(List<GeoFence> geoFenceList) {
            String formatTime = TimeFunction.transTimeToFormatPerfect(System.currentTimeMillis());
            for (GeoFence geoFence : geoFenceList) {
                geoFence.setCreateTime(formatTime);
                geoFence.setUpdateTime(formatTime);
            }
            return moonlightMapper.insertBatch(geoFenceList);
        }
    }

![复制代码][aHR0cHM6Ly9jb21tb24uY25ibG9ncy5jb20vaW1hZ2VzL2NvcHljb2RlLmdpZg]

**4、开启事务**

最后你要在Application类中开启事务管理，开启事务管理很简单，只需要@EnableTransactionManagement注解就行

![复制代码][aHR0cHM6Ly9jb21tb24uY25ibG9ncy5jb20vaW1hZ2VzL2NvcHljb2RlLmdpZg]

@EnableTransactionManagement
    @SpringBootApplication
    public class WebApplication {
        public static void main(String[] args) {
            SpringApplication.run(WebApplication.class, args);
        }
    }

![复制代码][aHR0cHM6Ly9jb21tb24uY25ibG9ncy5jb20vaW1hZ2VzL2NvcHljb2RlLmdpZg]

**三、测试一下**

可以做一个简单的测试，主动抛出异常，测试一下是否真的能保证事务性。

在执行完插入之后，手动抛出一个空指针异常，可以发现数据真的回滚了。

![复制代码][aHR0cHM6Ly9jb21tb24uY25ibG9ncy5jb20vaW1hZ2VzL2NvcHljb2RlLmdpZg]

[aHR0cHM6Ly9jb21tb24uY25ibG9ncy5jb20vaW1hZ2VzL2NvcHljb2RlLmdpZg]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9jb21tb24uY25ibG9ncy5jb20vaW1hZ2VzL2NvcHljb2RlLmdpZg
[http_www.cnblogs.com_kangoroo_p_7133543.html]: http://www.cnblogs.com/kangoroo/p/7133543.html