Spring事务管理

事务

事务的基本概念
事务指的是逻辑上的一组操作，这组操作要么全部成功，要么全部失败。

事务的特性
原子性：事务是一个不可分割的工作单位，事务中的操作要么都发生，要么都不发生。

一致性：事务前后数据的完整性必须保持一致。

隔离性：多个用户并发访问数据库时，一个用户的事务不能被其他用户的事务所干扰，多个并发事务之间数据要相互隔离（数据库中相应的数据隔离级别，通过它避免事务间的冲突）。

持久性:一个事务一旦被提交，它对数据库中数据的改变是永久性的，即使数据库发生故障也不应该对其有任何影响。

Spring中的事务管理

Spring提供了一组接口进行事务的管理。
Spring提供事务管理的3个接口：
【1】PlatformTransactionManager：事务管理器，用来管理事务的接口，定义了事务的提交、回滚等方法。
【2】TransactionDefinition：事务定义信息（隔离级别、传播行为、是否超时、是否只读）
【3】TransactionStatus：事务具体运行状态（事务是否提交，事务是否有保存点，事务是否是新事物等状态）。
Spring事务管理时，这三个接口是有联系的，Spring首先会根据事务定义信息TransactionDefinition获取信息,然后由事务管理器PlatformTransactionManager进行管理，在事务管理过程中，会产生一个事务的状态，这个状态就保存在事务具体运行状态TransactionStatus中了。

PlatformTransactionManager接口介绍：
通过Spring的API可以知道该接口有许多实现类例如：DataSourceTransactionManager、HibernateTransactionManager等。Spring会为不同的持久化框架提供了不同PlatformTransactionManager接口实现。
比如当我们使用SpringJDBC或者iBatis进行持久化数据时使用DataSourceTransactionManager。

image.png
TransactionDefinition定义事务隔离级别
该接口还提供了一些方法，例如：获得隔离级别、获得超时信息、获得是否只是只读的等。
如果不考虑隔离性，就会引发安全问题:脏读、不可重复读、以及虚读或者叫做幻读。

脏读：一个事务读取了另一个事务改写但还未提交的数据，如果这些数据被回滚，则读到的数据是无效的。

不可重复读：同一事务中，多次读取同一数据返回的结果有所不同（读取到另一个事务已经提交的更新的数据）。

幻读：一个事务读取了几行记录后，另一个事务插入一些记录，幻读就发生了。再后来的查询中，第一个事务就会发现有些原来没有的记录。

正常情况下，数据库提供了四种隔离级别：
READ_UNCOMMITED:安全级别最低，如果设置为该级别，就可能会发生脏读、不可重复读、幻读等。

READ_COMMITED:如果设置该级别，可以避免脏读的发生，但是可能会发生不可重复读和幻读。

REPEATABLE_READ:如果设置该级别，可以避免脏读和不可重复读，但是可能会发生幻读。

SERIALIZABLE:事务是串行的，不会发生并发访问这种情况
Spring提供了DEFAULT,它代表使用数据库默认的隔离级别（例如：Mysql默认采用REPEATABLE_READ隔离级别，Oracle默认采用READ_COMMITTED隔离级别）。

TransactionDefinition定义事务传播行为
事务的传播行为：解决业务层方法之间相互调用的问题（一个service层里的方法调用另一个service里中的方法，这两个service中又分属于两个不同的事务，传播行为就是为了解决方法调用时事务的传递）。

事务的传播行为有7种，可以为3类：

image.png

第一类为前三个，重点掌握第一个（在相同事务里）：支持当前事务（Service中bbb（）调用Service中aaa（）方法时，如果aaa（）有事务，则使用该事务。如果没有事务，则使用bbb（）当前事务，如果当前bbb（）也没有事务，就会新创建一个事务）

第二类为接下来三个，重点掌握第一个（在不同事务中）：如果aaa（）有事务存在，挂起当前事务，创建一个新的事务（aaa（）和bbb（）不在一个事务中）。
第三类：如果当前事务存在，则嵌套事务执行（执行aaa（）完后，会使用事务的保存点，在执行bbb（）时如果发生异常，可以回滚到设置的保存点，也可以回滚到最初始的状态）。

TransactionStatus接口介绍
TransactionStatus接口：提供了获取事务状态的方法（例如：hasSavepoint()事务是否有保存点，isCompleted()事务是否已经完成，isNewTransaction(）是否是新的事务)。

Spring事务管理的两种方式

【1】编程式的事务管理：手动在程序中编写代码实现事务管理，实际应用中很少使用，通过TransactionTemplate管理事务。

【2】声明式的事务管理：使用XML配置实现事务管理，推荐使用（代码侵入性最小），Spring的声明式事务管理是通过AOP实现的（没有代码之前开启事务，代码完成后提交事务）。

使用声明式事务管理实现转账示例

搭建事务管理环境（模拟转账环境）
【a】创建表及插入记录

image.png

【b】创建项目并引入jar包

image.png

【c】引入log4j.properties、applicationContext.xml、jdbc.properties配置文件。

【e】创建包结构，编写Dao及Service

package spring.demo3;
/*
 * 转账案例Dao层接口
 */
public interface AccountDao {
    
    public void outMoney(String out,Double money);
    
    public void inMoney(String in,Double money);

}

package spring.demo3;
/*
 * 转账案例的业务层接口
 */
public interface AccountService {

