spring jdbcTemplate 事務，各種詭異，包你醍醐灌頂！

来源:http://www.cnblogs.com/youzhibing/archive/2016/12/02/6127250.html
-Advertisement-
Play Games

前言 項目框架主要是spring，持久層框架沒有用mybtis，用的是spring 的jdbc； 業務需求：給應用添加領域(一個領域包含多個應用，一個應用可能屬於多個領域，一般而言一個應用只屬於一個領域)，要求是給應用添加領域的時候，先將該應用已有的領域都刪除，之後再將選中的領域添加到資料庫； 為了 ...


前言

　　項目框架主要是spring，持久層框架沒有用mybtis，用的是spring 的jdbc；

　　業務需求：給應用添加領域(一個領域包含多個應用，一個應用可能屬於多個領域，一般而言一個應用只屬於一個領域)，要求是給應用添加領域的時候，先將該應用已有的領域都刪除，之後再將選中的領域添加到資料庫；

　　為了減少準備工作，我利用了以前的代碼和數據建模，那麼就成了：添加person的時候先刪除已存在name為新添加person的name的person，再添加新person，說直白點就是：添加name為zhangsan的person，那麼先刪除資料庫中name為zhangsan的所有person信息，然後再將新的zhangsan的person信息添加到資料庫中；

　　環境搭建過程我就不寫了，完整代碼會以附件形式上傳；

　　註意：druid連接池一般而言，jdbc設置成自動提交，不設置的話，預設也是自動提交(有興趣的朋友可以去看下druid連接池的源碼)

 

jdbcTemplate自動提交

　　先來驗證下，當前jdbcTempalte是否是自動提交的，如何驗證了，我可以在jdbcTemplate執行完之後拋出一個異常，代碼如下　　

public int deleteOnePerson(String name) {
        int count = jdbcTemplate.update(DELETE_ONE_PERSON, new Object[]{name});        // jdbcTemplate執行完成
        count = count / 0;                                                            // 拋出RuntimeException
        return count;
    }

　　沒有配置事務

<?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:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
     http://www.springframework.org/schema/beans/spring-beans.xsd
     http://www.springframework.org/schema/context
     http://www.springframework.org/schema/context/spring-context.xsd
     http://www.springframework.org/schema/aop
     http://www.springframework.org/schema/aop/spring-aop.xsd
     http://www.springframework.org/schema/tx 
     http://www.springframework.org/schema/tx/spring-tx.xsd">
     
    <context:component-scan base-package="com.lee.you.jdbc" />

    <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="location">
                   <value>mysqldb.properties</value>
        </property>
    </bean>

    <!-- 配置數據源 -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
        <!-- 基本屬性 url、user、password -->  
        <property name="driverClassName" value="${jdbc.driverClassName}" />  
        <property name="url" value="${jdbc.url}" />  
        <property name="username" value="${jdbc.username}" />  
        <property name="password" value="${jdbc.password}" />  
        <property name="initialSize" value="${jdbc.initialSize}" />  
        <property name="minIdle" value="${jdbc.minIdle}" />   
        <property name="maxActive" value="${jdbc.maxActive}" />  
        <property name="maxWait" value="${jdbc.maxWait}" />
        <!-- 超過時間限制是否回收 -->
        <property name="removeAbandoned" value="${jdbc.removeAbandoned}" />
        <!-- 超過時間限制多長； -->
        <property name="removeAbandonedTimeout" value="${jdbc.removeAbandonedTimeout}" />
        <!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒 -->
        <property name="timeBetweenEvictionRunsMillis" value="${jdbc.timeBetweenEvictionRunsMillis}" />
        <!-- 配置一個連接在池中最小生存的時間，單位是毫秒 -->
        <property name="minEvictableIdleTimeMillis" value="${jdbc.minEvictableIdleTimeMillis}" />
        <!-- 用來檢測連接是否有效的sql，要求是一個查詢語句-->
        <property name="validationQuery" value="${jdbc.validationQuery}" />
        <!-- 申請連接的時候檢測 -->
        <property name="testWhileIdle" value="${jdbc.testWhileIdle}" />
        <!-- 申請連接時執行validationQuery檢測連接是否有效，配置為true會降低性能 -->
        <property name="testOnBorrow" value="${jdbc.testOnBorrow}" />
        <!-- 歸還連接時執行validationQuery檢測連接是否有效，配置為true會降低性能  -->
        <property name="testOnReturn" value="${jdbc.testOnReturn}" />
        
        <property name="defaultAutoCommit" value="${jdbc.defaultAutoCommit}" />
    </bean>

     <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource" />
    </bean>
