mybatis-sql執行流程源碼分析

来源:https://www.cnblogs.com/zmy-520131499/archive/2019/08/23/11397720.html
-Advertisement-
Play Games

1. SqlSessionFactory 與 SqlSession. 通過前面的章節對於mybatis 的介紹及使用，大家都能體會到SqlSession的重要性了吧， 沒錯，從錶面上來看，咱們都是通過SqlSession去執行sql語句（註意：是從錶面看，實際的待會兒就會講）。那麼咱們就先看看是怎麼 ...


 

1. SqlSessionFactory 與 SqlSession.

　　通過前面的章節對於mybatis 的介紹及使用，大家都能體會到SqlSession的重要性了吧， 沒錯，從錶面上來看，咱們都是通過SqlSession去執行sql語句（註意：是從錶面看，實際的待會兒就會講）。那麼咱們就先看看是怎麼獲取SqlSession的吧：

（1）首先，SqlSessionFactoryBuilder去讀取mybatis的配置文件，然後build一個DefaultSqlSessionFactory。源碼如下：

 

/**
   * 一系列的構造方法最終都會調用本方法（配置文件為Reader時會調用本方法，還有一個InputStream方法與此對應）
   * @param reader
   * @param environment
   * @param properties
   * @return
   */
  public SqlSessionFactory build(Reader reader, String environment, Properties properties) {
    try {
      //通過XMLConfigBuilder解析配置文件，解析的配置相關信息都會封裝為一個Configuration對象
      XMLConfigBuilder parser = new XMLConfigBuilder(reader, environment, properties);
      //這兒創建DefaultSessionFactory對象
      return build(parser.parse());
    } catch (Exception e) {
      throw ExceptionFactory.wrapException("Error building SqlSession.", e);
    } finally {
      ErrorContext.instance().reset();
      try {
        reader.close();
      } catch (IOException e) {
        // Intentionally ignore. Prefer previous error.
      }
    }
  }

  public SqlSessionFactory build(Configuration config) {
    return new DefaultSqlSessionFactory(config);
  }

 

 

（2）當我們獲取到SqlSessionFactory之後，就可以通過SqlSessionFactory去獲取SqlSession對象。源碼如下：

 

/**
   * 通常一系列openSession方法最終都會調用本方法
   * @param execType 
   * @param level
   * @param autoCommit
   * @return
   */
  private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {
    Transaction tx = null;
    try {
      //通過Confuguration對象去獲取Mybatis相關配置信息, Environment對象包含了數據源和事務的配置
      final Environment environment = configuration.getEnvironment();
      final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);
      tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);
      //之前說了，從錶面上來看，咱們是用sqlSession在執行sql語句， 實際呢，其實是通過excutor執行， excutor是對於Statement的封裝
      final Executor executor = configuration.newExecutor(tx, execType);
      //關鍵看這兒，創建了一個DefaultSqlSession對象
      return new DefaultSqlSession(configuration, executor, autoCommit);
    } catch (Exception e) {
      closeTransaction(tx); // may have fetched a connection so lets call close()
      throw ExceptionFactory.wrapException("Error opening session.  Cause: " + e, e);
    } finally {
      ErrorContext.instance().reset();
    }
  }

 

 

通過以上步驟，咱們已經得到SqlSession對象了。接下來就是該幹嘛幹嘛去了（話說還能幹嘛，當然是執行sql語句咯）。看了上面，咱們也回想一下之前寫的Demo, 

 

SqlSessionFactory sessionFactory = null;  
String resource = "mybatis-conf.xml";  
try {
     //SqlSessionFactoryBuilder讀取配置文件
    sessionFactory = new SqlSessionFactoryBuilder().build(Resources  
              .getResourceAsReader(resource));
} catch (IOException e) {  
    e.printStackTrace();  
}    
//通過SqlSessionFactory獲取SqlSession
SqlSession sqlSession = sessionFactory.openSession();

 

還真這麼一回事兒，對吧！ 

