springboot mybatis 事务管理

本文主要讲述 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

    <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>

 

2、application.properties

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

# 主数据源 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

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

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

 

3、Service 层

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

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

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

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

给出一些示例代码

@Service
public class GeoFenceService {
@Autowired
</span><span style="color: rgba(0, 0, 255, 1)">private</span><span style="color: rgba(0, 0, 0, 1)"> MoonlightMapper moonlightMapper;

@Transactional
</span><span style="color: rgba(0, 0, 255, 1)">public</span> <span style="color: rgba(0, 0, 255, 1)">int</span><span style="color: rgba(0, 0, 0, 1)"> addGeoFence(GeoFence geoFence) {
    String formatTime </span>=<span style="color: rgba(0, 0, 0, 1)"> TimeFunction.transTimeToFormatPerfect(System.currentTimeMillis());
    geoFence.setCreateTime(formatTime);
    geoFence.setUpdateTime(formatTime);
    </span><span style="color: rgba(0, 0, 255, 1)">return</span><span style="color: rgba(0, 0, 0, 1)"> moonlightMapper.insertOne(geoFence);
}

@Transactional
</span><span style="color: rgba(0, 0, 255, 1)">public</span> <span style="color: rgba(0, 0, 255, 1)">int</span> batchGeoFence(List&lt;GeoFence&gt;<span style="color: rgba(0, 0, 0, 1)"> geoFenceList) {
    String formatTime </span>=<span style="color: rgba(0, 0, 0, 1)"> TimeFunction.transTimeToFormatPerfect(System.currentTimeMillis());
    </span><span style="color: rgba(0, 0, 255, 1)">for</span><span style="color: rgba(0, 0, 0, 1)"> (GeoFence geoFence : geoFenceList) {
        geoFence.setCreateTime(formatTime);
        geoFence.setUpdateTime(formatTime);
    }
    </span><span style="color: rgba(0, 0, 255, 1)">return</span><span style="color: rgba(0, 0, 0, 1)"> moonlightMapper.insertBatch(geoFenceList);
}

}

 

4、开启事务

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

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

 

三、测试一下

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

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

@Service
public class GeoFenceService {
@Autowired
</span><span style="color: rgba(0, 0, 255, 1)">private</span><span style="color: rgba(0, 0, 0, 1)"> MoonlightMapper moonlightMapper;

@Transactional
</span><span style="color: rgba(0, 0, 255, 1)">public</span> <span style="color: rgba(0, 0, 255, 1)">int</span><span style="color: rgba(0, 0, 0, 1)"> addGeoFence(GeoFence geoFence) {
    String formatTime </span>=<span style="color: rgba(0, 0, 0, 1)"> TimeFunction.transTimeToFormatPerfect(System.currentTimeMillis());
    geoFence.setCreateTime(formatTime);
    geoFence.setUpdateTime(formatTime);
    </span><span style="color: rgba(0, 0, 255, 1)">int</span> count =<span style="color: rgba(0, 0, 0, 1)"> moonlightMapper.insertOne(geoFence);
    String a </span>= <span style="color: rgba(0, 0, 255, 1)">null</span><span style="color: rgba(0, 0, 0, 1)">;
    a.indexOf(</span>'c'<span style="color: rgba(0, 0, 0, 1)">);
    </span><span style="color: rgba(0, 0, 255, 1)">return</span><span style="color: rgba(0, 0, 0, 1)"> count;
}

}