持久層Mybatis3底層源碼分析，原理解析

来源:https://www.cnblogs.com/dream-sun/archive/2019/03/26/10603931.html
-Advertisement-
Play Games

Mybatis-持久層的框架，功能是非常強大的，對於移動互聯網的高併發 和 高性能是非常有利的，相對於Hibernate全自動的ORM框架，Mybatis簡單，易於學習，sql編寫在xml文件中，和代碼分離，易於維護，屬於半ORM框架，對於面向用戶層面的互聯網業務性能和併發，可以通過sql優化解決一 ...


Mybatis-持久層的框架，功能是非常強大的，對於移動互聯網的高併發 和 高性能是非常有利的，相對於Hibernate全自動的ORM框架，Mybatis簡單，易於學習，sql編寫在xml文件中，和代碼分離，易於維護，屬於半ORM框架，對於面向用戶層面的互聯網業務性能和併發，可以通過sql優化解決一些問題。

現如今大部分公司都在使用Mybatis，所以我們要理解框架底層的原理。閑話不多說。

Mybatis框架的核心入口 是SqlSessionFactory介面，我們先看一下它的代碼

public interface SqlSessionFactory {

  SqlSession openSession();

  SqlSession openSession(boolean autoCommit);
  SqlSession openSession(Connection connection);
  SqlSession openSession(TransactionIsolationLevel level);

  SqlSession openSession(ExecutorType execType);
  SqlSession openSession(ExecutorType execType, boolean autoCommit);
  SqlSession openSession(ExecutorType execType, TransactionIsolationLevel level);
  SqlSession openSession(ExecutorType execType, Connection connection);

  Configuration getConfiguration();

}
SqlSessionFactory

SqlSessionFactory介面很多重載的openSession方法，返回sqlSession類型 對象， 還有Configuration類（這個類非常強大，下麵會梳理），我們先看一下SqlSession的代碼

public interface SqlSession extends Closeable {

 
  <T> T selectOne(String statement);


  <T> T selectOne(String statement, Object parameter);

  <E> List<E> selectList(String statement);

  <E> List<E> selectList(String statement, Object parameter);

  <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds);

  <K, V> Map<K, V> selectMap(String statement, String mapKey);
  <K, V> Map<K, V> selectMap(String statement, Object parameter, String mapKey);

  <K, V> Map<K, V> selectMap(String statement, Object parameter, String mapKey, RowBounds rowBounds);

  <T> Cursor<T> selectCursor(String statement);
  <T> Cursor<T> selectCursor(String statement, Object parameter);

  <T> Cursor<T> selectCursor(String statement, Object parameter, RowBounds rowBounds);


  void select(String statement, Object parameter, ResultHandler handler);


  void select(String statement, ResultHandler handler);


  List<BatchResult> flushStatements();

  /**
   * Closes the session
   */
  @Override
  void close();

  void clearCache();


  Configuration getConfiguration();


  <T> T getMapper(Class<T> type);

  Connection getConnection();
}
sqlSeesion

只是展示了部分代碼，但我們可以看到，sqlSeesion裡面 大多數方法是 增刪改查的執行方法，包括查詢返回不同的數據結構，比較註意的是clearCache()和getConnection()方法，一個是清楚緩存，一個是獲取連接，獲取資料庫連接在這不在描述， 為什麼要註意清楚緩存那，因為mybatis框架是實現了 緩存的，分為一級緩存，二級緩存，當增刪改的時候就會調用此方法，刪除緩存（後續會專門寫一篇文章來分析Mybatis緩存），先在這給大家熟悉一下。

上面的SqlSessionFactory和SqlSeesion都是介面，我們在看一下實現類DefaultSqlSessionFactory和DefaultSqlSession,下麵展示DefaultSqlSessionFactory的比較核心的代碼

 1   private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {
 2     Transaction tx = null;
 3     try {
 4       final Environment environment = configuration.getEnvironment();
 5       final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);
 6       tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);
 7       final Executor executor = configuration.newExecutor(tx, execType);
 8       return new DefaultSqlSession(configuration, executor, autoCommit);
 9     } catch (Exception e) {
10       closeTransaction(tx); // may have fetched a connection so lets call close()
11       throw ExceptionFactory.wrapException("Error opening session.  Cause: " + e, e);
12     } finally {
13       ErrorContext.instance().reset();
14     }
15   }
DefaultSqlSessionFactory