SqlSession咱們也拿到了，咱們可以調用SqlSession中一系列的select...,  insert..., update..., delete...方法輕鬆自如的進行CRUD操作了。 就這樣？ 那咱配置的映射文件去哪兒了？  別急， 咱們接著往下看：

 

2. 利器之MapperProxy:

 

在mybatis中，通過MapperProxy動態代理咱們的dao， 也就是說， 當咱們執行自己寫的dao裡面的方法的時候，其實是對應的mapperProxy在代理。那麼，咱們就看看怎麼獲取MapperProxy對象吧：

（1）通過SqlSession從Configuration中獲取。源碼如下：

 

/**
   * 什麼都不做，直接去configuration中找， 哥就是這麼任性
   */
  @Override
  public <T> T getMapper(Class<T> type) {
    return configuration.<T>getMapper(type, this);
  }

 

 

（2）SqlSession把包袱甩給了Configuration, 接下來就看看Configuration。源碼如下：

 

/**
   * 燙手的山芋，俺不要，你找mapperRegistry去要
   * @param type
   * @param sqlSession
   * @return
   */
  public <T> T getMapper(Class<T> type, SqlSession sqlSession) {
    return mapperRegistry.getMapper(type, sqlSession);
  }

 

 

（3）Configuration不要這燙手的山芋，接著甩給了MapperRegistry， 那咱看看MapperRegistry。 源碼如下：

 

/**
   * 爛活凈讓我來做了，沒法了，下麵沒人了，我不做誰來做
   * @param type
   * @param sqlSession
   * @return
   */
  @SuppressWarnings("unchecked")
  public <T> T getMapper(Class<T> type, SqlSession sqlSession) {
    //能偷懶的就偷懶，俺把粗活交給MapperProxyFactory去做
    final MapperProxyFactory<T> mapperProxyFactory = (MapperProxyFactory<T>) knownMappers.get(type);
    if (mapperProxyFactory == null) {
      throw new BindingException("Type " + type + " is not known to the MapperRegistry.");
    }
    try {
      //關鍵在這兒
      return mapperProxyFactory.newInstance(sqlSession);
    } catch (Exception e) {
      throw new BindingException("Error getting mapper instance. Cause: " + e, e);
    }
  }

 

 

(4)MapperProxyFactory是個苦B的人，粗活最終交給它去做了。咱們看看源碼：

 

/**
   * 別人虐我千百遍，我待別人如初戀
   * @param mapperProxy
   * @return
   */
  @SuppressWarnings("unchecked")
  protected T newInstance(MapperProxy<T> mapperProxy) {
    //動態代理我們寫的dao介面
    return (T) Proxy.newProxyInstance(mapperInterface.getClassLoader(), new Class[] { mapperInterface }, mapperProxy);
  }
  
  public T newInstance(SqlSession sqlSession) {
    final MapperProxy<T> mapperProxy = new MapperProxy<T>(sqlSession, mapperInterface, methodCache);
    return newInstance(mapperProxy);
  }

 

 

通過以上的動態代理，咱們就可以方便地使用dao介面啦， 就像之前咱們寫的demo那樣：

UserDao userMapper = sqlSession.getMapper(UserDao.class);  
 User insertUser = new User();

 

這下方便多了吧， 呵呵， 貌似mybatis的源碼就這麼一回事兒啊。

別急，還沒完， 咱們還沒看具體是怎麼執行sql語句的呢。

 

3. Excutor:

接下來，咱們才要真正去看sql的執行過程了。

上面，咱們拿到了MapperProxy, 每個MapperProxy對應一個dao介面， 那麼咱們在使用的時候，MapperProxy是怎麼做的呢？ 源碼奉上：

MapperProxy:

/**
   * MapperProxy在執行時會觸發此方法
   */
  @Override
  public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
    if (Object.class.equals(method.getDeclaringClass())) {
      try {
        return method.invoke(this, args);
      } catch (Throwable t) {
        throw ExceptionUtil.unwrapThrowable(t);
      }
    }
    final MapperMethod mapperMethod = cachedMapperMethod(method);
    //二話不說，主要交給MapperMethod自己去管
    return mapperMethod.execute(sqlSession, args);
  }

 

 

