Spring 事务处理

前言:

事务处理的本质

在学习事务处理前,需要明确一点:

数据库操作最终都要使用到jdbc,那么无论上层如何封装,底层都是调用connection的commit,rollback来完成

烦人的事务处理:

在日常开发中,数据访问层(dao)必然需要进行事务的处理,但是我们会发现,事务处理的代码通常是简单的重复的,编写这样的重复代码会浪费大量的时间,所以我们需要找到一种方案可以将这些重复的代码进行抽取,以便与管理维护和复用,

我们的需求:在一系列数据库操作上的方法上增加额外的事务处理代码,让原来的方法中只关注具体的数据处理,即在原本以及存在的数据库操作方法上添加额外的事务处理逻辑

到这里你应该想到aop了,没错! 这样的场景下aop是最好的解决方案;

解决方案:aop

回顾一下spring的aop:在结合目前的需求

1.将目标对象(dao)放入spring容器

2.告知spring你的通知代码是什么(事务处理)

3.告知spring 哪些方法(dao的crud)要应用那些通知(不同的事务处理代码)

4.从spring中获取代理对象来完成原本的crud,代理对象会自动完成事务处理

spring 事务处理api

spring作为框架,需要进行详细的设计,全方位的考虑事务处理的各个方面,而不仅是简单的帮你执行commit,rollback;

spring对事务处理进行了抽象定义,形成了一套具体的api结构,如下:

• transactiondefinition:定义事务的具体属性,如隔离级别,超时设置,传播行为等

• transactionstatus: 用于获取当前事务的状态信息

• platformtransactionmananger: 主要的事务管理接口,提供三个实现类对应不同场景

类型	场景
datasourcetransactionmanager	使用spring jdbc或 ibatis 进行持久化数据时使用
hibernatetransactionmanager	使用hibernate3.0版本 进行持久化数据时使用
jpatransactionmanager	使用jpa进行持久化时 使用
jtatransactionmanager	使用一个jta实现来管理事务,跨数据源时使用

注意其分布在不同的jar包中,使用时根据需要导入对应jar包

事务的传播行为控制

这是一个新概念但是也非常简单,即在一个执行sql的方法中调用了另一个方法时,该如何处理这两个方法之间的事务

spring定义了7种不同的处理方式:

常量名	含义
propagation_required	支持当前事务。如果 a 方法已经在事 务中，则 b 事务将直接使用。否则将 创建新事务
propagation_supports	支持当前事务。如果 a 方法已经在事 务中，则 b 事务将直接使用。否则将 以非事务状态执行
propagation_mandatory	支持当前事务。如果 a 方法没有事 务，则抛出异常
propagation_requires_new	将创建新的事务，如果 a 方法已经在 事务中，则将 a 事务挂起
propagation_not_supported	不支持当前事务，总是以非事务状态 执行。如果 a 方法已经在事务中，则 将其挂起
propagation_never	不支持当前事务，如果 a 方法在事务 中，则抛出异常
propagation.nested	嵌套事务,当外层出现异常则连同内层一起回滚,若外层正常而内部异常,仅回滚内部操作

上述涉及的挂起,意思是开启一个独立的事务,已存在的事务暂停执行,等待新事务执行完毕后继续执行,两个事务不会互相影响

spring 整合mybatis

在开始前我们先完成一个基础的curd功能,后续开发中spring + mybatis项目是很常见的,那要将mybatis整合到spring中来,要明确一下两者的关系和定位

• spring java开发框架,其本质是一个对象容器,可以帮助我们完成ioc,di,aop

• mybatis是一个持久层框架,用于简化对数据库的操作

将两者整合起来,就是将mybatis中的对象交给spring来管理,且将这些对象的依赖也交给spring来管理;

添加依赖:

spring 3.0 的开发在 mybatis 3.0 官方发布前就结束了,于是mybatis社区自己召集开发者完成了这一部分工作,于是有了mybatis-spring项目,后续spring也就没有必要在开发一个新的模块了,所以该jar是mybatis提供的