其實SqlSessionFactory中的多個重載openSeesion方法最終都是執行的這個方法，我們可以看到這個方法中 通過 configuration屬性 獲取到Executor 執行器對象，DefaultSqlSession構造器把這configuration和executor當成構造參數，初始化創建一個 DefaultSqlSession對象，然後我們在展示一下DefaultSqlSession代碼中的大家一看就理解的代碼

 1   public <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds) {
 2     try {
 3       MappedStatement ms = configuration.getMappedStatement(statement);
 4       return executor.query(ms, wrapCollection(parameter), rowBounds, Executor.NO_RESULT_HANDLER);
 5     } catch (Exception e) {
 6       throw ExceptionFactory.wrapException("Error querying database.  Cause: " + e, e);
 7     } finally {
 8       ErrorContext.instance().reset();
 9     }
10   }
DefaultSession

看到這個方法大家估計就會看明白了，底層執行的就是 通過Executor 對象執行的 查詢， 通過configuration獲取到 要執行的sql,獲取到我們需要的結果。

從上面代碼可以看出 Configuration 類無處不在，那我們就去看一下源碼

 1 public class Configuration {
 2 
 3   protected Environment environment;
 4 
 5   protected boolean safeRowBoundsEnabled;
 6   protected boolean safeResultHandlerEnabled = true;
 7   protected boolean mapUnderscoreToCamelCase;
 8   protected boolean aggressiveLazyLoading;
 9   protected boolean multipleResultSetsEnabled = true;
10   protected boolean useGeneratedKeys;
11   protected boolean useColumnLabel = true;
12   protected boolean cacheEnabled = true;
13   protected boolean callSettersOnNulls;
14   protected boolean useActualParamName = true;
15   protected boolean returnInstanceForEmptyRow;
16 
17   protected String logPrefix;
18   protected Class <? extends Log> logImpl;
19   protected Class <? extends VFS> vfsImpl;
20   protected LocalCacheScope localCacheScope = LocalCacheScope.SESSION;
21   protected JdbcType jdbcTypeForNull = JdbcType.OTHER;
22   protected Set<String> lazyLoadTriggerMethods = new HashSet<String>(Arrays.asList(new String[] { "equals", "clone", "hashCode", "toString" }));
23   protected Integer defaultStatementTimeout;
24   protected Integer defaultFetchSize;
25   protected ExecutorType defaultExecutorType = ExecutorType.SIMPLE;
26   protected AutoMappingBehavior autoMappingBehavior = AutoMappingBehavior.PARTIAL;
27   protected AutoMappingUnknownColumnBehavior autoMappingUnknownColumnBehavior = AutoMappingUnknownColumnBehavior.NONE;
28 
29   protected Properties variables = new Properties();
30   protected ReflectorFactory reflectorFactory = new DefaultReflectorFactory();
31   protected ObjectFactory objectFactory = new DefaultObjectFactory();
32   protected ObjectWrapperFactory objectWrapperFactory = new DefaultObjectWrapperFactory();
33 
34   protected boolean lazyLoadingEnabled = false;
35   protected ProxyFactory proxyFactory = new JavassistProxyFactory(); // #224 Using internal Javassist instead of OGNL
36 
37   protected String databaseId;
38   /**
39    * Configuration factory class.
40    * Used to create Configuration for loading deserialized unread properties.
41    *
42    * @see <a href='https://code.google.com/p/mybatis/issues/detail?id=300'>Issue 300 (google code)</a>
43    */
44   protected Class<?> configurationFactory;
45 
46   protected final MapperRegistry mapperRegistry = new MapperRegistry(this);
47   protected final InterceptorChain interceptorChain = new InterceptorChain();
48   protected final TypeHandlerRegistry typeHandlerRegistry = new TypeHandlerRegistry();
49   protected final TypeAliasRegistry typeAliasRegistry = new TypeAliasRegistry();
50   protected final LanguageDriverRegistry languageRegistry = new LanguageDriverRegistry();
51 
52   protected final Map<String, MappedStatement> mappedStatements = new StrictMap<MappedStatement>("Mapped Statements collection");
53   protected final Map<String, Cache> caches = new StrictMap<Cache>("Caches collection");
54   protected final Map<String, ResultMap> resultMaps = new StrictMap<ResultMap>("Result Maps collection");
55   protected final Map<String, ParameterMap> parameterMaps = new StrictMap<ParameterMap>("Parameter Maps collection");
56   protected final Map<String, KeyGenerator> keyGenerators = new StrictMap<KeyGenerator>("Key Generators collection");
57 
58   protected final Set<String> loadedResources = new HashSet<String>();
59   protected final Map<String, XNode> sqlFragments = new StrictMap<XNode>("XML fragments parsed from previous mappers");
60 
61   protected final Collection<XMLStatementBuilder> incompleteStatements = new LinkedList<XMLStatementBuilder>();
62   protected final Collection<CacheRefResolver> incompleteCacheRefs = new LinkedList<CacheRefResolver>();
63   protected final Collection<ResultMapResolver> incompleteResultMaps = new LinkedList<ResultMapResolver>();
64   protected final Collection<MethodResolver> incompleteMethods = new LinkedList<MethodResolver>();
65 
66   /*
67    * A map holds cache-ref relationship. The key is the namespace that
68    * references a cache bound to another namespace and the value is the
69    * namespace which the actual cache is bound to.
70    */
71   protected final Map<String, String> cacheRefMap = new HashMap<String, String>();}
Configuration