MapperMethod:

 

/**
   * 看著代碼不少，不過其實就是先判斷CRUD類型，然後根據類型去選擇到底執行sqlSession中的哪個方法，繞了一圈，又轉回sqlSession了
   * @param sqlSession
   * @param args
   * @return
   */
  public Object execute(SqlSession sqlSession, Object[] args) {
    Object result;
    if (SqlCommandType.INSERT == command.getType()) {
      Object param = method.convertArgsToSqlCommandParam(args);
      result = rowCountResult(sqlSession.insert(command.getName(), param));
    } else if (SqlCommandType.UPDATE == command.getType()) {
      Object param = method.convertArgsToSqlCommandParam(args);
      result = rowCountResult(sqlSession.update(command.getName(), param));
    } else if (SqlCommandType.DELETE == command.getType()) {
      Object param = method.convertArgsToSqlCommandParam(args);
      result = rowCountResult(sqlSession.delete(command.getName(), param));
    } else if (SqlCommandType.SELECT == command.getType()) {
      if (method.returnsVoid() && method.hasResultHandler()) {
        executeWithResultHandler(sqlSession, args);
        result = null;
      } else if (method.returnsMany()) {
        result = executeForMany(sqlSession, args);
      } else if (method.returnsMap()) {
        result = executeForMap(sqlSession, args);
      } else {
        Object param = method.convertArgsToSqlCommandParam(args);
        result = sqlSession.selectOne(command.getName(), param);
      }
    } else {
      throw new BindingException("Unknown execution method for: " + command.getName());
    }
    if (result == null && method.getReturnType().isPrimitive() && !method.returnsVoid()) {
      throw new BindingException("Mapper method '" + command.getName() 
          + " attempted to return null from a method with a primitive return type (" + method.getReturnType() + ").");
    }
    return result;
  }

 

 

既然又回到SqlSession了， 那麼咱們就看看SqlSession的CRUD方法了，為了省事，還是就選擇其中的一個方法來做分析吧。這兒，咱們選擇了selectList方法：

 

public <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds) {
    try {
      MappedStatement ms = configuration.getMappedStatement(statement);
      //CRUD實際上是交給Excetor去處理， excutor其實也只是穿了個馬甲而已，小樣，別以為穿個馬甲我就不認識你嘞！
      return executor.query(ms, wrapCollection(parameter), rowBounds, Executor.NO_RESULT_HANDLER);
    } catch (Exception e) {
      throw ExceptionFactory.wrapException("Error querying database.  Cause: " + e, e);
    } finally {
      ErrorContext.instance().reset();
    }
  }
public <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds) {
    try {
      MappedStatement ms = configuration.getMappedStatement(statement);
      //CRUD實際上是交給Excetor去處理， excutor其實也只是穿了個馬甲而已，小樣，別以為穿個馬甲我就不認識你嘞！
      return executor.query(ms, wrapCollection(parameter), rowBounds, Executor.NO_RESULT_HANDLER);
    } catch (Exception e) {
      throw ExceptionFactory.wrapException("Error querying database.  Cause: " + e, e);
    } finally {
      ErrorContext.instance().reset();
    }
  }

 

 

然後，通過一層一層的調用，最終會來到doQuery方法， 這兒咱們就隨便找個Excutor看看doQuery方法的實現吧，我這兒選擇了SimpleExecutor:

 

public <E> List<E> doQuery(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) throws SQLException {
    Statement stmt = null;
    try {
      Configuration configuration = ms.getConfiguration();
      StatementHandler handler = configuration.newStatementHandler(wrapper, ms, parameter, rowBounds, resultHandler, boundSql);
      stmt = prepareStatement(handler, ms.getStatementLog());
      //StatementHandler封裝了Statement, 讓 StatementHandler 去處理
      return handler.<E>query(stmt, resultHandler);
    } finally {
      closeStatement(stmt);
    }
  }

 

 