<!-- spring整合mybatis依赖 -->
<dependency>
    <groupid>org.mybatis</groupid>
    <artifactid>mybatis-spring</artifactid>
    <version>2.0.3</version>
</dependency>

<dependency>
  <groupid>org.mybatis</groupid>
  <artifactid>mybatis</artifactid>
  <version>3.5.2</version>
</dependency>



<!--jdbc-->
<dependency>
  <groupid>mysql</groupid>
  <artifactid>mysql-connector-java</artifactid>
  <version>5.1.44</version>
</dependency>

<dependency>
  <groupid>junit</groupid>
  <artifactid>junit</artifactid>
  <version>4.12</version>
</dependency>


<dependency>
  <groupid>org.springframework</groupid>
  <artifactid>spring-context</artifactid>
  <version>5.2.2.release</version>
</dependency>

<!--spring jdbc-->
<dependency>
  <groupid>org.springframework</groupid>
  <artifactid>spring-jdbc</artifactid>
  <version>5.2.2.release</version>
</dependency>
<!--事务管理-->
<dependency>
  <groupid>org.springframework</groupid>
  <artifactid>spring-tx</artifactid>
  <version>5.2.2.release</version>
</dependency>

<dependency>
  <groupid>org.springframework</groupid>
  <artifactid>spring-test</artifactid>
  <version>5.2.2.release</version>
</dependency>
<!--aspectj-->
<dependency>
  <groupid>org.aspectj</groupid>
  <artifactid>aspectjweaver</artifactid>
  <version>1.8.0</version>
</dependency>

sm基础使用

配置文件

<?xml version="1.0" encoding="utf-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:xsi="http://www.w3.org/2001/xmlschema-instance"
       xsi:schemalocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                           http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

<!--    加载properties-->
    <context:property-placeholder location="jdbc.properties"/>

<!--    数据源 后续可更换为其他更方便的数据源-->
    <bean id="datasource" class="org.springframework.jdbc.datasource.drivermanagerdatasource">
        <property name="url" value="${url}"/>
        <property name="username" value="${usr}"/>
        <property name="password" value="${password}"/>
        <property name="driverclassname" value="${driver}"/>
    </bean>
  
<!--    mybatis核心对象sqlsessionfactory-->
    <bean id="sessionfactory" class="org.mybatis.spring.sqlsessionfactorybean">
        <property name="datasource" ref="datasource"/>
    </bean>

<!--    扫描mapper 将代理对象放入spring-->
    <bean class="org.mybatis.spring.mapper.mapperscannerconfigurer">
        <property name="basepackage" value="com.yh.dao"/>
    </bean>
</beans>

jdbc.properties:

driver = com.mysql.jdbc.driver
url = jdbc:mysql:///smdb?servertimezone=asia/shanghai&characterencoding=utf8&usessl=false
usr = root
password = admin
location = /users/jerry/.m2/repository/mysql/mysql-connector-java/8.0.17/mysql-connector-java-8.0.17.jar

测试代码:

@runwith(springjunit4classrunner.class)
@contextconfiguration("classpath:applicationcontext.xml")

public class test1 {
    @autowired
    private studentmapper studentmapper;
    @test
    public  void test(){
        student student = studentmapper.selectbyprimarykey(1);
        system.out.println(student);
    }
}

编码式事务

编码式事务,即在源代码中加入 事务处理的代码, 即commit,rollback等,这是非常原始的做法仅作为了解

纯手动管理事务

配置文件:

<!--    在之前的配置中添加内容-->

<!--事务管理器-->
    <bean class="org.springframework.jdbc.datasource.datasourcetransactionmanager">
        <property name="datasource" ref="datasource"/>
    </bean>

<!--    事务定义 -->
    <bean class="org.springframework.transaction.support.defaulttransactiondefinition">
<!--        隔离级别 可缺省-->
        <property name="isolationlevelname" value="isolation_repeatable_read"/>
<!--        传播行为 可缺省-->
        <property name="propagationbehaviorname" value="propagation_required"/>
    </bean>

