9 聲明式事務(wù)

module：spring-11-transaction

回顧事務(wù)

• 事務(wù)在項(xiàng)目開發(fā)過程中非常重要，涉及到數(shù)據(jù)一致性問題！
• 事務(wù)管理是企業(yè)級(jí)應(yīng)用程序開發(fā)中必備技術(shù)，用來確保數(shù)據(jù)的完整性和一致性。

事務(wù)就是把一系列的動(dòng)作當(dāng)成一個(gè)獨(dú)立的工作單元，這些動(dòng)作要么全部完成，要么全部不起作用。

事務(wù)ACID屬性

• 原子性：事務(wù)是原子性操作，由一系列動(dòng)作組成，事務(wù)的原子性確保動(dòng)作要么全部完成，要么完全不起作用。
• 一致性：一旦所有事務(wù)動(dòng)作完成，事務(wù)就要被提交。數(shù)據(jù)和資源處于一種滿足業(yè)務(wù)規(guī)則的一致性狀態(tài)中。
• 隔離性：可能多個(gè)事務(wù)會(huì)同時(shí)處理相同的數(shù)據(jù)，因此每個(gè)事務(wù)都應(yīng)該與其他事務(wù)隔離開來，防止數(shù)據(jù)損壞。
• 持久性：事務(wù)一旦完成，無論系統(tǒng)發(fā)生什么錯(cuò)誤，結(jié)果都不會(huì)受到影響。通常情況下，事務(wù)的結(jié)果被寫到持久化存儲(chǔ)器中。

代碼實(shí)現(xiàn)：

1、編寫實(shí)體類User.java

package com.zzb.pojo;

public class User {

    private int id;
    private String name;
    private String pwd;

    public User() {
    }

    public User(int id, String name, String pwd) {
        this.id = id;
        this.name = name;
        this.pwd = pwd;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getPwd() {
        return pwd;
    }

    public void setPwd(String pwd) {
        this.pwd = pwd;
    }

    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", pwd='" + pwd + '\'' +
                '}';
    }
}

2、編寫UserMapper接口

package com.zzb.mapper;

import com.zzb.pojo.User;
import org.apache.ibatis.annotations.Param;

import java.util.List;

public interface UserMapper {
    List<User> getUser();

    // 添加一個(gè)用戶
    int addUser(User user);

    // 刪除一個(gè)用戶
    int deleteUser(@Param("id") int id);
}

3、編寫UserMapper.xml配置文件

注意：此處故意將delete語句寫錯(cuò)，寫成delete

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-////DTD Config 3.0//EN"
        "http:///dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.zzb.mapper.UserMapper">

    <select id="getUser" resultType="User">
        select * from user
    </select>

    <insert id="addUser" parameterType="User">
        insert into user (id, name, pwd) values (#{id}, #{name}, #{pwd})
    </insert>

    <deletes id="deleteUser">
        deletes from user where id = #{id}
    </delete>
</mapper>

4、編寫接口實(shí)現(xiàn)類

package com.zzb.mapper;

import com.zzb.pojo.User;
import org.mybatis.spring.SqlSessionTemplate;

import java.util.List;

public class UserMapperImpl implements UserMapper{

    private SqlSessionTemplate sqlSession;

    public void setSqlSession(SqlSessionTemplate sqlSession) {
        this.sqlSession = sqlSession;
    }

    public List<User> getUser() {
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);

        mapper.addUser(new User(5,"王二狗","95271111"));
        mapper.deleteUser(3);


        List<User> users = mapper.getUser();
        return users;
    }

    public int addUser(User user) {
        System.out.println("insert");
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        return mapper.addUser(user);
    }

    public int deleteUser(int id) {
        System.out.println("delete");
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        return mapper.deleteUser(10);
    }
}

5、測(cè)試

import com.zzb.mapper.UserMapper;
import com.zzb.pojo.User;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.util.List;

public class MyTest {
    public static void main(String[] args) {
        ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
        UserMapper mapper = context.getBean("userMapperImpl", UserMapper.class);
        List<User> userList = mapper.getUser();
        for (User user : userList) {
            System.out.println(user);
        }
    }
}

測(cè)試結(jié)果：

報(bào)錯(cuò)：sql異常，delete寫錯(cuò)了

結(jié)果：數(shù)據(jù)插入成功，刪除數(shù)據(jù)失?。?/p>

沒有進(jìn)行事務(wù)的管理；應(yīng)該讓他們都成功才成功，有一個(gè)失敗，就都失敗，我們就應(yīng)該需要事務(wù)！

Spring 中的事務(wù)管理

Spring在不同的事務(wù)管理API之上定義了一個(gè)抽象層，使得開發(fā)人員不必了解底層的事務(wù)管理API就可以使用Spring的事務(wù)管理機(jī)制。Spring支持編程式事務(wù)管理和聲明式的事務(wù)管理。

編程式事務(wù)管理

• 將事務(wù)管理代碼嵌到業(yè)務(wù)方法中來控制事務(wù)的提交和回滾
• 缺點(diǎn)：必須在每個(gè)事務(wù)操作業(yè)務(wù)邏輯中包含額外的事務(wù)管理代碼

聲明式事務(wù)管理

