Spring 事務管理機制

事務的概念和特性

事務：一起成功、一起失敗

什么是事務呢？

事務指的是邏輯上的一組操作，這組操作要么全部成功，要么全部失敗

事務的特性：

原子性、一致性、隔離性、持久性

原子性：原子性是值事務是一個不可分割的工作單位，事務中的操作要么都發生，要么都不發生

一致性：一致性指事務前后數據的完整性必須保持一致

隔離性：隔離性是指多個用戶并發訪問數據庫時，一個用戶的事務不能被其他用戶的事務所干擾，多個并發事務之間數據要相互隔離。

持久性：一個事務一旦被提交，它對數據庫中數據的改變就是永久性的，即使數據庫發生故障也不應該對其有任何影響。

如果不考慮隔離性，會引發安全問題如下：

臟讀、不可重復讀、幻讀

臟讀：一個事務讀取了另一個事務改寫但還未提交的數據，如果這些數據被回滾，則讀到的數據是無效的。

不可重復讀：在同一事務中，多次讀取同一數據返回的結果有所不同。

幻讀：一個事務讀取了幾行記錄后，另一個事務插入一些記錄，幻讀就發生了，再后來的查詢中，第一個數據就會發現有些原來沒有的記錄

Spring接口介紹

Spring事務管理高層首相主要包括三個接口

PlatformTransactionManager

平臺事務管理器

TransactionDefinition

事務定義信息（隔離、傳播、超時、只讀）

TransactionStatus

事務具體運行狀態

平臺事務管理器

事務的四種隔離級別

MySql默認的事務隔離級別為REPEATABLE_READ
Oracle默認的事務隔離級別為READ_COMMITTED

spring 事務的七種傳播行為

什么是事務的傳播行為？

事務有哪些傳播行為？

重點記第一個PROPAGATION_REQUIRED、第四個PROPAGATION_REQUIRES_NEW、和最后一個PROPAGATION_NESTED

Spring事務管理

Spring支持兩種方式

1.編程式的事務

在實際應用中很少使用

通過TransactionTemplate手動管理事務

2.使用xml配置聲明式事務

開發中推薦使用（代碼侵入性最小）

Spring的聲明式事務是通過AOP實現的

Spring事務管理的實現

描述：在ssm環境下，以簡單的轉賬案例，分別使用編程式事務管理、以及聲明式事務管理來實現Spring事務管理。

創建數據庫表

CREATE TABLE `account` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(20) NOT NULL,
  `money` double DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8;
INSERT INTO `account` VALUES ('1', 'aaa', '1000');
INSERT INTO `account` VALUES ('2', 'bbb', '1000');
INSERT INTO `account` VALUES ('3', 'ccc', '1000');

編寫AccountDaO層

package com.mavenssmlr.dao;

import org.apache.ibatis.annotations.Param;

/**
 * 轉賬案例的Dao層的接口
 * Created by shirukai on 2017/11/1.
 */
public interface AccountDao {
    /**
     *
     * @param out   轉出賬號
     * @param money 轉出金額
     */
    public void outMoney(@Param("out") String out,@Param("money") Double money);

    /**
     *
     * @param in    轉入賬號
     * @param money 轉入金額
     */
    public void inMoney(@Param("in") String in,@Param("money") Double money);
}

編寫 AccountDaoMappper

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.mavenssmlr.dao.AccountDao">
    <update id="outMoney">
        UPDATE mavenssmlr.account SET money = money - #{money} WHERE name = #{out}
    </update>
    <update id="inMoney">
        UPDATE mavenssmlr.account SET money = money+ #{money} WHERE name = #{in}
    </update>
</mapper>

編寫Service接口

/**
 * 轉賬案例的業務接口
 * @param out   轉出的賬號
 * @param in    轉入的賬號
 * @param money 轉賬金額
 */
Map<String,String> transfer(String out ,String in ,Double money);

編寫Service接口實現類

public Map<String, String> transfer(String out, String in, Double money) {
    accountDao.outMoney(out, money);
    accountDao.inMoney(in, money);
    return null;
}

編寫service測試類

@Test
public void accountTest()throws Exception{
    mavenssmlrService.transfer("aaa","bbb",200d);
}

以上基本的轉賬案例就寫完了，但是沒有加入事務管理。

一、基于編程式的事務管理

Spring-service.xml

配置事務管理器

<!--配置事務管理器-->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <!--注入數據庫連接池-->
    <property name="dataSource" ref="dataSource"/>
</bean>

配置事務管理模板

<!--配置事務管理的模板：Spring為了簡化事務管理的代碼而提供的類-->
<bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">
    <property name="transactionManager" ref="transactionManager"/>
