Spring整合Mybatis，宣告式事務(狂神)

1、整合Mybatis

程式碼：https://gitee.com/deza-to/spring_mybatis

B站 https://www.bilibili.com/video/BV1WE411d7Dv

參考部落格：https://mp.weixin.qq.com/s/gXFMNU83_7PqTkNZUgvigA

​ https://mp.weixin.qq.com/s/mYOBJdygHDcXPYBls7cxUA

步驟

1. 匯入相關jar包

   • junit
   • mybatis
   • mysql資料庫
   • spring相關
   • aop織入
   • mybatis-spring【核心】

   pom.xml

   <dependencies>
           <dependency>
               <groupId>mysql</groupId>
               <artifactId>mysql-connector-java</artifactId>
               <version>5.1.47</version>
           </dependency>
           <dependency>
               <groupId>org.springframework</groupId>
               <artifactId>spring-webmvc</artifactId>
               <version>5.1.9.RELEASE</version>
           </dependency>
           <!--Spring操作資料庫需要一個spring-jdbc-->
           <dependency>
               <groupId>org.springframework</groupId>
               <artifactId>spring-jdbc</artifactId>
               <version>5.1.9.RELEASE</version>
           </dependency>
           <dependency>
               <groupId>org.mybatis</groupId>
               <artifactId>mybatis</artifactId>
               <version>3.5.2</version>
           </dependency>
           <dependency>
               <groupId>org.aspectj</groupId>
               <artifactId>aspectjweaver</artifactId>
               <version>1.9.7</version>
           </dependency>
           <dependency>
               <groupId>org.mybatis</groupId>
               <artifactId>mybatis-spring</artifactId>
               <version>2.0.2</version>
           </dependency>
           <dependency>
               <groupId>junit</groupId>
               <artifactId>junit</artifactId>
               <version>4.13.2</version>
               <scope>test</scope>
           </dependency>
       </dependencies>
    
   

2. 配置Maven靜態資源過濾問題

<build>
    <resources>
        <resource>
            <directory>src/main/resources</directory>
            <includes>
                <include>**/*.properties</include>
                <include>**/*.xml</include>
            </includes>
            <filtering>true</filtering>
        </resource>
        <resource>
            <directory>src/main/java</directory>
            <includes>
                <include>**/*.properties</include>
                <include>**/*.xml</include>
            </includes>
            <filtering>true</filtering>
        </resource>
    </resources>
</build>
 

3. 編寫配置檔案

4. 測試

1.1、回憶Mybatis

1. 編寫實體類
2. 編寫核心配置檔案
3. 編寫介面
4. 編寫Mapper.xml
5. 測試

1.2、Mybatis-Spring

整合方式一

1. 編寫資料來源配置【spring-dao.xml】

<!--DataSource:使用Spring的資料來源替換Mybatis的配置-->
<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=false&amp;useUnicode=true&amp;characterEncoding=UTF-8&amp;serverTimezone=Asia/Shanghai"/>
    <property name="username" value="root"/>
    <property name="password" value="cqp123"/>
</bean>

2. sqlSessionFactory

<!--SqlSessionFactory-->
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="dataSource" ref="dataSource" />
    <!--繫結Mybatis配置檔案-->
    <property name="configLocation" value="classpath:mybatis-config.xml"/>
    <!--註冊mapper.xml-->
    <property name="mapperLocations" value="classpath:com/chen/dao/*.xml"/>
</bean>

mybatis-config.xml一般配置setting和typeAliases

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
<!--configuration核心配置檔案-->
<configuration>

    <!--setting也合適放在這個配置檔案-->
    <!--    <settings>-->
    <!--        <setting name="" value=""/>-->
    <!--    </settings>-->

    <typeAliases>
        <package name="com.chen.pojo"/>
    </typeAliases>

    <!--<environments default="development">
        <environment id="development">
            <transactionManager type="JDBC"/>
            <dataSource type="POOLED">
                <property name="driver" value="com.mysql.jdbc.Driver"/>
                <property name="url" value="jdbc:mysql://localhost:3306/mybatis?useSSL=false&amp;useUnicode=true&amp;characterEncoding=UTF-8&amp;serverTimezone=Asia/Shanghai"/>
                <property name="username" value="root"/>
                <property name="password" value="cqp123"/>
            </dataSource>
        </environment>
    </environments>-->
    <!--<mappers>
        <package name="com.chen.dao"/>
    </mappers>-->