测试代码:

@autowired
private studentmapper studentmapper;
@autowired
private datasourcetransactionmanager manager;
@autowired
private defaulttransactiondefinition definition;

@test
public  void test(){
    transactionstatus transactionstatus = manager.gettransaction(definition);
    try{
        student student = studentmapper.selectbyprimarykey(1);
        system.out.println(student);
        student.setage(201);
        studentmapper.updatebyprimarykey(student);
      
        int i = 1/0;
        manager.commit(transactionstatus);
    }catch (exception e){
        e.printstacktrace();
        manager.rollback(transactionstatus);
    }
}

上述代码仅用于测试事务处理的有效性;

我们已经在spring中配置了mybatis,并进行了事务处理,但是没有解决重复代码的问题

使用事务模板

事务模板原理是将要执行的具体代码交给模板,模板会在执行这写代码的同时处理事务,当这写代码出现异常时则自动回滚事务,以此来简化书写

配置文件:

<!-- 在上述配置基础上删除事务定义 添加模板bean-->
<bean id="transactiontemplate" class="org.springframework.transaction.support.transactiontemplate">
  <!--       传播行为隔离级别等参数  可缺省-->
  <property name="propagationbehaviorname" value="propagation_required"/>
  <property name="transactionmanager" ref="transactionmanager"/>
</bean>

测试代码:

public class test2 {

    @autowired
    private studentmapper studentmapper;

    @autowired
    private transactiontemplate transactiontemplate;


    @test
    public  void test(){
        transactiontemplate.execute(new transactioncallback() {
            public object dointransaction(transactionstatus transactionstatus) {
                student student = studentmapper.selectbyprimarykey(1);
                system.out.println(student);
                student.setage(1101);
                studentmapper.updatebyprimarykey(student);
//                int i = 1/0;
                return null;
            }
        });
    }
}

可以看到事务模板要求提供一个实现类来提交原始的数据库操作给模板,从而完成事务代码的增强

无论是纯手动管理还是利用模板,依然存在大量与业务无关的重复代码,这也是编码式事务最大的问题;

声明式事务

即不需要在原来的业务逻辑代码中加入任何事务相关的代码,而是通过xml,或者注解的方式,来告诉框架,哪些方法需要添加事务处理代码,让框架来完成在原始业务逻辑前后增加事务处理的代码(通过aop),这也是aop使用较多的场景之一;

基于tx名称空间的配置

配置文件:

需要引入aop和tx名称空间

<?xml version="1.0" encoding="utf-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns:xsi="http://www.w3.org/2001/xmlschema-instance"
       xsi:schemalocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
       http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
       http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd
       http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <import resource="mybatis-beans.xml"/>
    <context:component-scan base-package="com.yh.service"/>

<!--    添加事务管理器-->
    <bean id="transactionmanager" class="org.springframework.jdbc.datasource.datasourcetransactionmanager">
        <property name="datasource" ref="datasource"/>
    </bean>

<!--    事务通知-->
    <tx:advice id="transactionadvice" transaction-manager="transactionmanager">
        <tx:attributes>
<!--            name指定要应用的方法名称 还有其他事务常用属性如隔离级别传播行为等..-->
            <tx:method name="*" read-only="false"/>
        </tx:attributes>
    </tx:advice>

<!--    切点信息-->
    <aop:config >
<!--        根据表达式中的信息可以自动查找到目标对象 从而进行增强 先查找目标再生产代理-->
        <aop:pointcut id="pointcut" expression="execution(* com.yh.service.*.*(..))"/>
        <aop:advisor advice-ref="transactionadvice" pointcut-ref="pointcut"/>
    </aop:config>
</beans>

tx:method属性:

属性名	含义
name	匹配的方法名称
isolation	事务隔离级别
read-only	是否采用优化的只 读事务
timeout	超时
rollback-for	需要回滚的异常类
propagation	传播行为
no-rollback-for	不需要回滚的异常类

service:

