Spring一套全通4—持久層整合

百知教育 — Spring系列課程 — 持久層整合


第一章、持久層整合

1.Spring框架為什麼要與持久層技術進行整合
1. JavaEE開發需要持久層進行資料庫的訪問操作。
2. JDBC Hibernate MyBatis進行持久開發過程存在大量的程式碼冗餘
3. Spring基於模板設計模式對於上述的持久層技術進行了封裝
2. Spring可以與那些持久層技術進行整合?
1. JDBC
     |-  JDBCTemplate 
2. Hibernate (JPA)
     |-  HibernateTemplate
3. MyBatis
     |-  SqlSessionFactoryBean MapperScannerConfigure 

第二章、Spring與MyBatis整合

1. MyBatis開發步驟的回顧
1. 實體
2. 實體別名  
3. 表
4. 創建DAO介面
5. 實現Mapper文件
6. 註冊Mapper文件
7. MybatisAPI調用
2. Mybatis在開發過程中存在問題
配置繁瑣  程式碼冗餘 

1. 實體
2. 實體別名         配置繁瑣 
3. 表
4. 創建DAO介面
5. 實現Mapper文件
6. 註冊Mapper文件   配置繁瑣 
7. MybatisAPI調用  程式碼冗餘 
3. Spring與Mybatis整合思路分析