</beans>
View Code

 

　　                                                                 

　　那麼如果直接像如下方式來處理先刪後加是不行的，如果刪成功添加失敗，那麼資料庫的數據卻只是刪了而沒有添加成功

public int insertOnePerson(String name, int age) {
        int result = 0;
        int count = jdbcTemplate.update(DELETE_ONE_PERSON, new Object[]{name});
        if(count >= 0)                                                                    // =0的情況是資料庫之前不存在該name的person信息
        {
            result = jdbcTemplate.update(INSERT_ONE_PERSON, new Object[]{name,age});
        }
        return result    ;
    }

 

手動提交事務

　　為了保證事務一致性，第一時間想到了jdbcTemplate是否有事務相關設置，然而並沒有發現，但是發現了jdbcTemplate.getDataSource().getConnection()，於是飛快的寫瞭如下代碼：

　　手動提交1

public int insertOnePerson(String name, int age) {
        int result = 0;
        try {
            jdbcTemplate.getDataSource().getConnection().setAutoCommit(false);
            int count = jdbcTemplate.update(DELETE_ONE_PERSON, new Object[]{name});
            if(count >= 0)                                                                    // =0的情況是資料庫之前不存在該name的person信息
            {
                result = jdbcTemplate.update(INSERT_ONE_PERSON, new Object[]{name,"1ac"});
            }
            jdbcTemplate.getDataSource().getConnection().commit();
        } catch (SQLException e) {
            e.printStackTrace();
            try {
                jdbcTemplate.getDataSource().getConnection().rollback();
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
        } finally {
            try {
                jdbcTemplate.getDataSource().getConnection().setAutoCommit(true);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return result    ;
    }

　　本以為實現事務一致性，可執行結果如下：                                        

                                                    

 　　發現沒有實現事務一致性，這是為什麼？？？？？？？ 這裡先留個懸念，大家好好思考下；當時我也沒去仔細研究，因為完成任務才是第一要緊事，緊接著寫出瞭如下代碼：

　　手動提交2

public int insertOnePerson(String name, int age) {
        int result = 0;
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            conn = jdbcTemplate.getDataSource().getConnection();
            if(conn != null)
            {
                conn.setAutoCommit(false);
                pstmt = conn.prepareStatement(DELETE_ONE_PERSON);
                pstmt.setString(1, name);
                int count = pstmt.executeUpdate();
                pstmt.close();
                if(count >= 0)
                {
                    pstmt = conn.prepareStatement(INSERT_ONE_PERSON);
                    pstmt.setString(1, name);
                    pstmt.setString(2, "1adh");                                        // 引發異常
                    result = pstmt.executeUpdate();
                }
                conn.commit();
            }
        } catch (SQLException e) {
            e.printStackTrace();
            try {
                conn.rollback();
            } catch (SQLException e1) {
                System.out.println("rollback failed..");
                e1.printStackTrace();
            }
        } finally {
            try{
                conn.setAutoCommit(true);
                if(pstmt != null){
                    pstmt.close();
                }
                if(conn != null){
                    conn.close();
                }
            }catch(SQLException e){
                
            }
        }
        return result    ;
    }

 　　詭異的事情來了，居然和上面的情況一樣：刪除成功，添加失敗！ 我的天老爺，這是怎麼回事？？？？

　　                         

　　瞬間懵逼了，怎麼回事？代碼怎麼改都不行！！！

　　mysql引擎

　　　　查看資料庫引擎，發現引擎是MyISAM！  瞬間爆炸！！！！

                                                              

　　將引擎改成InnoDB後，手動提交2的代碼是能夠保證事務一致性的，那麼手動提交1的代碼是不是也能保證事務一致性了？ 此處再留一個懸念，希望各位觀眾老爺們好好思考下。

 

事務自動管理

　　任務雖然完成了，可是無論是手動提交2，還是手動提交1(姑且認為能保證事務一致性)，代碼的try catch簡直讓人無法接受；映像中，spring有事務管理，那麼就來看看事務交給spring如何實現

　　配置事務管理器：

<?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:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
     http://www.springframework.org/schema/beans/spring-beans.xsd
     http://www.springframework.org/schema/context
     http://www.springframework.org/schema/context/spring-context.xsd
     http://www.springframework.org/schema/aop
     http://www.springframework.org/schema/aop/spring-aop.xsd
     http://www.springframework.org/schema/tx 
     http://www.springframework.org/schema/tx/spring-tx.xsd">
     
    <context:component-scan base-package="com.lee.you.jdbc" />

    <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="location">
                   <value>mysqldb.properties</value>
        </property>
    </bean>

    <!-- 配置數據源 -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
        <!-- 基本屬性 url、user、password -->  
        <property name="driverClassName" value="${jdbc.driverClassName}" />  
        <property name="url" value="${jdbc.url}" />  
        <property name="username" value="${jdbc.username}" />  
        <property name="password" value="${jdbc.password}" />  
        <property name="initialSize" value="${jdbc.initialSize}" />  
        <property name="minIdle" value="${jdbc.minIdle}" />   
        <property name="maxActive" value="${jdbc.maxActive}" />  
        <property name="maxWait" value="${jdbc.maxWait}" />
        <!-- 超過時間限制是否回收 -->
        <property name="removeAbandoned" value="${jdbc.removeAbandoned}" />
        <!-- 超過時間限制多長； -->
        <property name="removeAbandonedTimeout" value="${jdbc.removeAbandonedTimeout}" />
        <!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒 -->
        <property name="timeBetweenEvictionRunsMillis" value="${jdbc.timeBetweenEvictionRunsMillis}" />
        <!-- 配置一個連接在池中最小生存的時間，單位是毫秒 -->
        <property name="minEvictableIdleTimeMillis" value="${jdbc.minEvictableIdleTimeMillis}" />
        <!-- 用來檢測連接是否有效的sql，要求是一個查詢語句-->
        <property name="validationQuery" value="${jdbc.validationQuery}" />
        <!-- 申請連接的時候檢測 -->
        <property name="testWhileIdle" value="${jdbc.testWhileIdle}" />
        <!-- 申請連接時執行validationQuery檢測連接是否有效，配置為true會降低性能 -->
        <property name="testOnBorrow" value="${jdbc.testOnBorrow}" />
        <!-- 歸還連接時執行validationQuery檢測連接是否有效，配置為true會降低性能  -->
        <property name="testOnReturn" value="${jdbc.testOnReturn}" />
        
        <property name="defaultAutoCommit" value="${jdbc.defaultAutoCommit}" />
    </bean>

     <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource" />
    </bean>

    <!-- 事務管理器 -->
    <bean id="transactionManager"
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource" />
    </bean>
    
    <tx:annotation-driven transaction-manager="transactionManager" />
</beans>
View Code

　　配置事務

@Transactional
    public int insertOnePerson(String name, int age) {
        int result = 0;
        int count = jdbcTemplate.update(DELETE_ONE_PERSON, new Object[]{name});
        if(count >= 0)                                                                    
        {
            result = jdbcTemplate.update(INSERT_ONE_PERSON, new Object[]{name,"l123a"});
        }
        return result    ;
    }

　　執行結果如下：

　　    

　　這代碼清爽多了，要的就是這種感覺！！ 就是這個feel倍兒爽，爽爽爽爽！

 

 後話及懸念解答

　　搭建這個工程的用到了lombok，不知道的可以去百度下，我這裡就想提醒下，這玩意和一般的jar有區別，他需要安裝，不然編譯不通過! 喜歡搞事的jar；

　　另外druid連接池對mysql驅動是有版本要求的，mysql驅動5.1.10是會在連接池初始化的時候報錯的，具體是從哪個版本開始不報錯我就沒去逐個試了，知道的朋友可以留個言，本工程中用的是5.1.25版本；

警告: Cannot resolve com.mysq.jdbc.Connection.ping method.  Will use 'SELECT 1' instead.
java.lang.NullPointerException
    at com.alibaba.druid.pool.vendor.MySqlValidConnectionChecker.<init>(MySqlValidConnectionChecker.java:50)
    at com.alibaba.druid.pool.DruidDataSource.initValidConnectionChecker(DruidDataSource.java:892)
    at com.alibaba.druid.pool.DruidDataSource.init(DruidDataSource.java:608)
    at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:934)
    at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:930)
    at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:102)
    at org.springframework.jdbc.datasource.DataSourceUtils.doGetConnection(DataSourceUtils.java:111)
    at org.springframework.jdbc.datasource.DataSourceUtils.getConnection(DataSourceUtils.java:77)
    at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:386)
    at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:466)
    at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:471)
    at com.lee.you.jdbc.dao.impl.DaoImpl.queryAllPerson(DaoImpl.java:31)
    at com.lee.you.jdbc.JdbcTemplateTest.main(JdbcTemplateTest.java:17)