@service
public class studentservice {
    @autowired
    private studentmapper studentmapper;
    public student getstudent(int id ){
        return studentmapper.selectbyprimarykey(id);
    }
    public void update(student student){
        studentmapper.updatebyprimarykey(student);
        int i  = 1/0;
    }
}

测试代码:

@runwith(springjunit4classrunner.class)
@contextconfiguration("classpath:applicationcontext3.xml")
public class test3 {
    @autowired
    studentservice studentservice;

    @test
    public void test(){
        student student = studentservice.getstudent(1);
        system.out.println(student);
        student.setage(8818);
        studentservice.update(student);
    }
}

强调:事务增强应该应用到service层,即业务逻辑层,应为一个业务方法可能涉及多个数据库操作,当某个操作遇到异常时需要将所有操作全部回滚

基于注解的配置

spring当然也支持采用注解形式来处理事务

开启注解事务支持:

<?xml version="1.0" encoding="utf-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns:xsi="http://www.w3.org/2001/xmlschema-instance"
       xsi:schemalocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
       http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd
       http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <!--为了分离关注点,故将mybatis相关配置放到其他配置文件了-->
    <import resource="mybatis-beans.xml"/>
    <context:component-scan base-package="com.yh.service"/>
  
<!--    添加事务管理器-->
    <bean id="transactionmanager" class="org.springframework.jdbc.datasource.datasourcetransactionmanager">
        <property name="datasource" ref="datasource"/>
    </bean>
<!--    开启注解事务管理-->
    <tx:annotation-driven transaction-manager="transactionmanager"/>
</beans>

service中增加方法:

@transactional(propagation = propagation.required,readonly = false)
public void transactiontest(){
    student student = getstudent(1);
    student.setage(1);
    update(student);
    int i = 1/0;
    student.setname("jack");
    update(student);
}
//当然注解上的参数都是可选的采用默认值即可

测试代码

@runwith(springjunit4classrunner.class)
@contextconfiguration("classpath:applicationcontext4.xml")
public class test4 {

    @autowired
    studentservice studentservice;

    @test
    public void test(){
        studentservice.transactiontest();
    }
}

你可能会觉得注解的方式比xml配置简单的多,但是考虑一下,当你的项目特别大,涉及的表很多的时候呢,你可能需要些很多很多的注解,假设后期需要修改某些属性,还得一个个改;

所以大项目建议采用xml,小项目使用注解也ok;

原理简述

声明式事务其底层用的还是aop,你完全可以自己手动的配置每个环节,如目标,通知,切面,代理等,这能让你更清晰的理解每一行代码背后到底做了什么事情;

配置文件:

<?xml version="1.0" encoding="utf-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/xmlschema-instance"
       xsi:schemalocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

    <import resource="mybatis-beans.xml"/>

<!--    添加事务管理器-->
    <bean id="transactionmanager" class="org.springframework.jdbc.datasource.datasourcetransactionmanager">
        <property name="datasource" ref="datasource"/>
    </bean>

<!--    要进行事务增强的目标对象-->
    <bean id="servicetarget" class="com.yh.service.studentservice"/>
<!--    事务通知-->
    <bean id="transactioninterceptor" class="org.springframework.transaction.interceptor.transactioninterceptor">
        <property name="transactionmanager" ref="transactionmanager"/>
        <property name="transactionattributes">
            <props>
                <prop key="*">propagation_required</prop>
            </props>
        </property>
    </bean>
<!--    代理对象-->
    <bean id="orderservice" class="org.springframework.aop.framework.proxyfactorybean">
        <property name="target" ref="servicetarget"/>
        <property name="interceptornames">
            <list>
                <idref bean="transactioninterceptor"/>
            </list>
        </property>
    </bean>
</beans>

测试代码:

@runwith(springjunit4classrunner.class)
@contextconfiguration("classpath:applicationcontext5.xml")
public class test5 {

    @autowired
    @qualifier("orderservice")
    studentservice studentservice;

    @test
    public void test(){
        student student = studentservice.getstudent(1);
        student.setage(1);
        studentservice.update(student);
    }
}