上面的代碼都是 Configuration類中的屬性值，上面的boolean 類型的屬性 都是一些配置的屬性，比如useGeneratedKeys是否開啟使用返回主鍵，cacheEnabled是否開啟緩存等等，下麵的Map類型的 就是存儲一些我們項目中需要編寫的sql.xml文件，我們可以通過變數名大致推測出來存儲的結果，比如typeAliasRegistry 存儲的別名，mappedStatements 存儲的sql，resultMaps存儲的結果等，當然這些map的key對應的就是 sql.xml中的唯一的id，分析到現在，我們大致知道Mybatis框架底層的執行原理了。

但是，這時候就有個疑問了，入口類是SqlSessionFactory，那是怎麼載入資源的那，我們通過名稱尋找源碼，可以找到一個SqlSessionFactoryBuilder（這些開發開源框架的牛人們不管技術NB，對類的命名也是很值的大家效仿的），builder--載入， 說明這個類就是載入 SqlSessionFactory,我們看一下代碼

 1 public class SqlSessionFactoryBuilder {
 2 
 3   public SqlSessionFactory build(Reader reader) {
 4     return build(reader, null, null);
 5   }
 6 
 7   public SqlSessionFactory build(Reader reader, String environment) {
 8     return build(reader, environment, null);
 9   }
10 
11   public SqlSessionFactory build(Reader reader, Properties properties) {
12     return build(reader, null, properties);
13   }
14 
15   public SqlSessionFactory build(Reader reader, String environment, Properties properties) {
16     try {
17       XMLConfigBuilder parser = new XMLConfigBuilder(reader, environment, properties);
18       return build(parser.parse());
19     } catch (Exception e) {
20       throw ExceptionFactory.wrapException("Error building SqlSession.", e);
21     } finally {
22       ErrorContext.instance().reset();
23       try {
24         reader.close();
25       } catch (IOException e) {
26         // Intentionally ignore. Prefer previous error.
27       }
28     }
29   }
30 
31   public SqlSessionFactory build(InputStream inputStream) {
32     return build(inputStream, null, null);
33   }
34 
35   public SqlSessionFactory build(InputStream inputStream, String environment) {
36     return build(inputStream, environment, null);
37   }
38 
39   public SqlSessionFactory build(InputStream inputStream, Properties properties) {
40     return build(inputStream, null, properties);
41   }
42 
43   public SqlSessionFactory build(InputStream inputStream, String environment, Properties properties) {
44     try {
45       XMLConfigBuilder parser = new XMLConfigBuilder(inputStream, environment, properties);
46       return build(parser.parse());
47     } catch (Exception e) {
48       throw ExceptionFactory.wrapException("Error building SqlSession.", e);
49     } finally {
50       ErrorContext.instance().reset();
51       try {
52         inputStream.close();
53       } catch (IOException e) {
54         // Intentionally ignore. Prefer previous error.
55       }
56     }
57   }
58     
59   public SqlSessionFactory build(Configuration config) {
60     return new DefaultSqlSessionFactory(config);
61   }
62 
63 }
SqlSessionFactoryBuilder