</bean>

service實現類

注入編程事務模板

//注入編程式事務模板
@Autowired
private TransactionTemplate transactionTemplate;

編程式事務方法

public Map<String, String> transfer(final String out,final String in,final Double money) {
    transactionTemplate.execute(new TransactionCallbackWithoutResult() {
        @Override
        protected void doInTransactionWithoutResult(TransactionStatus status) {
            accountDao.outMoney(out, money);
            //制造異常
            int i = 1 / 0;
            accountDao.inMoney(in, money);
        }
    });
    return null;
}

測試類 無需改動

@Test
public void accountTest()throws Exception{
    mavenssmlrService.transfer("aaa","bbb",200d);
}

二、基于聲明式的事務管理

1.基于TransactionProxy的聲明式事務管理

Spring-service.xml

配置事務管理器

<!--配置事務管理器-->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <!--注入數據庫連接池-->
    <property name="dataSource" ref="dataSource"/>
</bean>

配置業務代理

<!--配置業務代理：-->
<bean id="accountServiceProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
    <!--配置目標對象-->
    <property name="target" ref="mavenssmlrServiceImpl"/>
    <!--注入事務管理器-->
    <property name="transactionManager" ref="transactionManager"/>
    <!--注入事務屬性-->
    <property name="transactionAttributes">
        <props>
            <!--prop的格式
                    * PROPAGATION ：事務的傳播行為
                    * ISOLATION   ：事務的隔離級別
                    * readOnly    ：只讀
                    * -Exception  ：發生哪些異常回滾事務
                    * +Exception  ：發生哪些以上不回滾事務
            -->
            <prop key="transfer">PROPAGATION_REQUIRED</prop>
        </props>
    </property>

service實現類

public Map<String, String> transfer(String out, String in, Double money) {
    accountDao.outMoney(out, money);
    //制造異常
    int i = 1 / 0;
    accountDao.inMoney(in, money);
    return null;
}

測試類 需要引入Service的增強類

@Resource(name = "accountServiceProxy")
private MavenssmlrService mavenssmlrService;

@Test
public void accountTest()throws Exception{
    mavenssmlrService.transfer("aaa","bbb",200d);
}

2.基于AspectJ的xml配置聲明式事務（沒有實現）

<!--配置事務管理器-->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <!--注入數據庫連接池-->
    <property name="dataSource" ref="dataSource"/>
</bean>


<!--2)配置事務的通知（事務的增強）-->
<tx:advice id="txAdvice" transaction-manager="transactionManager">
    <tx:attributes>
        <!--
            propagation    :事務傳播行為
            isolation  :事務的隔離級別
            read-only  :只讀
            rollback-for:發生哪些異常回滾
            no-rollback-for    :發生哪些異常不回滾
            timeout       :過期信息
         -->
        <tx:method name="transfer" propagation="REQUIRED"/>
    </tx:attributes>
</tx:advice>

<!-- 配置切面 -->
<aop:config>
    <!-- 配置切入點 -->
    <aop:pointcut expression="execution(* com.mavenssmlr.service.MavenssmlrService+.*(..))" id="pointcut1"/>
    <!-- 配置切面 -->
    <aop:advisor advice-ref="txAdvice" pointcut-ref="pointcut1"/>
</aop:config>

3.基于注解的聲明式事務

Spring-service.xml

<!--配置事務管理器-->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <!--注入數據庫連接池-->
    <property name="dataSource" ref="dataSource"/>
</bean>

<!--2配置基于注解的聲明式事務-->
<tx:annotation-driven transaction-manager="transactionManager"/>

在方法上添加@Transactional

/**
 * 
 * @param out   轉出的賬號
 * @param in    轉入的賬號
 * @param money 轉賬金額
 * @return
 * 
 * Transactional注解中的屬性
 * propagation：事務的傳播行為
 * isolation：隔離基本
 * readOnly：只讀信息
 * rollbackFor：發生哪些異常回滾
 * noRollbackFor：發生哪些異常不回滾
 */
@Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.DEFAULT,readOnly = false)
public Map<String, String> transfer(String out, String in, Double money) {
    accountDao.outMoney(out, money);
    //制造異常
    int i = 1 / 0;
    accountDao.inMoney(in, money);
    return null;
}

總結：

Spring將事務管理分成了兩類

• 編程式事務管理

  手動編寫代碼進行事務管理（很少使用）

• 聲明式事務管理

  基于TransactionProxyFactoryBean（很少使用）

  基于AspectJ的XMl方式

  基于注解方式（經常使用）

  ?