2. 程式人生 > >Spring JDBC-混合框架的事務管理

Spring JDBC-混合框架的事務管理

阿新 • • 發佈：2017-10-01
組合 manager 延遲 發生 required 應用 conf 一個 研究

  • ?

Spring 抽象的 DAO 體系兼容多種數據訪問技術，它們各有特色，各有千秋。

  • Hibernate 是非常優秀的 ORM 實現方案，但對底層 SQL 的控制不太方便

  • MyBatis 則通過模板化技術讓我們能方便地控制 SQL，但沒有 Hibernate 那樣高的開發效率

  • 自由度最高的當然是直接使用 Spring JDBC 莫屬了，但是它也是最底層的，靈活的代價是代碼的繁復

很難說哪種數據訪問技術是最優秀的，只有在某種特定的場景下，才能給出答案。所以在一個應用中，往往采用多個數據訪問技術：一般是兩種，一種采用 ORM 技術框架，而另一種采用偏 JDBC 的底層技術。

問題

當我們采用：ORM 技術框架+ 偏 JDBC 的底層技術如何應對事務管理的問題呢？ 我們知道 Spring 為每種數據訪問技術提供了相應的事務管理器，難道需要分別為它們配置對應的事務管理器嗎？它們到底是如何協作，如何工作的呢？

解決方案

Spring 事務管理的為我們的提供了解決方案。

當我們采用了一個高端 ORM 技術（Hibernate，JPA，JDO），同時采用一個 JDBC 技術（Spring JDBC，MyBatis），由於前者的會話（Session）是對後者連接（Connection）的封裝，Spring 會“足夠智能地”在同一個事務線程讓前者的會話封裝後者的連接。所以，我們只要直接采用前者的事務管理器就可以了。

我們列舉下混合數據訪問技術所對應的事務管理器：

技術分享

示例：Hibernate + Spring JDBC

由於一般不會出現同時使用多個 ORM 框架的情況（如 Hibernate + JPA），我們不擬對此命題展開論述，只重點研究 ORM 框架 + JDBC 框架的情況。

Hibernate + Spring JDBC 可能是被使用得最多的組合，我們通過實例來觀察事物的運行情況。

User 使用了註解聲明的實體類

import javax.persistence.Entity; import javax.persistence.Table; import javax.persistence.Column; import javax.persistence.Id; import java.io.Serializable; @Entity @Table(name="T_USER") public class User implements Serializable{ @Id @Column(name = "USER_NAME") private String userName; private String password; private int score; @Column(name = "LAST_LOGON_TIME") private long lastLogonTime = 0;  
}

UserService 使用 Hibernate 數據訪問技術