接下來，咱們看看StatementHandler 的一個實現類 PreparedStatementHandler（這也是我們最常用的，封裝的是PreparedStatement）, 看看它使怎麼去處理的：

 

public <E> List<E> query(Statement statement, ResultHandler resultHandler) throws SQLException {
     //到此，原形畢露， PreparedStatement, 這個大家都已經滾瓜爛熟了吧
    PreparedStatement ps = (PreparedStatement) statement;
    ps.execute();
    //結果交給了ResultSetHandler 去處理
    return resultSetHandler.<E> handleResultSets(ps);
  }

 


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

-Advertisement-
Play Games
更多相關文章
  • DOM之事件（二）
    今天詳細講解JavaScript中的常用事件類型和功能。 一 滑鼠事件 1， click：點擊事件 等同於mousedown+mouseup，不管這兩個事件間隔多久，都會觸發一次click事件。 2， mousedown：滑鼠按下事件 3， mouseup：滑鼠彈起事件 4， mouseover/m ...
  • H5中滾動到底部的事件
    問題：在H5中，我們有這樣的需求：例如有列表的時候，滾動到底部時，需要載入更多。 解決方案：可以採用window的滾動事件進行處理 分析：如果滾動是針對整個屏幕而言的（不針對於某個界面小塊），那麼這個應該是是成立的：屏幕的高度+最大滾動的距離 = 內容的高度 代碼實現： 代碼的相關說明：很多時候，列 ...
  • 關於防抖與節流的思考
    百度防抖與節流，一直沒搞懂防抖與節流的區別，然後google了一下，（google大法好 _(:з」∠)_）個人理解了一下 1，比較正式的解釋他們的區別： 防抖：就是指觸發事件後在 n 秒內函數只能執行一次，如果在 n 秒內又觸發了事件，則會重新計算函數執行時間，防抖註重結果 節流：:是讓一個函數無 ...
  • React教程：4 個 useState Hook 示例
    摘要： React示例教程。 原文： "快速瞭解 React Hooks 原理" 譯者：前端小智 到 React 16.8 目前為止，如果編寫函數組件，然後遇到需要添加狀態的情況，咱們就必須將組件轉換為類組件。 編寫 ，將函數體複製到 方法中，修複縮進，最後添加需要的狀態。 今天，可以使用 Hook ...
  • Javascript中的原型對象
    原型prototype 我們所創建的每一個函數，解析器都會向函數中添加一個屬性prototype 這個屬性對應著一個對象，這個對象就是我們所謂的原型對象 如果函數作為普通函數，調用prototype沒有任何作用 當函數作為普通函數調用時，它所創建的對象中都會有一個隱含的屬性， 指向該構造函數的原型對 ...
  • 設計模式-建造者模式詳解
    一、建造者模式的概念 建造者模式屬於創建型設計模式。 指的是將一個複雜的構建與其表示相分離，使得同樣的構建過程可以創建不同的表示。 建造者模式主要解決在軟體系統中，有時候面臨著"一個複雜對象"的創建工作，其通常由各個部分的子對象用一定的演算法構成；由於需求的變化，這個複雜對象的各個部分經常面臨著劇烈的 ...
  • 對象的生命周期
    在解釋“對象的生命周期”前，先來看下麵這個例子： 有一個停車場共50個停車位，假如這個停車場是通過人工來管理停車位的使用情況，管理員有一個計數器，用來計錄當前空閑的停車位有多少個，每當有新的停車位被使用了計數器就減1，而有新的停車位空閑了計數器就加1。 我們可以把這些停車位理解為【資源空間】，可支配 ...
  • 從拖拉控制項編程到面向設計編程(一)
    前言 一> 本書目的。 這是一本思想層面的書，主要是向讀者展示，專業程式員是如何面向對象編程的？設計師是如何面向設計編 程的？逐步引導讀者從控制項編程到對象編程再到業務設計。 二>內容結構。 同事跟我說過一句話，所謂門坎，跨過了就是門，跨不過就是坎。在介紹本書內容之前，先帶領大家瞭解一下從拖拉控制項編程 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類