    public void transfer(String out,String in,Double money);
}

【f】spring配置文件编写

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"  
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
xmlns:context="http://www.springframework.org/schema/context"  
xmlns:aop="http://www.springframework.org/schema/aop"  
xmlns:tx="http://www.springframework.org/schema/tx"  
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  
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">  

    <!-- 引入外部的属性文件 --> 
    <context:property-placeholder location="classpath:jdbc.properties"/>
    
    <!-- 配置c3p0连接池 -->
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="${jdbc.driverClassName}"></property>
        <property name="jdbcUrl" value="${jdbc.url}"></property>
        <property name="user" value="${jdbc.username}"></property>
        <property name="password" value="${jdbc.password}"></property>
    </bean>
    
    <!--配置业务层类 -->
    <bean id="accountService" class="spring.demo3.AccountServiceImpl">
        <property name="accountDao" ref="accountDao"></property>
        
    </bean>
    
    <!-- 配置DAO的类 -->
    <bean id="accountDao" class="spring.demo3.AccountDapImpl">
        <!-- 注入连接池  -->
        <property name="dataSource" ref="dataSource"></property>
    </bean>

【g】Dao中获取JDBC模板
首先Dao实现类需要继承JdbcDaoSupport类，该类中就会注入JDBC模板，该类中定义了JDBC模板，并提供set方法只要Dao中注入模板就可以。也可以通过注入连接池获取JDBC模板。
【h】Dao方法具体编写

import org.springframework.jdbc.core.support.JdbcDaoSupport;



public class AccountDapImpl extends JdbcDaoSupport implements AccountDao {

    public void outMoney(String out, Double money) {
        // TODO Auto-generated method stub
        String sql="update acount set acount =acount - ? where name = ?";
        this.getJdbcTemplate().update(sql,money,out);

    }

    public void inMoney(String in, Double money) {
        // TODO Auto-generated method stub
        String sql="update acount set acount =acount + ? where name = ?";
        this.getJdbcTemplate().update(sql,money,in);
    }

}

【i】Service中注入Dao，并调用Dao中的方法

    package spring.demo3;

import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
import org.springframework.transaction.support.TransactionTemplate;

/*
 * 业务层实现类
 */
public class AccountServiceImpl implements AccountService
{
    //注入转账的Dao的类
    private AccountDao accountDao;
    

    public void setAccountDao(AccountDao accountDao) {
        this.accountDao = accountDao;
    }
    
    

    public void transfer( String out,  String in,  Double money) {
        
        accountDao.outMoney(out, money);
        int i=1/0;
        accountDao.inMoney(in, money);
    }

}

【k】测试：由于Junit4和spring整合的包已经引入，所以通过注解@ContextConfiguration注解加载配置文件，这里使用注解@Resource(name="")方式注入AccountService。

import javax.annotation.Resource;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
/*
 * Spring的声明事务管理的方式二:基于AspectJ的xml方式配置
 */
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext3.xml")
public class TestDemo3 {

    @Resource(name="accountService")
    private AccountService accountService;
    @Test
    /*
     * 转账案例测试
     */
    public void demo3(){
        accountService.transfer("aaa", "bbb", 100d);
    }
}

声明式事物管理方式：基于AspectJ的XML方式

【1】引入AspectJ的jar包和整合AspectJ的包。
AspectJ简介：Spring在开发AOP时，为了简化编程而建立的。（AspectJ实际是开源的、第三方的AOP开发框架，Spring为简化自身开发，就引入了AspectJ的包）
【2】配置事物管理器，并注入数据源dataSource。

<!-- 配置事务管理器  -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"></property>
    </bean>

【3】配置事物的通知
（事物的增强,通过<tx:advice id="" transaction-manager="事物管理器Id"></tx:advice>，这个标签中需要配置事物相关的一些属性<tx:attributes></tx:attributes>，该属性的作用就是哪些方法执行事务,<tx:method="方法名"></tx:method>如果多个方法可以用英文单词*,该标签中还定义了事物的传播行为、隔离级别、超时信息、只读等等属性)

    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <!--
              PROPAGATION:事务的传播行为 
              ISOLATION:事务的隔离级别
              readOnly:只读 
              rollback-for:发生哪些异常回滚
              no-rollback-for:发生哪些异常不回滚
              timeout:过期信息
               -->
        <tx:attributes>
            <tx:method name="transfer" propagation="REQUIRED"/>
        </tx:attributes>
    </tx:advice>

【4】配置AOP的切面
（通过<aop:config></aop:config>,在<aop:config>下需要配置切入点<aop:point-cut expression="" id=""></aop:point-cut>,其中表达式最前面的表示方法返回值为任意的，+号表示及其子类，.表示任意的方法，（..）表示任意的参数，接下来需要配置切面其中<aop:aspect>代表多个切入点，多个通知，而<aop:advisor>是一个切入点，一个通知的。这里使用它即可。因为现在只有一个增强即事物增强，这样AccountService即其子类的任意方法都会事物增强了）

    <aop:config>
        <!--配置切入点  -->
        <aop:pointcut expression="execution(* spring.demo3.AccountService+.*(..))" id="pointcut1"/>
        <!-- 配置切面  -->
        <aop:advisor advice-ref="txAdvice" pointcut-ref="pointcut1"/>
    </aop:config>

使用事务管理方式,一旦发生异常,整个事务不会执行,不会出现钱转丢的现象