import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import org.springframework.stereotype.Service; import org.springframework.orm.hibernate3.HibernateTemplate; import org.apache.commons.dbcp.BasicDataSource; import user.User; @Service("userService") public class UserService extends BaseService { @Autowired private HibernateTemplate hibernateTemplate; @Autowired private ScoreService scoreService; public void logon(String userName) {
        System.out.println("logon method...");
        updateLastLogonTime(userName); //①使用Hibernate數據訪問技術 scoreService.addScore(userName, 20); //②使用Spring JDBC數據訪問技術 } public void updateLastLogonTime(String userName) {
        System.out.println("updateLastLogonTime...");
        User user = hibernateTemplate.get(User.class,userName);
        user.setLastLogonTime(System.currentTimeMillis());
        hibernateTemplate.flush(); //③請看下文的分析 }
}

在①處，使用 Hibernate 操作數據，而在②處調用 ScoreService#addScore()，該方法內部使用 Spring JDBC 操作數據。

在③處，我們顯式調用了 flush() 方法，將 Session 中的緩存同步到數據庫中，這個操作將即時向數據庫發送一條更新記錄的 SQL 語句。

之所以要在此顯式執行 flush() 方法，原因是：默認情況下，Hibernate 要在事務提交時才將數據的更改同步到數據庫中，而事務提交發生在 logon() 方法返回前。

如果所有針對數據庫的更改都使用 Hibernate，這種數據同步延遲的機制不會產生任何問題。但是，我們在 logon() 方法中同時采用了 Hibernate 和 Spring JDBC 混合數據訪問技術。

Spring JDBC 無法自動感知 Hibernate 一級緩存，所以如果不及時調用 flush() 方法將數據更改同步到數據庫，則②處通過 Spring JDBC 進行數據更改的結果將被 Hibernate 一級緩存中的更改覆蓋掉，武漢試管嬰兒因為，一級緩存在 logon() 方法返回前才同步到數據庫！

ScoreService ：使用 Spring JDBC 數據訪問技術

import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Service; import org.apache.commons.dbcp.BasicDataSource; @Service("scoreUserService") public class ScoreService extends BaseService{ @Autowired private JdbcTemplate jdbcTemplate; public void addScore(String userName, int toAdd) {
        System.out.println("addScore...");
        String sql = "UPDATE t_user u SET u.score = u.score + ? WHERE user_name =?";
        jdbcTemplate.update(sql, toAdd, userName); //① 查看此處數據庫激活的連接數 BasicDataSource basicDataSource = (BasicDataSource) jdbcTemplate.getDataSource();
        System.out.println("激活連接數量："+basicDataSource.getNumActive());
    }
}

關鍵配置文件

<!-- 使用Hibernate事務管理器 --> <bean id="hiberManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager" p:sessionFactory-ref="sessionFactory"/> <!-- 對所有繼承BaseService類的公用方法實施事務增強 --> <aop:config proxy-target-class="true"> <aop:pointcut id="serviceJdbcMethod" expression="within(com.artisan.BaseService+)"/> <aop:advisor pointcut-ref="serviceJdbcMethod" advice-ref="hiberAdvice"/> </aop:config> <tx:advice id="hiberAdvice" transaction-manager="hiberManager"> <tx:attributes> <tx:method name="*"/> </tx:attributes> </tx:advice>

日誌：

21:37:57,062 (AbstractPlatformTransactionManager.java:365) - Creating new transaction 
    with name [com.artisan.UserService.logon]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT 21:37:57,093 (SessionImpl.java:220) - opened session at timestamp: 12666407370 21:37:57,093 (HibernateTransactionManager.java:493) - Opened new Session 
    [org.hibernate.impl.SessionImpl@83020] for Hibernate transaction ① 21:37:57,093 (HibernateTransactionManager.java:504) - Preparing JDBC Connection 
    of Hibernate Session [org.hibernate.impl.SessionImpl@83020] 21:37:57,109 (JDBCTransaction.java:54) - begin

…

logon method...
updateLastLogonTime...
… 21:37:57,109 (AbstractBatcher.java:401) - select user0_.USER_NAME as USER1_0_0_, 
    user0_.LAST_LOGON_TIME as LAST2_0_0_, user0_.password as password0_0_, 
    user0_.score as score0_0_ from T_USER user0_ where user0_.USER_NAME=? Hibernate: select user0_.USER_NAME as USER1_0_0_, 
    user0_.LAST_LOGON_TIME as LAST2_0_0_, user0_.password as password0_0_, 
    user0_.score as score0_0_ from T_USER user0_ where user0_.USER_NAME=?

… 21:37:57,187 (HibernateTemplate.java:422) - Not closing pre-bound 
    Hibernate Session after HibernateTemplate 21:37:57,187 (HibernateTemplate.java:397) - Found thread-bound Session
    for HibernateTemplate Hibernate: update T_USER set LAST_LOGON_TIME=?, password=?, score=? where USER_NAME=?

… 2017-09-26 21:37:57,203 DEBUG [main] (AbstractPlatformTransactionManager.java:470) 
    - Participating in existing transaction ②
addScore... 2017-09-26 21:37:57,203 DEBUG [main] (JdbcTemplate.java:785) 
    - Executing prepared SQL update 2017-09-26 21:37:57,203 DEBUG [main] (JdbcTemplate.java:569)
    - Executing prepared SQL statement 
    [UPDATE t_user u SET u.score = u.score + ? WHERE user_name =?] 2017-09-26 21:37:57,203 DEBUG [main] (JdbcTemplate.java:794) 
    - SQL update affected 1 rows

激活連接數量：1 ③ 2017-09-26 21:37:57,203 DEBUG [main] (AbstractPlatformTransactionManager.java:752) 
    - Initiating transaction commit 2017-09-26 21:37:57,203 DEBUG [main] (HibernateTransactionManager.java:652) 
    - Committing Hibernate transaction on Session 
    [org.hibernate.impl.SessionImpl@83020] ④ 2017-09-26 21:37:57,203 DEBUG [main] (JDBCTransaction.java:103) - commit ⑤

在①處 UserService#logon() 開啟一個新的事務，
在②處 ScoreService#addScore() 方法加入到①處開啟的事務上下文中。
③處的輸出是 ScoreService#addScore() 方法內部的輸出，匯報此時數據源激活的連接數為 1，回力這清楚地告訴我們 Hibernate 和 JDBC 這兩種數據訪問技術在同一事務上下文中“共用”一個連接。
在④處，提交 Hibernate 事務，
接著在⑤處觸發調用底層的 Connection 提交事務。

使用 Hibernate 事務管理器後，可以混合使用 Hibernate 和 Spring JDBC 數據訪問技術，它們將工作於同一事務上下文中。但是使用 Spring JDBC 訪問數據時，Hibernate 的一級或二級緩存得不到同步，此外，一級緩存延遲數據同步機制可能會覆蓋 Spring JDBC 數據更改的結果。

由於混合數據訪問技術的方案的事務同步而緩存不同步的情況，所以最好用 Hibernate 完成讀寫操作，而用 Spring JDBC 完成讀的操作。比如用 Spring JDBC 進行簡要列表的查詢，而用 Hibernate 對查詢出的數據進行維護。

如果確實要同時使用 Hibernate 和 Spring JDBC 讀寫數據，則必須充分考慮到 Hibernate 緩存機制引發的問題：必須充分分析數據維護邏輯，根據需要，及時調用 Hibernate 的 flush() 方法，以免覆蓋 Spring JDBC 的更改，在 Spring JDBC 更改數據庫時，維護 Hibernate 的緩存。

可以將以上結論推廣到其它混合數據訪問技術的方案中，如 Hibernate+MyBatis,JPA+Spring JDBC，JDO+Spring JDBC 等

Spring JDBC-混合框架的事務管理

相關推薦

Spring JDBC-混合框架的事務管理

組合 manager 延遲 發生 required 應用 conf 一個 研究 ? Spring 抽象的 DAO 體系兼容多種數據訪問技術，它們各有特色，各有千秋。 Hibernate 是非常優秀的 ORM 實現方案，但對底層 SQL 的控制不太方便 M

四、spring的JDBC模板和事務管理

Spring的JDBC模板 Spring是JavaEE開發的一站式框架，對各種持久化技術都提供了簡單的模板 ORM持久化技術 模板類 JDBC org.springframework.jdbc.core.JdbcTemplate

xml方式實現spring的宣告式事務管理及對jdbc操作的支援

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"     xmlns:xsi="http://www.w3.org/2001/XMLSchema-

Spring框架事務管理之四：Spring程式設計式事務

雖然Spring框架推薦使用宣告式事務管理，但是我們也要了解一下Spring的程式設計式事務。Spring程式設計式事務僅適用於操作簡單的事務，有兩種程式設計實現的方式：直接使用org.springframework.transaction.PlatformTransacti

馬士兵Spring-聲明式事務管理-annotation

con his pri 默認值 bsp nco cti generated span 1.事務加在DAO層還是service層？ service中可能多涉及多種DAO的操作，比如存了一個User之後，需要保存一條日誌信息；如果在DAO中分別設置事務的話，一個DAO下面方法拋

spring支持的事務管理

持久化 完成 nes 標簽 什麽 異常 管理器 ont 文件中 1、編程式事務： 需在spring.xml配置文件中， 1、配置數據源、 2、持久化模板(jdbc模板、hibernate模板、mybatis模板)、 對象裏面註入的是數據源及框架的屬性配置； 3

Spring 聲明式事務管理（11）

fault cep 維護 eat ati 信息 圖書管理 rem tro 案例分析 　　本案例是圖書管理系統精簡部分，在數據庫中有3張表。分別保存圖書庫存、圖書信息和用戶信息。下面是建表SQL語句 1 DROP TABLE IF EXISTS store; 2 DR

spring配置多個事務管理器

<tx:annotation-driven/> <bean id="transactionManager1" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <prope

Java程式設計師從笨鳥到菜鳥之（八十）細談Spring（九）spring+hibernate宣告式事務管理詳解

分享一下我老師大神的人工智慧教程！零基礎，通俗易懂！http://blog.csdn.net/jiangjunshow 也歡迎大家轉載本篇文章。分享知識，造福人民，實現我們中華民族偉大復興！        

Spring的資料訪問---------------事務管理

ThreadLocal 　　ThreadLocal為每一個使用該變數的執行緒分配一個變數副本，所以每一個執行緒在改變自己的副本時，不會改變其他執行緒的副本資訊。該類主要包含四個方法： 　　public void set(Object obj) 　　public Object get() 　　publi

JDBC例子4_事務管理

事務管理 1 事務概述  事務指的是邏輯上的一組操作(多條sql語句),組成這組操作的各個單元要麼全都成功,要麼全都失敗.  事務作用：保證在一個事務中多次操作要麼全都成功,要麼全都失敗. 例如轉賬： update account set money=money-100 wh

使用註解實現Spring的宣告式事務管理

使用註解實現Spring的宣告式事務管理，更加簡單！ 步驟：          1） 必須引入Aop相關的jar檔案          2） b

Spring原始碼分析筆記--事務管理

核心類 InfrastructureAdvisorAutoProxyCreator 本質是一個後置處理器，和AOP的後置處理器類似，但比AOP的使用級別低。當開啟AOP代理模式後，優先使用AOP的後置處理器。 AopConfigUtils： /** * The bean name of the

Spring 的 AOP 進行事務管理的一些問題

AspectJ AOP事務屬性的配置（隔離級別、傳播行為等）： <tx:advice id="myAdvice" transaction-manager="mtTxManager"> <tx:attributes> <tx:method

Spring Boot中的事務管理實戰

一 什麼是事務 在開發企業應用時，對於業務人員的一個操作實際是對資料讀寫的多步操作的結合。由於資料操作在順序執行的過程中，任何一步操作都有可能發生異常，異常會導致後續操作無法完成，此時由於業務邏輯並未正確的完成，之前成功操作資料的並不可靠，需要在這種情況下進行回退。 事務

Spring Boot多資料來源事務管理

在開發企業應用時，對於使用者的一個操作實際上對應底層資料庫的多個讀寫。由於資料操作在順序執行的過程中，任何一步操作都有可能發生異常，異常會導致後續操作無法完成，此時由於業務邏輯並未正確的完成，之前成功操作資料的並不可靠，會產生不一致的資料，需要在這種情況下進行回退。事務的作用

Spring的四種事務管理（一種程式設計式事務+三種宣告事務）

Spring的4種事務管理（1種程式設計式事務+三種宣告事務） 一、Spring事務的介紹 二、程式設計式事務xml的配置 注入後直接在service層呼叫模板的方法使用 三、基於AOP方式的宣告式事務管理 prop的具體配置

spring資料來源配置及事務管理--entityManager

一、實體管理其必須執行在web（ejb容器）容器，用main方法是不能執行的。 二、配置檔案：applicationContext-em.xml <beans xmlns="http://www.springframework.org/schema/beans"   

Spring入門學習（事務管理） 第十九節

Spring入門學習（事務管理） 事務簡介 事務的四個關鍵屬性（ACID） 沒有事務之前 事務管理器 事務簡介 事務就是用來確保資料的完整性和一致性的一系列的動作，它們被當做一個單獨的工作單元，這些動作要

Spring整合MyBatis進行事務管理

1、引入的Spring和MyBatis依賴的jar包    引入c3p0.jar與mchange-commons.jar是為了使用資料庫連線池，資料庫連線池會在MyBatis以及Spring的事務管理器介面PlatformTransactionManager中使用到。