• <noscript id="e0iig"><kbd id="e0iig"></kbd></noscript>
  • <td id="e0iig"></td>
  • <option id="e0iig"></option>
  • <noscript id="e0iig"><source id="e0iig"></source></noscript>
  • Mybatis源碼解析之事務管理

    Mybatis源碼解析之核心類分析
    Mybatis源碼解析之初始化分析
    Mybatis源碼解析之執行流程解析
    Mybatis源碼解析之數據庫連接和連接池

    一、事務簡介

    1. 事務的特性(ACID)

    (1)原子性(Atomicity)

    一個事務內的所有操作,要么全部完成,要么全部沒做,不可能存在中間狀態。如果一個事務在執行過程中出現異常,會將已經執行完成的操作回滾,使得所有操作保持在全部沒做的狀態

    (2)一致性(Consistency)

    事務執行前和執行后的數據庫的完整性約束沒有變化,執行前和執行后都處于一致性狀態。
    比如,A向B轉賬,轉賬就是一個事務,不管轉賬多少次,A和B的賬戶總額一致。

    (3)隔離性(Isolation)

    事務和事務之間互相隔離,互不影響。

    (4)持久性(Durability)

    事務完成后對數據庫中數據的改變是永久的。

    2. 事務的并發問題

    (1)臟讀

    臟讀是指事務A讀取到事務B未提交的數據。

    (2)不可重復讀

    不可重復讀是指同一事物內的兩次相同的查詢操作讀取到了不同的數據,比如事務A兩次查詢操作之間,事務B對數據進行了修改并提交。

    (3)幻讀

    幻讀是指事務A提交了一次更新操作,此時事務B新插入了一條數據,之后事務A查看數據會發現有一條數據沒有更新,仿佛出現了幻覺。

    不可重復讀和幻讀都是一個事務A讀取了事務B提交之后的數據,而臟讀是指事務A讀取了事務B沒有提交的數據。
    不可重復讀和幻讀有些相似,容易出現混淆。不可重復讀側重于另一事務的修改操作,幻讀側重于另一事務的增加和刪除操作。不可重復讀的避免需要行鎖,幻讀需要表鎖。

    3. 事務隔離級別

    事務隔離級別

    二、事務的配置

    1. transaction節點的配置

    事務transaction通過配置文件的transaction節點進行配置,和數據源datasource節點一樣都是environment節點的子節點,如:

    <environments default="test">
      <environment id="test">
    	 <transactionManager type="JDBC"></transactionManager>
    	 <dataSource type="UNPOOLED">
    	      <property name="driver" value="${driver-class-name}"/>
    	      <property name="url" value="${url}"/>
    	      <property name="username" value="${username}"/>
    	      <property name="password" value="${password}"/>
    	 </dataSource>
      </environment>
    </environments>
    
    參考自http://www.mybatis.org/mybatis-3/zh/configuration.html#environments
    在 MyBatis 中有兩種類型的事務管理器(也就是 type=”[JDBC|MANAGED]”):
    JDBC – 這個配置就是直接使用了 JDBC 的提交和回滾設置,它依賴于從數據源得到的連接來管理事務作用域。
    MANAGED – 這個配置幾乎沒做什么。它從來不提交或回滾一個連接,而是讓容器來管理事務的整個生命周期(比如 JEE 應用服務器的上下文)。 默認情況下它會關閉連接,然而一些容器并不希望這樣,因此需要將 closeConnection 屬性設置為 false 來阻止它默認的關閉行為。例如:
    <transactionManager type="MANAGED">
      <property name="closeConnection" value="false"/>
    </transactionManager>
    

    2. transaction節點的解析

    同樣的,根據前面幾篇博客可以知道,配置文件的解析在XMLConfigBuilder#parse()方法中進行,而關于transaction節點的解析則委托給了XMLConfigBuilder#transactionManagerElement(XNode)方法處理。

    private TransactionFactory transactionManagerElement(XNode context) throws Exception {
      if (context != null) {
        String type = context.getStringAttribute("type");
        Properties props = context.getChildrenAsProperties();
        TransactionFactory factory = (TransactionFactory) resolveClass(type).newInstance();
        factory.setProperties(props);
        return factory;
      }
      throw new BuilderException("Environment declaration requires a TransactionFactory.");
    }
    

    根據type屬性找到對象的TransactionFactory類型,調用無參構造器生成TransactionFactory對象。

    三、事務管理

    1.類圖

    Transaction類圖
    Mybatis自己并不處理事務,只是做一層封裝,方便調用。

    1. TransactioIsolationLevel

    TransactionIsolationLeve就是Mybatis的事務隔離級別,Mybatis一共有5中,NONE代表不支持事務,其它4種與數據庫事務隔離級別一一對應。

    public enum TransactionIsolationLevel {
      NONE(Connection.TRANSACTION_NONE),
      READ_COMMITTED(Connection.TRANSACTION_READ_COMMITTED),
      READ_UNCOMMITTED(Connection.TRANSACTION_READ_UNCOMMITTED),
      REPEATABLE_READ(Connection.TRANSACTION_REPEATABLE_READ),
      SERIALIZABLE(Connection.TRANSACTION_SERIALIZABLE);
    
      private final int level;
    
      private TransactionIsolationLevel(int level) {
        this.level = level;
      }
    
      public int getLevel() {
        return level;
      }
    }
    

    2. JdbcTransaction

    JdbcTransaction就是由jdbc處理事務,有connection對象完成事務的commit、rollback和close。

    @Override
    public void commit() throws SQLException {
      if (connection != null && !connection.getAutoCommit()) {
        if (log.isDebugEnabled()) {
          log.debug("Committing JDBC Connection [" + connection + "]");
        }
        connection.commit();
      }
    }
    
    @Override
    public void rollback() throws SQLException {
      if (connection != null && !connection.getAutoCommit()) {
        if (log.isDebugEnabled()) {
          log.debug("Rolling back JDBC Connection [" + connection + "]");
        }
        connection.rollback();
      }
    }
    
    @Override
    public void close() throws SQLException {
      if (connection != null) {
        resetAutoCommit();
        if (log.isDebugEnabled()) {
          log.debug("Closing JDBC Connection [" + connection + "]");
        }
        connection.close();
      }
    }
    protected void resetAutoCommit() {
      try {
        if (!connection.getAutoCommit()) {
          // MyBatis does not call commit/rollback on a connection if just selects were performed.
          // Some databases start transactions with select statements
          // and they mandate a commit/rollback before closing the connection.
          // A workaround is setting the autocommit to true before closing the connection.
          // Sybase throws an exception here.
          if (log.isDebugEnabled()) {
            log.debug("Resetting autocommit to true on JDBC Connection [" + connection + "]");
          }
          connection.setAutoCommit(true);
        }
      } catch (SQLException e) {
        if (log.isDebugEnabled()) {
          log.debug("Error resetting autocommit to true "
            + "before closing the connection.  Cause: " + e);
        }
      }
    }
    

    可以看到,close方法中會將connection設置成自動提交。

    3. ManagedTransaction

    ManagedTransaction讓容器來管理事務Transaction的整個生命周期,使用ManagedTransaction的commit和rollback功能不會對事務有任何的影響,它什么都不會做,它將事務管理的權利移交給了容器來實現。

    @Override
    public void commit() throws SQLException {
      // Does nothing
    }
    
    @Override
    public void rollback() throws SQLException {
      // Does nothing
    }
    
    @Override
    public void close() throws SQLException {
      if (this.closeConnection && this.connection != null) {
        if (log.isDebugEnabled()) {
          log.debug("Closing JDBC Connection [" + this.connection + "]");
        }
        this.connection.close();
      }
    }
    
    版權聲明:本文為qq_39470742原創文章,遵循 CC 4.0 BY-SA 版權協議,轉載請附上原文出處鏈接和本聲明。
    本文鏈接:https://blog.csdn.net/qq_39470742/article/details/88546054

    智能推薦

    電腦空間不夠了?教你一個小秒招快速清理 Docker 占用的磁盤空間!

    Docker 很占用空間,每當我們運行容器、拉取鏡像、部署應用、構建自己的鏡像時,我們的磁盤空間會被大量占用。 如果你也被這個問題所困擾,咱們就一起看一下 Docker 是如何使用磁盤空間的,以及如何回收。 docker 占用的空間可以通過下面的命令查看: TYPE 列出了docker 使用磁盤的 4 種類型: Images:所有鏡像占用的空間,包括拉取下來的鏡像,和本地構建的。 Con...

    requests實現全自動PPT模板

    http://www.1ppt.com/moban/ 可以免費的下載PPT模板,當然如果要人工一個個下,還是挺麻煩的,我們可以利用requests輕松下載 訪問這個主頁,我們可以看到下面的樣式 點每一個PPT模板的圖片,我們可以進入到詳細的信息頁面,翻到下面,我們可以看到對應的下載地址 點擊這個下載的按鈕,我們便可以下載對應的PPT壓縮包 那我們就開始做吧 首先,查看網頁的源代碼,我們可以看到每一...

    Linux C系統編程-線程互斥鎖(四)

    互斥鎖 互斥鎖也是屬于線程之間處理同步互斥方式,有上鎖/解鎖兩種狀態。 互斥鎖函數接口 1)初始化互斥鎖 pthread_mutex_init() man 3 pthread_mutex_init (找不到的情況下首先 sudo apt-get install glibc-doc sudo apt-get install manpages-posix-dev) 動態初始化 int pthread_...

    統計學習方法 - 樸素貝葉斯

    引入問題:一機器在良好狀態生產合格產品幾率是 90%,在故障狀態生產合格產品幾率是 30%,機器良好的概率是 75%。若一日第一件產品是合格品,那么此日機器良好的概率是多少。 貝葉斯模型 生成模型與判別模型 判別模型,即要判斷這個東西到底是哪一類,也就是要求y,那就用給定的x去預測。 生成模型,是要生成一個模型,那就是誰根據什么生成了模型,誰就是類別y,根據的內容就是x 以上述例子,判斷一個生產出...

    猜你喜歡

    styled-components —— React 中的 CSS 最佳實踐

    https://zhuanlan.zhihu.com/p/29344146 Styled-components 是目前 React 樣式方案中最受關注的一種,它既具備了 css-in-js 的模塊化與參數化優點,又完全使用CSS的書寫習慣,不會引起額外的學習成本。本文是 styled-components 作者之一 Max Stoiber 所寫,首先總結了前端組件化樣式中的最佳實踐原則,然后在此基...

    基于TCP/IP的網絡聊天室用Java來實現

    基于TCP/IP的網絡聊天室實現 開發工具:eclipse 開發環境:jdk1.8 發送端 接收端 工具類 運行截圖...

    19.vue中封裝echarts組件

    19.vue中封裝echarts組件 1.效果圖 2.echarts組件 3.使用組件 按照組件格式整理好數據格式 傳入組件 home.vue 4.接口返回數據格式...

    劍指Offer39-調整數組順序使奇數位于偶數前面

    一開始想著用冒泡排序的方法來做,但是bug還是很多,后來看了評論區答案,發現直接空間換時間是最簡單的,而且和快排的寫法是類似的。...

    【一只蒟蒻的刷題歷程】【藍橋杯】歷屆試題 九宮重排 (八數碼問題:BFS+集合set)

    資源限制 時間限制:1.0s 內存限制:256.0MB 問題描述 如下面第一個圖的九宮格中,放著 1~8 的數字卡片,還有一個格子空著。與空格子相鄰的格子中的卡片可以移動到空格中。經過若干次移動,可以形成第二個圖所示的局面。 我們把第一個圖的局面記為:12345678. 把第二個圖的局面記為:123.46758 顯然是按從上到下,從左到右的順序記錄數字,空格記為句點。 本題目的任務是已知九宮的初態...

    精品国产乱码久久久久久蜜桃不卡