9 宣告式事務-有解無憂

9 宣告式事務

module：spring-11-transaction

回顧事務

事務在專案開發程序中非常重要，涉及到資料一致性問題！
事務管理是企業級應用程式開發中必備技術，用來確保資料的完整性和一致性，

事務就是把一系列的動作當成一個獨立的作業單元，這些動作要么全部完成，要么全部不起作用，

事務ACID屬性

原子性：事務是原子性操作，由一系列動作組成，事務的原子性確保動作要么全部完成，要么完全不起作用，
一致性：一旦所有事務動作完成，事務就要被提交，資料和資源處于一種滿足業務規則的一致性狀態中，
隔離性：可能多個事務會同時處理相同的資料，因此每個事務都應該與其他事務隔離開來，防止資料損壞，
持久性：事務一旦完成，無論系統發生什么錯誤，結果都不會受到影響，通常情況下，事務的結果被寫到持久化存盤器中，

代碼實作：

1、撰寫物體類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();

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

    // 洗掉一個用戶
    int deleteUser(@Param("id") int id);
}

3、撰寫UserMapper.xml組態檔

注意：此處故意將delete陳述句寫錯，寫成delete

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/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、撰寫介面實作類

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、測驗

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);
        }
    }
}

測驗結果：

報錯：sql例外，delete寫錯了

結果：資料插入成功，洗掉資料失敗！

沒有進行事務的管理；應該讓他們都成功才成功，有一個失敗，就都失敗，我們就應該需要事務！

Spring 中的事務管理

Spring在不同的事務管理API之上定義了一個抽象層，使得開發人員不必了解底層的事務管理API就可以使用Spring的事務管理機制，Spring支持編程式事務管理和宣告式的事務管理，

編程式事務管理

將事務管理代碼嵌到業務方法中來控制事務的提交和回滾
缺點：必須在每個事務操作業務邏輯中包含額外的事務管理代碼

宣告式事務管理

一般情況下比編程式事務好用，
將事務管理代碼從業務方法中分離出來，以宣告的方式來實作事務管理，
將事務管理作為橫切關注點，通過aop方法模塊化，Spring中通過Spring AOP框架支持宣告式事務管理，

使用Spring管理事務，注意頭檔案的約束匯入 : tx

事務管理器

無論使用Spring的哪種事務管理策略（編程式或者宣告式）事務管理器都是必須的，
是 Spring的核心事務管理抽象，管理封裝了一組獨立于技術的方法，

JDBC 事務

  	<!--配置宣告事務-->
    <bean id="transactionManager" >
        <constructor-arg name="dataSource" ref="dataSource"/>
    </bean>

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

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

spring事務傳播特性：

事務傳播行為就是多個事務方法相互呼叫時，事務如何在這些方法間傳播，spring支持7種事務傳播行為：

propagation_requierd：如果當前沒有事務，就新建一個事務，如果已存在一個事務中，加入到這個事務中，這是最常見的選擇，
propagation_supports：支持當前事務，如果沒有當前事務，就以非事務方法執行，
propagation_mandatory：使用當前事務，如果沒有當前事務，就拋出例外，
propagation_required_new：新建事務，如果當前存在事務，把當前事務掛起，
propagation_not_supported：以非事務方式執行操作，如果當前存在事務，就把當前事務掛起，
propagation_never：以非事務方式執行操作，如果當前事務存在則拋出例外，
propagation_nested：如果當前存在事務，則在嵌套事務內執行，如果當前沒有事務，則執行與propagation_required類似的操作

Spring 默認的事務傳播行為是 PROPAGATION_REQUIRED，它適合于絕大多數的情況，

假設 ServiveX#methodX() 都作業在事務環境下（即都被 Spring 事務增強了），假設程式中存在如下的呼叫鏈：Service1#method1()->Service2#method2()->Service3#method3()，那么這 3 個服務類的 3 個方法通過 Spring 的事務傳播機制都作業在同一個事務中，

就好比，我們剛才的幾個方法存在呼叫，所以會被放在一組事務當中！

配置AOP

注意：需要匯入aop約束

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

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

測驗:

測驗結果：

程式報錯，插入失敗，洗掉失敗！

完整的xml組態檔spring-dao.xml：

<?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:tx="http://www.springframework.org/schema/tx"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        https://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/tx
        https://www.springframework.org/schema/tx/spring-tx.xsd
        http://www.springframework.org/schema/aop
        https://www.springframework.org/schema/aop/spring-aop.xsd">

    <bean id="dataSource" >
        <property name="driverClassName" value="https://www.cnblogs.com/zzbstudy/p/com.mysql.jdbc.Driver"/>
        <property name="url"
                  value="https://www.cnblogs.com/zzbstudy/p/jdbc:mysql://localhost:3306/mybatis?useSSL=true&verifyServerCertificate=false&useUnicode=true&characterEncoding=utf8"/>
        <property name="username" value="https://www.cnblogs.com/zzbstudy/p/root"/>
        <property name="password" value="https://www.cnblogs.com/zzbstudy/p/1234"/>
    </bean>

    <bean id="sqlSessionFactory" >
        <property name="dataSource" ref="dataSource"/>
        <property name="configLocation" value="https://www.cnblogs.com/zzbstudy/p/mybatis-config.xml"/>
        <property name="mapperLocations" value="https://www.cnblogs.com/zzbstudy/p/classpath:com/zzb/mapper/*.xml"/>
    </bean>

    <bean id="sqlSession" >
        <constructor-arg index="0" ref="sqlSessionFactory"/>
    </bean>

    <!--配置宣告事務-->
    <bean id="transactionManager" >
        <constructor-arg name="dataSource" ref="dataSource"/>
    </bean>

    <!--結合AOP實作事務的織入-->
    <!--配置事務通知-->
    <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>

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/232855.html

標籤：Java

上一篇：8 整合MyBatis

下一篇：填坑系列之OpenFeign