</configuration>

3. sqlSessionTemplate

<!--SqlSessionTemplate:就是我們使用的sqlSession-->
<bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">
    <!--只能使用構造器注入sqlSessionFactory，因為它沒有set方法-->
    <constructor-arg name="sqlSessionFactory" ref="sqlSessionFactory"/>
</bean>

4. 需要給介面加實現類

import com.chen.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> getUsers(){
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        List<User> userList = mapper.getUsers();
        return userList;
    }

    public int addUser(User user){
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        int i = mapper.addUser(user);
        return i;
    }

    public int deleteUser(int id){
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        int i = mapper.deleteUser(id);
        return i;
    }

}

5. 將自己寫的實現類注入到Spring中【ApplicationContext.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"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        https://www.springframework.org/schema/beans/spring-beans.xsd">

    <!--將dao的配置匯入-->
    <import resource="spring-dao.xml"/>

    <bean id="userMapperImpl" class="com.chen.dao.UserMapperImpl">
        <property name="sqlSession" ref="sqlSession"/>
    </bean>

</beans>

6. 測試

@Test
public void test() throws IOException {
    ApplicationContext context = new ClassPathXmlApplicationContext("ApplicationContext.xml");
    UserMapper userMapper = (UserMapper) context.getBean("userMapperImpl");
    List<User> userList = userMapper.getUsers();
    for (User user : userList) {
        System.out.println(user);
    }
}

整合方式二

mybatis-spring1.2.3版以上的才有這個

1. 繼承SqlSessionDaoSupport,直接利用getSqlSession()獲得，然後注入SqlSessionFactory 。

比起方式1 , 不需要管理SqlSessionTemplate , 而且對事務的支援更加友好。

import com.chen.pojo.User;
import org.mybatis.spring.support.SqlSessionDaoSupport;

import java.util.Date;
import java.util.List;

public class UserMapperImpl2 extends SqlSessionDaoSupport implements UserMapper{
    //繼承SqlSessionDaoSupport可以直接獲得SqlSession物件
    public List<User> getUsers() {
        UserMapper mapper = getSqlSession().getMapper(UserMapper.class);
        return mapper.getUsers();
    }
}

2. 在ApplicationContext.xml中配置bean

<?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
        https://www.springframework.org/schema/beans/spring-beans.xsd">

    <import resource="spring-dao.xml"/>

    <bean id="userMapperImpl2" class="com.chen.dao.UserMapperImpl2">
        <property name="sqlSessionFactory" ref="sqlSessionFactory"/>
    </bean>
</beans>

3. 測試

@Test
public void test2(){
    ApplicationContext context = new ClassPathXmlApplicationContext("ApplicationContext.xml");
    UserMapper userMapper = (UserMapper) context.getBean("userMapperImpl2");
    List<User> userList = userMapper.getUsers();
    for (User user : userList) {
        System.out.println(user);
    }
}

2、宣告式事務

2.1、回顧事務

• 把一組業務當成一個業務來做，要麼都成功，要麼都失敗
• 事務在專案開發中十分重要，涉及到資料的一致性問題，不能馬虎
• 確保完整性和一致性

事務的ACID原則：

• 原子性
  • 事務是原子性操作，由一系列動作組成，事務的原子性確保動作要麼全部完成，要麼都不起作用。
• 一致性
  • 一旦所有事務動作完成，事務就要被提交。資料和資源處於一種滿足業務規則的一致性狀態中。
• 隔離性
  • 多個業務可能操作同一個資源，因此每個事務都應該與其他事務隔離開，防止資料損壞。