View Code

　　懸念解答：

　　　　還記得是哪兩個懸念嗎？　　1、手動提交1不能保證事務一致性是不是mysql引擎引起的；　　2、如果mysql引擎是支持事務的InnoDB，手動提交1能不能保證事務一致性；

　　　　關於懸念1，這個很明瞭，如果mysql引擎不支持事務，那麼代碼無論怎麼寫，事務一致性都是空談；

　　　　懸念2的話，是能肯定的回答：不能保證事務一致性的！ 因為jdbcTemplate.getDataSource().getConnection()獲取的connection與每次jdbcTemplate.update用到的connection都是從連接池中獲取的，不能保證是一個connection，那怎麼保證事務一致性; 感興趣的朋友可以去閱讀源碼，裡面各種黃金、各種美女哦！

　　那麼問題又來了，既然jdbcTemplate每次執行一個操作的時候都是從連接池中獲取connection，那麼spring事務管理是怎麼實現事務一致性的呢？更多精彩內容，請關註我的下篇博客

　　本文附件


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • C語言中指針定義的字元串和數組定義的字元串的區別
    2016-12-03 數組定義字元串： 每次定義數組的時候，系統都會在記憶體開闢你指定數組大小的空間，並且數組中的內容對於我們是可讀可寫的，看如下代碼： 1 #include<stdio.h> 2 int main() 3 { 4 char str[100] = "hello world"; 5 ch ...
  • 二級c程式設計題（2）
    原文：http://www.cnblogs.com/imaker/p/6128049.html 所屬年份：2010.9;2012.3編寫函數fun，其功能是：根據以下公式求π的值(要求精度0.0005，即某項小於0.0005時停止迭代)。 程式運行後，若輸入精度0.0005，則程式應輸出為3.14… ...
  • [terry筆記]python FTP
    如下是作業，用python做一個ftp，主要利用socket。 server端在linux下運行，在client端可以執行shell命令（靜態的） 在client端輸入get xxx，即可下載。 在client端輸入put xxx，即可上傳。 server端： client端： ...
  • SpringInAction讀書筆記--第1章Spring之旅
    1.簡化Java開發 Spring是一個開源框架，它的根本使命在於簡化java開發。為了降低java開發的複雜性，Spring採取了以下4種關鍵策略： 1.基於POJO的輕量級和最小侵入性編程； 有很多框架強迫應用繼承它們的類或實現它們的介面從而導致應用與框架綁死，而基於Spring構建的應用通常沒 ...
  • 【C++】pair
    STL的pair，有兩個值，可以是不同的類型。 template struct pair; 註意，pair在頭文件utility中，不要include。（一個錯誤是 include ） 成員類型 first_type first的類型 second_type second的類型 成員變數 first... ...
  • 字元串模板替換方法 MessageFormat.format
    解釋如下: content 中需要被替換的就是{}中的參數，array數組中存放的是對應的要替換的參數；使用MessageFormat方法的時候，需要要將這些參數的個數匹配正確，並且數序要指定，否則匹配出錯。這樣就實現了參數的替換。很簡單，也很死板。 MessageFormat:出自java.tex ...
  • 淺析String不可變性
    在所有編程語言領域，我想字元串應該是地球上最常用的表達手段了吧。 在java的世界里，String是作為類出現的，核心的一個域就是一個char數組，內部就是通過維護一個不可變的char數組，來向外部輸出的。 這是jdk一段String類定義，首先類是final，表明類不可被繼承；核心域是privat ...
  • 學習: java中 "package" 和 "import" 的使用舉例
    1.package 的用途，解決了什麼問題 提供類的命名空間，解決類的命名衝突，類文件管理問題 2.使用舉例 2.1 自測代碼 (1) package 必須做為源文件的第一條非註釋語句 (2) 一個源文件只能有一個包 (3) 沒有顯示指定則處於預設包下 (4) 同包下可自由訪問 1 package ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類