• 一般情況下比編程式事務(wù)好用。
• 將事務(wù)管理代碼從業(yè)務(wù)方法中分離出來，以聲明的方式來實(shí)現(xiàn)事務(wù)管理。
• 將事務(wù)管理作為橫切關(guān)注點(diǎn)，通過aop方法模塊化。Spring中通過Spring AOP框架支持聲明式事務(wù)管理。

使用Spring管理事務(wù)，注意頭文件的約束導(dǎo)入 : tx

事務(wù)管理器

• 無論使用Spring的哪種事務(wù)管理策略（編程式或者聲明式）事務(wù)管理器都是必須的。
• 是 Spring的核心事務(wù)管理抽象，管理封裝了一組獨(dú)立于技術(shù)的方法。

JDBC 事務(wù)

  <!--配置聲明事務(wù)-->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <constructor-arg name="dataSource" ref="dataSource"/>
    </bean>

配置好事務(wù)管理器后我們需要去配置事務(wù)的通知

<!--配置事務(wù)通知-->
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <tx:attributes>
            <tx:method name="*" propagation="REQUIRED"/>
        </tx:attributes>
    </tx:advice>

spring事務(wù)傳播特性：

事務(wù)傳播行為就是多個(gè)事務(wù)方法相互調(diào)用時(shí)，事務(wù)如何在這些方法間傳播。spring支持7種事務(wù)傳播行為：

• propagation_requierd：如果當(dāng)前沒有事務(wù)，就新建一個(gè)事務(wù)，如果已存在一個(gè)事務(wù)中，加入到這個(gè)事務(wù)中，這是最常見的選擇。
• propagation_supports：支持當(dāng)前事務(wù)，如果沒有當(dāng)前事務(wù)，就以非事務(wù)方法執(zhí)行。
• propagation_mandatory：使用當(dāng)前事務(wù)，如果沒有當(dāng)前事務(wù)，就拋出異常。
• propagation_required_new：新建事務(wù)，如果當(dāng)前存在事務(wù)，把當(dāng)前事務(wù)掛起。
• propagation_not_supported：以非事務(wù)方式執(zhí)行操作，如果當(dāng)前存在事務(wù)，就把當(dāng)前事務(wù)掛起。
• propagation_never：以非事務(wù)方式執(zhí)行操作，如果當(dāng)前事務(wù)存在則拋出異常。
• propagation_nested：如果當(dāng)前存在事務(wù)，則在嵌套事務(wù)內(nèi)執(zhí)行。如果當(dāng)前沒有事務(wù)，則執(zhí)行與propagation_required類似的操作

Spring 默認(rèn)的事務(wù)傳播行為是 PROPAGATION_REQUIRED，它適合于絕大多數(shù)的情況。

假設(shè) ServiveX#methodX() 都工作在事務(wù)環(huán)境下（即都被 Spring 事務(wù)增強(qiáng)了），假設(shè)程序中存在如下的調(diào)用鏈：Service1#method1()->Service2#method2()->Service3#method3()，那么這 3 個(gè)服務(wù)類的 3 個(gè)方法通過 Spring 的事務(wù)傳播機(jī)制都工作在同一個(gè)事務(wù)中。

就好比，我們剛才的幾個(gè)方法存在調(diào)用，所以會(huì)被放在一組事務(wù)當(dāng)中！

配置AOP

注意：需要導(dǎo)入aop約束

    <aop:config>
        <aop:pointcut id="txPointCut" expression="execution(* com.zzb.mapper.UserMapperImpl.*(..))"/>

        <aop:advisor advice-ref="txAdvice" pointcut-ref="txPointCut"/>
    </aop:config>

測(cè)試:

測(cè)試結(jié)果：

程序報(bào)錯(cuò)，插入失敗，刪除失??！

完整的xml配置文件spring-dao.xml：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www./schema/beans"
       xmlns:xsi="http://www./2001/XMLSchema-instance"
       xmlns:tx="http://www./schema/tx"
       xmlns:aop="http://www./schema/aop"
       xsi:schemaLocation="http://www./schema/beans
        https://www./schema/beans/spring-beans.xsd
        http://www./schema/tx
        https://www./schema/tx/spring-tx.xsd
        http://www./schema/aop
        https://www./schema/aop/spring-aop.xsd">

    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
        <property name="url"
                  value="jdbc:mysql://localhost:3306/mybatis?useSSL=true&verifyServerCertificate=false&useUnicode=true&characterEncoding=utf8"/>
        <property name="username" value="root"/>
        <property name="password" value="1234"/>
    </bean>

    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource"/>
        <property name="configLocation" value="mybatis-config.xml"/>
        <property name="mapperLocations" value="classpath:com/zzb/mapper/*.xml"/>
    </bean>

    <bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">
        <constructor-arg index="0" ref="sqlSessionFactory"/>
    </bean>

    <!--配置聲明事務(wù)-->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <constructor-arg name="dataSource" ref="dataSource"/>
    </bean>

    <!--結(jié)合AOP實(shí)現(xiàn)事務(wù)的織入-->
    <!--配置事務(wù)通知-->
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <tx:attributes>
            <tx:method name="*" propagation="REQUIRED"/>
        </tx:attributes>
    </tx:advice>

    <aop:config>
        <aop:pointcut id="txPointCut" expression="execution(* com.zzb.mapper.UserMapperImpl.*(..))"/>

        <aop:advisor advice-ref="txAdvice" pointcut-ref="txPointCut"/>
    </aop:config>
</beans>