• 永續性
  • 事物一旦提交，無論系統發生什麼問題，結果都不會被影響，被持久化的寫到儲存器中。

2.2、編寫程式碼

1、給UserMapper介面增加兩個方法

//新增一個使用者
int addUser(User user);

//刪除一個使用者
int deleteUser(@Param("id") int id);

2、相應的新增mapper.xml的實現(故意將delete寫錯成deletes)

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

<delete id="deleteUser" parameterType="int">
    deletes from USER where id = #{id}
</delete>

3、編寫介面的實現類

import com.chen.pojo.User;
import org.mybatis.spring.support.SqlSessionDaoSupport;

import java.util.Date;
import java.util.List;

public class UserMapperImpl2 extends SqlSessionDaoSupport implements UserMapper{

    //繼承SqlSessionDaoSupport可以直接獲得SqlSession物件
    public List<User> getUsers() {

        UserMapper mapper = getSqlSession().getMapper(UserMapper.class);

        User user = new User("小山", "33333", new Date());
        mapper.addUser(user);
        mapper.deleteUser(8);
        return mapper.getUsers();

    }

    public int addUser(User user){
        return getSqlSession().getMapper(UserMapper.class).addUser(user);
    }

    public int deleteUser(int id){
        return getSqlSession().getMapper(UserMapper.class).deleteUser(id);
    }

}

4、測試

@Test
public void test2(){
    ApplicationContext context = new ClassPathXmlApplicationContext("ApplicationContext.xml");
    UserMapper userMapper = (UserMapper) context.getBean("userMapperImpl2");
    List<User> userList = userMapper.getUsers();
    for (User user : userList) {
        System.out.println(user);
    }
}

報錯：sql異常，delete寫錯了

結果：插入成功

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

以前我們都需要自己手動管理事務，十分麻煩！

但是Spring給我們提供了事務管理，我們只需要配置即可；

2.3、Spring中的事務管理

• 宣告式事務：AOP
  • 一般情況下比程式設計式事務好用。
  • 將事務管理程式碼從業務方法中分離出來，以宣告的方式來實現事務管理。
  • 將事務管理作為橫切關注點，通過aop方法模組化。Spring中通過Spring AOP框架支援宣告式事務管理。
• 程式設計式事務：需要在程式碼中，進行事物的管理
  • 將事務管理程式碼嵌到業務方法中來控制事務的提交和回滾
  • 缺點：必須在每個事務操作業務邏輯中包含額外的事務管理程式碼

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

xmlns:tx="http://www.springframework.org/schema/tx"

http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd">

事務管理器

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

JDBC事務

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

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

<!--配置事務通知-->
<tx:advice id="txAdvice" transaction-manager="transactionManager">
   <tx:attributes>
       <!--配置哪些方法使用什麼樣的事務,配置事務的傳播特性-->
       <tx:method name="add" propagation="REQUIRED"/>
       <tx:method name="delete" propagation="REQUIRED"/>
       <tx:method name="update" propagation="REQUIRED"/>
       <tx:method name="search*" propagation="REQUIRED"/>
       <tx:method name="get" read-only="true"/>
       <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.chen.dao.*.*(..))"/>
    <aop:advisor advice-ref="txAdvice" pointcut-ref="txPointCut"/>
</aop:config>

進行測試

刪掉剛才插入的資料，再次測試！

@Test
public void test2(){
    ApplicationContext context = new ClassPathXmlApplicationContext("ApplicationContext.xml");
    UserMapper userMapper = (UserMapper) context.getBean("userMapperImpl2");
    List<User> userList = userMapper.getUsers();
    for (User user : userList) {
        System.out.println(user);
    }
}

思考：

為什麼需要事務？

• 如果不配置事務，可能存在資料提交不一致的情況
• 如果我們不在Spring中去配置宣告式事務，就需要在程式碼中手動配置事務
• 事務在專案開發中十分重要，涉及資料的一致性和完整性問題