查看代碼中的build方法，可以看出是 通過流來載入xml文件 ，包括mybatis的配置文件和 sql.xml文件，返回一個DefaultSqlSessionFactory 對象。

本篇文件只是介紹了mybatis的底層執行原理，喜歡深入瞭解的可以自己去深入瞭解一下。

以上是個人理解，歡迎大家來討論，不喜勿噴！謝謝！！

如轉載，請註明轉載地址，謝謝

 


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

-Advertisement-
Play Games
更多相關文章
  • springboot之旅第一篇-springboot初探
    一、springboot是什麼？ 微服務，應該是近年來最火的概念，越來越多的公司開始使用微服務架構，面試中被問到的微服務的概率很高，不管對技術的追求，還是為了進更好的公司，微服務都是我們開發人員的必須要學習的知識。 那麼微服務究竟是什麼呢？ 我們通俗的理解方式就是：微服務化的核心就是將傳統的一站式應 ...
  • 從0開始學golang--1.1--連接ms sql server資料庫
    package main import ( "database/sql" "fmt" "strings" ) import ( _ "github.com/mattn/go-adodb" ) type Mssql struct { *sql.DB dataSource string database ...
  • Python中append()與extend()的區別
    列表方法append()和extend()之間的差異: append：在最後追加對象 結果 [1, 2, 3, [4, 5]] extend：通過追加加迭代中的元素來擴展列表。 結果 [1, 2, 3, 4, 5] 作者：阿裡媽媽 鏈接：www.pythonheidong.com/blog/arti ...
  • Maven環境的搭建
    1.本地倉庫和apache-mavenbin.zip的下載與解壓 <1.apache-mavenbin.zip下載網址 2.Maven環境變數配置 <1.MAVEN_HOME <2.PATH 3.環境搭建驗證 4自定義數據倉庫的位置（apache-maven.setting.xml）的配置 ...
  • Spring中的IOC_源碼_隨筆
    Spring ioc 叫控制反轉，也就是把創建Bean的動作交給Spring去完成。 spring ioc 流程大致為 定位-> 載入->註冊 先說幾個比較有意思的點 1.Spring中的通過IOC生成的Bean是存放在ConcurrentHashMap中的 2.通過xml配置SpringBean時 ...
  • python 通過元類控制類的創建
    一、python中如何創建類？ 1. 直接定義類 2. 通過type對象創建 在python中一切都是對象 在上面這張圖中，A是我們平常在python中寫的類，它可以創建一個對象a。其實A這個類也是一個對象，它是type類的對象，可以說type類是用來創建類對象的類，我們平常寫的類都是type類創建 ...
  • BZOJ5118: Fib數列2(二次剩餘)
    題意 "題目鏈接" 題目鏈接 一種做法是直接用歐拉降冪算出$2^p \pmod{p 1}$然後矩陣快速冪。 但是今天學習了一下二次剩餘，也可以用通項公式+二次剩餘做。 就是我們猜想$5$在這個模數下有二次剩餘，拉個板子發現真的有。 然求出來直接做就行了 cpp include define Pair ...
  • HashMap源碼詳解與對比
    前幾天工作忙得焦頭爛額時，同事問了一下關於Map的特性，剎那間懵了一下，緊接著就想起來了一些關於Map的一些知識，因為只要涉及到Collection集合類時，就會談及Map類，因此理解好Map相關的知識是灰常重要的。 Collection集合類 與 Map類的層次結構，如下圖： Map是用來存儲 K ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類