4. Spring與Mybatis整合的開發步驟
  • 配置文件(ApplicationContext.xml) 進行相關配置

    #配置 是需要配置一次 
    <bean id="dataSource" class=""/> 
    
    <!--創建SqlSessionFactory-->
    <bean id="ssfb" class="SqlSessionFactoryBean">
        <property name="dataSource" ref=""/>
        <property name="typeAliasesPackage">
             指定 實體類所在的包  com.baizhiedu.entity  User
                                                     Product
        </property>
        <property name="mapperLocations">
              指定 配置文件(映射文件)的路徑 還有通用配置 
              com.baizhiedu.mapper/*Mapper.xml 
        </property>
    </bean>
    
    <!--DAO介面的實現類
        session ---> session.getMapper() --- xxxDAO實現類對象 
        XXXDAO  ---> xXXDAO
    -->
    <bean id="scanner" class="MapperScannerConfigure">
        <property name="sqlSessionFactoryBeanName" value="ssfb"/>
        <property name="basePacakge">
            指定 DAO介面放置的包  com.baizhiedu.dao 
        </property>
    </bean>
    
  • 編碼

    # 實戰經常根據需求 寫的程式碼
    1. 實體
    2. 表
    3. 創建DAO介面
    4. 實現Mapper文件
    
5. Spring與Mybatis整合編碼
  • 搭建開發環境(jar)

    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-jdbc</artifactId>
      <version>5.1.14.RELEASE</version>
    </dependency>
    
    <dependency>
      <groupId>org.mybatis</groupId>
      <artifactId>mybatis-spring</artifactId>
      <version>2.0.2</version>
    </dependency>
    
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>druid</artifactId>
      <version>1.1.18</version>
    </dependency>
    
    <dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <version>5.1.48</version>
    </dependency>
    
    <dependency>
      <groupId>org.mybatis</groupId>
      <artifactId>mybatis</artifactId>
      <version>3.4.6</version>
    </dependency>
    
  • Spring配置文件的配置

    <!--連接池-->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
      <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
      <property name="url" value="jdbc:mysql://localhost:3306/suns?useSSL=false"></property>
      <property name="username" value="root"></property>
      <property name="password" value="123456"></property>
    </bean>
    
    <!--創建SqlSessionFactory SqlSessionFactoryBean-->
    <bean id="sqlSessionFactoryBean" class="org.mybatis.spring.SqlSessionFactoryBean">
      <property name="dataSource" ref="dataSource"></property>
      <property name="typeAliasesPackage" value="com.baizhiedu.entity"></property>
      <property name="mapperLocations">
        <list>
          <value>classpath:com.baizhiedu.mapper/*Mapper.xml</value>
        </list>
      </property>
    </bean>
    
    <!--創建DAO對象 MapperScannerConfigure-->
    
    <bean id="scanner" class="org.mybatis.spring.mapper.MapperScannerConfigurer">
      <property name="sqlSessionFactoryBeanName" value="sqlSessionFactoryBean"></property>
      <property name="basePackage" value="com.baizhiedu.dao"></property>
    </bean>
    
  • 編碼

    1. 實體
    2. 表
    3. DAO介面
    4. Mapper文件配置
    
6. Spring與Mybatis整合細節
  • 問題:Spring與Mybatis整合後,為什麼DAO不提交事務,但是數據能夠插入資料庫中?

    Connection --> tx
    Mybatis(Connection)
    
    本質上控制連接對象(Connection) ---> 連接池(DataSource)
    1. Mybatis提供的連接池對象 ---> 創建Connection
         Connection.setAutoCommit(false) 手工的控制了事務 , 操作完成後,手工提交
    2. Druid(C3P0 DBCP)作為連接池        ---> 創建Connection
         Connection.setAutoCommit(true) true默認值 保持自動控制事務,一條sql 自動提交 
    答案:因為Spring與Mybatis整合時,引入了外部連接池對象,保持自動的事務提交這個機制(Connection.setAutoCommit(true)),不需要手工進行事務的操作,也能進行事務的提交 
    
    注意:未來實戰中,還會手工控制事務(多條sql一起成功,一起失敗),後續Spring通過事務控制解決這個問題。
    

第三章、Spring的事務處理

1. 什麼是事務?
保證業務操作完整性的一種資料庫機制

事務的4特點: A C I D
1. A 原子性
2. C 一致性
3. I 隔離性
4. D 持久性
2. 如何控制事務
JDBC:
    Connection.setAutoCommit(false);
    Connection.commit();
    Connection.rollback();
Mybatis:
    Mybatis自動開啟事務
    
    sqlSession(Connection).commit();
    sqlSession(Connection).rollback();

結論:控制事務的底層 都是Connection對象完成的。
3.Spring控制事務的開發
Spring是通過AOP的方式進行事務開發
1. 原始對象
public class XXXUserServiceImpl{
   private xxxDAO xxxDAO
   set get

   1. 原始對象 ---》 原始方法 ---》核心功能 (業務處理+DAO調用)
   2. DAO作為Service的成員變數,依賴注入的方式進行賦值
}
2. 額外功能
1. org.springframework.jdbc.datasource.DataSourceTransactionManager
2. 注入DataSource 
1. MethodInterceptor
   public Object invoke(MethodInvocation invocation){
      try{
        Connection.setAutoCommit(false);
        Object ret = invocation.proceed();
        Connection.commit();
      }catch(Exception e){
        Connection.rollback();
      }
        return ret;
   }
2. @Aspect
   @Around 
3. 切入點
@Transactional 
事務的額外功能加入給那些業務方法。

1. 類上:類中所有的方法都會加入事務
2. 方法上:這個方法會加入事務
4 組裝切面
1. 切入點
2. 額外功能

<tx:annotation-driven transaction-manager=""/>
4. Spring控制事務的編碼
  • 搭建開發環境 (jar)

    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-tx</artifactId>
      <version>5.1.14.RELEASE</version>
    </dependency>
    
  • 編碼

    <bean id="userService" class="com.baizhiedu.service.UserServiceImpl">
      <property name="userDAO" ref="userDAO"/>
    </bean>
    
    <!--DataSourceTransactionManager-->
    <bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
      <property name="dataSource" ref="dataSource"/>
    </bean>
    
    @Transactional
    public class UserServiceImpl implements UserService {
        private UserDAO userDAO;
    
    <tx:annotation-driven transaction-manager="dataSourceTransactionManager"/>
    
  • 細節

    <tx:annotation-driven transaction-manager="dataSourceTransactionManager" proxy-target-class="true"/>
    進行動態代理底層實現的切換   proxy-target-class
        默認 false JDK
            true  Cglib 
    

第四章、 Spring中的事務屬性(Transaction Attribute)

1. 什麼是事務屬性
屬性:描述物體特徵的一系列值
     性別 身高 體重 ...
事務屬性:描述事務特徵的一系列值 
1. 隔離屬性
2. 傳播屬性
3. 只讀屬性
4. 超時屬性
5. 異常屬性 
2. 如何添加事務屬性
@Transactional(isloation=,propagation=,readOnly=,timeout=,rollbackFor=,noRollbackFor=,)
3. 事務屬性詳解
1. 隔離屬性 (ISOLATION)
  • 隔離屬性的概念

    概念:他描述了事務解決並發問題的特徵
    1. 什麼是並發
           多個事務(用戶)在同一時間,訪問操作了相同的數據
           
           同一時間:0.000幾秒 微小前 微小後
    2. 並發會產生那些問題
           1. 臟讀
           2. 不可重複讀
           3. 幻影讀
    3. 並發問題如何解決
           通過隔離屬性解決,隔離屬性中設置不同的值,解決並發處理過程中的問題。
    
  • 事務並發產生的問題

    • 臟讀

      一個事務,讀取了另一個事務中沒有提交的數據。會在本事務中產生數據不一致的問題
      解決方案  @Transactional(isolation=Isolation.READ_COMMITTED)
      
    • 不可重複讀

      一個事務中,多次讀取相同的數據,但是讀取結果不一樣。會在本事務中產生數據不一致的問題
      注意:1 不是臟讀 2 一個事務中
      解決方案 @Transactional(isolation=Isolation.REPEATABLE_READ)
      本質: 一把行鎖
      
    • 幻影讀

      一個事務中,多次對整表進行查詢統計,但是結果不一樣,會在本事務中產生數據不一致的問題
      解決方案 @Transactional(isolation=Isolation.SERIALIZABLE)
      本質:表鎖 
      
    • 總結

      並發安全: SERIALIZABLE>REPEATABLE_READ>READ_COMMITTED
      運行效率: READ_COMMITTED>REPEATABLE_READ>SERIALIZABLE
      
  • 資料庫對於隔離屬性的支援

    隔離屬性的值 MySQL Oracle
    ISOLATION_READ_COMMITTED
    IOSLATION_REPEATABLE_READ
    ISOLATION_SERIALIZABLE
    Oracle不支援REPEATABLE_READ值 如何解決不可重複讀
    採用的是多版本比對的方式 解決不可重複讀的問題
    
  • 默認隔離屬性

    ISOLATION_DEFAULT:會調用不同資料庫所設置的默認隔離屬性
    
    MySQL : REPEATABLE_READ 
    Oracle: READ_COMMITTED  
    
    • 查看資料庫默認隔離屬性

      • MySQL

        select @@tx_isolation;
        
      • Oracle

        SELECT s.sid, s.serial#,
           CASE BITAND(t.flag, POWER(2, 28))
              WHEN 0 THEN 'READ COMMITTED'
              ELSE 'SERIALIZABLE'
           END AS isolation_level
        FROM v$transaction t 
        JOIN v$session s ON t.addr = s.taddr
        AND s.sid = sys_context('USERENV', 'SID');
        
  • 隔離屬性在實戰中的建議

    推薦使用Spring指定的ISOLATION_DEFAULT
     1. MySQL   repeatable_read
     2. Oracle  read_commited 
    
    未來實戰中,並發訪問情況 很低 
    
    如果真遇到並發問題,樂觀鎖 
       Hibernate(JPA)  Version 
       MyBatis         通過攔截器自定義開發
     
    
2. 傳播屬性(PROPAGATION)
  • 傳播屬性的概念

    概念:他描述了事務解決嵌套問題的特徵
    
    什麼叫做事務的嵌套:他指的是一個大的事務中,包含了若干個小的事務
    
    問題:大事務中融入了很多小的事務,他們彼此影響,最終就會導致外部大的事務,喪失了事務的原子性
    
  • 傳播屬性的值及其用法

    傳播屬性的值 外部不存在事務 外部存在事務 用法 備註
    REQUIRED 開啟新的事務 融合到外部事務中 @Transactional(propagation = Propagation.REQUIRED) 增刪改方法
    SUPPORTS 不開啟事務 融合到外部事務中 @Transactional(propagation = Propagation.SUPPORTS) 查詢方法
    REQUIRES_NEW 開啟新的事務 掛起外部事務,創建新的事務 @Transactional(propagation = Propagation.REQUIRES_NEW) 日誌記錄方法中
    NOT_SUPPORTED 不開啟事務 掛起外部事務 @Transactional(propagation = Propagation.NOT_SUPPORTED) 及其不常用
    NEVER 不開啟事務 拋出異常 @Transactional(propagation = Propagation.NEVER) 及其不常用
    MANDATORY 拋出異常 融合到外部事務中 @Transactional(propagation = Propagation.MANDATORY) 及其不常用
  • 默認的傳播屬性

    REQUIRED是傳播屬性的默認值
    
  • 推薦傳播屬性的使用方式

    增刪改 方法:直接使用默認值REQUIRED 
    查詢   操作:顯示指定傳播屬性的值為SUPPORTS  
    
3. 只讀屬性(readOnly)
針對於只進行查詢操作的業務方法,可以加入只讀屬性,提供運行效率

默認值:false 
4. 超時屬性(timeout)
指定了事務等待的最長時間

1. 為什麼事務進行等待?
   當前事務訪問數據時,有可能訪問的數據被別的事務進行加鎖的處理,那麼此時本事務就必須進行等待。
2. 等待時間 秒
3. 如何應用 @Transactional(timeout=2)
4. 超時屬性的默認值 -1 
   最終由對應的資料庫來指定
5. 異常屬性
Spring事務處理過程中
默認 對於RuntimeException及其子類 採用的是回滾的策略
默認 對於Exception及其子類 採用的是提交的策略

rollbackFor = {java.lang.Exception,xxx,xxx} 
noRollbackFor = {java.lang.RuntimeException,xxx,xx}

@Transactional(rollbackFor = {java.lang.Exception.class},noRollbackFor = {java.lang.RuntimeException.class})

建議:實戰中使用RuntimeExceptin及其子類 使用事務異常屬性的默認值
4. 事務屬性常見配置總結
1. 隔離屬性   默認值 
2. 傳播屬性   Required(默認值) 增刪改   Supports 查詢操作
3. 只讀屬性   readOnly false  增刪改   true 查詢操作
4. 超時屬性   默認值 -1
5. 異常屬性   默認值 

增刪改操作   @Transactional
查詢操作     @Transactional(propagation=Propagation.SUPPORTS,readOnly=true)
5. 基於標籤的事務配置方式(事務開發的第二種形式)
基於註解 @Transaction的事務配置回顧
<bean id="userService" class="com.baizhiedu.service.UserServiceImpl">
  <property name="userDAO" ref="userDAO"/>
</bean>

<!--DataSourceTransactionManager-->
<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  <property name="dataSource" ref="dataSource"/>
</bean>

@Transactional(isolation=,propagation=,...)
public class UserServiceImpl implements UserService {
    private UserDAO userDAO;

<tx:annotation-driven transaction-manager="dataSourceTransactionManager"/>

基於標籤的事務配置
<bean id="userService" class="com.baizhiedu.service.UserServiceImpl">
  <property name="userDAO" ref="userDAO"/>
</bean>

<!--DataSourceTransactionManager-->
<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  <property name="dataSource" ref="dataSource"/>
</bean>

事務屬性 
<tx:advice id="txAdvice" transacation-manager="dataSourceTransactionManager">
    <tx:attributes>
          <tx:method name="register" isoloation="",propagation=""></tx:method>
          <tx:method name="login" .....></tx:method>
          等效於 
          @Transactional(isolation=,propagation=,)
          public void register(){
        
          }
      
    </tx:attributes>
</tx:advice>

<aop:config>
     <aop:pointcut id="pc" expression="execution(* com.baizhiedu.service.UserServiceImpl.register(..))"></aop:pointcut>
     <aop:advisor advice-ref="txAdvice" pointcut-ref="pc"></aop:advisor>
</aop:config>
  • 基於標籤的事務配置在實戰中的應用方式

    <bean id="userService" class="com.baizhiedu.service.UserServiceImpl">
      <property name="userDAO" ref="userDAO"/>
    </bean>
    
    <!--DataSourceTransactionManager-->
    <bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
      <property name="dataSource" ref="dataSource"/>
    </bean>
    
    編程時候 service中負責進行增刪改操作的方法 都以modify開頭
                           查詢操作 命名無所謂 
    <tx:advice id="txAdvice" transacation-manager="dataSourceTransactionManager">
        <tx:attributes>
              <tx:method name="register"></tx:method>
              <tx:method name="modify*"></tx:method>
              <tx:method name="*" propagation="SUPPORTS"  read-only="true"></tx:method>
        </tx:attributes>
    </tx:advice>
    
    應用的過程中,service放置到service包中
    <aop:config>
         <aop:pointcut id="pc" expression="execution(* com.baizhiedu.service..*.*(..))"></aop:pointcut>
         <aop:advisor advice-ref="txAdvice" pointcut-ref="pc"></aop:advisor>
    </aop:config>