Mybatis 源碼解讀-SqlSession 會話源碼和Executor SQL操作執行器源碼

作者源碼閱讀筆記主要采用金山云文檔記錄的，所有的交互圖和代碼閱讀筆記都是記錄在云文檔里面，本平臺的文檔編輯實在不方便，會導致我梳理的交互圖和文檔失去原來的格式，所以整理在文檔里面，供大家閱讀交流.

【金山文檔 | WPS云文檔】 SqlSession 會話源碼和Executor SQL操作執行器源碼

SqlSession 是框架與數據庫交互的核心接口。

核心功能

?SQL 操作執行

?提供 insert()、update()、delete()、select() 等方法直接執行 SQL 語句，支持參數綁定與結果映射?

?事務管理

?通過 commit() 和 rollback() 控制事務提交與回滾，需手動調用（非自動提交模式）?

?Mapper 接口代理

通過 getMapper(Class<T> type) 動態生成 Mapper 接口實現類，實現面向對象式數據庫操作?

?緩存管理

?默認啟用一級緩存（會話級），緩存相同 SQL 查詢結果，通過 clearCache() 可手動清空?。?

Executor 包是 MyBatis 執行 SQL 操作的核心引擎，位于 org.apache.ibatis.executor 包下，負責協調 SQL 執行全流程（包括緩存管理、事務控制、參數處理、結果映射等）

Executor 包是 MyBatis 的 ?SQL 執行中樞?，通過多態實現支持基礎操作、緩存優化、批量處理等場景，并協調四大組件完成從 SQL 解析到結果映射的全鏈路操作?

?核心接口與實現

`Executor` 接口

定義 SQL 執行的標準方法：

public interface Executor {int update(MappedStatement ms, Object parameter);         // 執行更新操作<E> List<E> query(...);                                  // 執行查詢操作void commit(boolean required);                           // 提交事務void rollback(boolean required);                         // 回滾事務CacheKey createCacheKey(...);                            // 創建緩存鍵boolean isCached(MappedStatement ms, CacheKey key);      // 檢查緩存
}

基礎實現類（`BaseExecutor` 子類）

類型	?特點?	?適用場景?
`SimpleExecutor`?	默認執行器，每次執行創建新 `Statement`，執行后立即關閉	常規單條 SQL 操作
`ReuseExecutor`?	復用 `Statement` 對象，緩存相同 SQL 的 `Statement` 以減少重復編譯開銷	高頻重復 SQL
`BatchExecutor`?	批量執行 SQL，通過 `addBatch()` 緩存操作，調用 `flushStatements()` 統一提交	批量插入/更新

增強實現類 `CachingExecutor`?

?二級緩存代理?：裝飾器模式，在基礎執行器外層添加二級緩存邏輯?
工作流程?：

優先查詢二級緩存（MappedStatement 級別）；
緩存未命中時委托底層執行器（如 SimpleExecutor）查詢數據庫

?協作組件

Executor 通過組合模式調用其他三大組件：

?組件?	?職責?	?依賴關系?
?`StatementHandler`?	處理 `Statement` 創建與參數綁定	Executor 調用其執行 SQL
`ParameterHandler`?	轉換參數類型并填充到 `PreparedStatement`	被 `StatementHandler` 調用
`ResultSetHandler`?	封裝結果集到 Java 對象	被 `StatementHandler` 調用

相關重要類介紹說明

SqlSessionManager 類

名稱	描述	默認值
sqlSessionFactory	?核心作用? 作為底層工廠實例，用于創建原生 `SqlSession` 對象（通過 `openSession()` 方法）? 代理模式下（調用 `startManagedSession()` 后），通過動態代理自動管理會話生命周期，此時 `sqlSessionFactory` 負責在后臺創建線程綁定的 `SqlSession`?
sqlSessionProxy	`sqlSessionProxy` 字段是一個關鍵動態代理對象核心功能 ?動態代理攔截? 作為 `SqlSession` 的代理實例，攔截所有 Mapper 方法調用，并路由到當前線程綁定的 `SqlSession` 或新建會話 ?通過 `InvocationHandler` 實現方法調用的統一處理（如事務提交、異常回滾）? ?線程安全會話管理 ?優先從 `ThreadLocal`（`localSqlSession`）獲取會話，避免重復創建，確保線程隔離? 若未綁定會話（未調用 `startManagedSession()`），則臨時創建并自動關閉會話（非托管模式）?
localSqlSession	`localSqlSession` 字段是一個關鍵線程安全控制組件核心作用線程隔離存儲通過 `ThreadLocal<SqlSession>` 實現線程綁定的會話管理，確保每個線程操作獨立的 `SqlSession` 實例避免多線程環境下會話沖突（如事務交叉）?? ?托管模式標志當調用 `startManagedSession()` 后，新創建的 `SqlSession` 會存入此字段，標記當前線程進入托管模式? ?未調用時字段值為 `null`，代理對象每次臨時創建新會話?

sqlSessionProxy代理對象創建：

this.sqlSessionProxy = (SqlSession) Proxy.newProxyInstance(SqlSessionFactory.class.getClassLoader(),new Class[] { SqlSession.class }, new SqlSessionInterceptor());

SqlSessionInterceptor 攔截器

每次調用代理對象 sqlSessionProxy 方法都會去執行invoke方法

private class SqlSessionInterceptor implements InvocationHandler {public SqlSessionInterceptor() {// Prevent Synthetic Access}@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throws Throwable {final SqlSession sqlSession = SqlSessionManager.this.localSqlSession.get();if (sqlSession != null) {try {return method.invoke(sqlSession, args);} catch (Throwable t) {throw ExceptionUtil.unwrapThrowable(t);}}try (SqlSession autoSqlSession = openSession()) {try {final Object result = method.invoke(autoSqlSession, args);autoSqlSession.commit();return result;} catch (Throwable t) {autoSqlSession.rollback();throw ExceptionUtil.unwrapThrowable(t);}}}}

SqlSessionFactory sqlSession 工廠類

負責創建和管理 SqlSession 實例?

名稱	描述	默認值
configuration	全局配置實例

DefaultSqlSession 默認會話類

名稱	描述	默認值
configuration	全局配置實例
executor	sql執行器
autoCommit	控制事務提交機制的核心參數	默認值為 `false`（需手動提交事務）?
dirty	用于標記當前會話是否存在未提交數據變更的關鍵狀態標識核心功能更新操作觸發：執行 `insert/update/delete` 操作時自動置為 `true`，表示有未提交的修改? ?事務提交后重置：調用 `commit()` 或 `rollback()` 后重置為 `false`，標識數據已同步? ?連接關閉兜底處理：若未提交事務時關閉會話（`close()`），自動觸發回滾并重置 `dirty`?
cursorList	用于管理流式查詢游標的關鍵資源集合

所有具體執行器父類 BaseExecutor抽象類

名稱	描述	默認值
transaction	管理數據庫事務的核心組件
wrapper	`BaseExecutor` 的 `wrapper` 字段是其自身實例的引用，核心作用在于?實現裝飾器模式?，為執行器提供動態擴展能力。若未配置裝飾器，`wrapper` 指向自身，直接執行 `BaseExecutor` 的邏輯；若配置裝飾器（如 `CachingExecutor`），則調用裝飾器的增強方法?
deferredLoads	`BaseExecutor` 的 ?`deferredLoads`? 字段是實現 MyBatis ?延遲加載（懶加載）? 機制的核心組件，用于管理需要延遲加載的關聯對象 `deferredLoads` 字段通過封裝延遲加載任務隊列，實現了 MyBatis 高效的懶加載機制，是優化復雜對象查詢性能的關鍵組件?
localCache	`BaseExecutor` 的 ?`localCache`? 字段是 MyBatis ?一級緩存（本地緩存）? 的核心實現。 `localCache` 是 MyBatis 一級緩存的核心載體，通過會話級緩存優化重復查詢性能。典型問題與使用建議 ?臟讀風險 ?對于不同的sqlsession A與B，A做update操作，只能刷新A自己的一級緩存，無法刷新B的一級緩存。所以如果A與B操作同一條記錄，就會有臟讀。 SqlSessionB第一查詢時進行了緩存，第二次查詢時從緩存獲取數據（臟數據），之后進行邏輯處理以及更新 ?
localOutputParameterCache	`BaseExecutor` 的 ?`localOutputParameterCache`? 字段是 MyBatis 用于?存儲過程輸出參數緩存?的核心組件
configuration	全局配置
queryStack	控制嵌套查詢與延遲加載?的關鍵計數器典型場景示例 ?嵌套查詢?：主查詢 `User` 觸發關聯對象 `Order` 的懶加載時，`queryStack` 會從 0→1→0 變化，確保關聯查詢僅在頂層觸發? ?循環依賴規避?：若 `User` 和 `Order` 互相引用，`queryStack` 機制會阻斷循環加載，避免棧溢出
closed	標識執行器（Executor）是否已被關閉?的關鍵狀態標記

基于SQL語句復用的執行器 ReuseExecutor 類

通過內部維護的 Map<String, Statement> 緩存（鍵為 SQL 語句，值為對應的 Statement 對象），避免相同 SQL 的重復編譯與創建開銷。適用于高頻執行?相同結構 SQL?（如循環中參數化查詢）的場景

名稱	描述	默認值
statementMap	`statementMap`? 字段是其實現 ?`Statement` 對象復用的核心緩存容器?，通過減少 JDBC 語句編譯與創建開銷提升高頻重復 SQL 的執行效率

批量操作執行器 ?BatchExecutor 類

BatchExecutor 是 MyBatis 中?專為批量數據庫操作優化的執行器實現?，通過延遲執行與批量提交機制顯著提升大批量數據操作的性能

名稱	描述	默認值
statementList	`statementList`? 字段是其實現批量操作的核心數據結構，用于緩存待執行的 `Statement` 對象以實現批量提交優化工作流程 ?緩存階段執行增刪改操作時，將相同 SQL 結構的 `Statement` 存入 `statementList`，并通過 `addBatch()` 添加參數? 若 SQL 結構變化（如切換表或操作類型），則創建新 `Statement` 并加入列表? ?批量提交調用 `flushStatements()` 或事務提交時，遍歷 `statementList` 執行批量操作? 提交后清空列表并關閉所有 `Statement`?
batchResultList	`batchResultList`? 字段是其實現批量操作結果跟蹤的核心數據結構，用于記錄每條批量操作的執行狀態和參數信息
currentSql	`currentSql`? 字段是其實現 SQL 批量優化的關鍵標識，用于動態跟蹤當前正在處理的 SQL 語句以實現批量操作的智能分組
currentStatement	`currentStatement`? 字段是用于跟蹤當前批量操作關聯的 `MappedStatement` 對象的核心標識，其設計旨在實現 SQL 執行的上下文一致性管理

二級緩存執行器 CachingExecutor 類

CachingExecutor是一個基于裝飾者模式實現的執行器類，主要用于增強二級緩存功能

名稱

描述

默認值

delegate

delegate 字段是其實現裝飾器模式的關鍵組件，用于承載實際的數據庫操作執行器

delegate 是 CachingExecutor 連接具體執行器的橋梁，使緩存功能可疊加于不同執行策略之上，體現了裝飾器模式在 MyBatis 中的靈活應用

tcm

tcm 字段是實現二級緩存事務性提交的核心組件，全稱為 TransactionalCacheManager

核心職責

?事務性緩存管理

?確保二級緩存的數據僅在事務成功提交后生效，避免臟讀問題。當執行寫操作（如 update）時，緩存變更不會立即同步到二級緩存，而是暫存在 TransactionalCache 中，直至事務提交?

?多命名空間協調

?管理多個映射語句（MappedStatement）對應的 TransactionalCache 實例，維護不同 Cache 對象的隔離性與一致性

這一設計解決了多 SqlSession 并發場景下二級緩存的數據一致性問題。?

TransactionalCacheManager 二級緩存事務管理器

MyBatis 的 TransactionalCacheManager 是二級緩存事務管理的核心組件，主要負責在事務提交時協調多個 TransactionalCache 的緩存同步操作

核心職責

?事務性緩存控制

?管理多個 TransactionalCache 實例，確保二級緩存的更新僅在事務提交后生效，避免事務未提交時其他會話讀取到臟數據?

?多緩存空間隔離

?通過 Map<String, TransactionalCache> 結構維護不同命名空間（namespace）的緩存實例，實現緩存區域的隔離與協同?

名稱	描述	默認值
transactionalCaches	維護底層真實緩存（如 `PerpetualCache`）與事務緩存代理（`TransactionalCache`）的映射關系，確保每個 `Cache` 對象都有獨立的事務暫存區?	Map<Cache, TransactionalCache>

TransactionalCache 二級事務緩存類

TransactionalCache 是二級緩存事務管理的核心代理類，負責在事務提交前攔截緩存操作，確保數據一致性

核心職責

?事務暫存區

?代理真實的 Cache 對象（如 PerpetualCache），在事務提交前將寫操作（putObject）暫存于內存，避免未提交事務污染二級緩存?

?臟數據隔離

通過 entriesToAddOnCommit（待提交數據）和 entriesMissedInCache（未命中記錄）兩個集合，隔離事務內外的緩存狀態

名稱	描述	默認值
delegate	`delegate` 字段是二級緩存實現的核心代理對象，其設計體現了裝飾器模式的應用 `delegate` 字段是 MyBatis 二級緩存事務機制與底層存儲的橋梁，其設計完美體現了?裝飾器模式?和?單一職責原則 ?核心職責 1、?真實緩存代理?：持有底層緩存實現（如 `PerpetualCache`），所有緩存操作最終委托給該對象執行? 2、?功能擴展基礎?：通過裝飾器模式（如 `LruCache`、`ScheduledCache`）對基礎緩存增強，而 `delegate` 是裝飾鏈的最終執行者???
clearOnCommit	用于控制事務提交時是否清空底層緩存	默認值為 `false`，可通過特定操作（如更新語句）動態修改狀態?
entriesToAddOnCommit	`entriesToAddOnCommit` 字段是二級緩存事務管理的核心數據結構，其設計實現了?事務隔離性?與?批量提交優化核心職責 ?事務暫存區?：臨時存儲事務內所有 `putObject` 操作的數據，直到事務提交時批量寫入底層緩存（`delegate`）? ?臟寫隔離?：避免未提交事務的中間狀態污染二級緩存，確保其他會話讀取的數據一致性?	Map<Object, Object> entriesToAddOnCommit
entriesMissedInCache	用于追蹤?二級緩存未命中記錄?的關鍵字段，其設計目的主要在于優化并發場景下的緩存一致性與阻塞控制；記錄事務執行過程中?緩存查詢未命中的鍵（Key）該字段是 MyBatis 二級緩存應對?高并發穿透問題?的核心設計組件之一。	Set<Object> entriesMissedInCache

?CacheKey 緩存key類

緩存key生成邏輯代碼：

@Overridepublic CacheKey createCacheKey(MappedStatement ms, Object parameterObject, RowBounds rowBounds, BoundSql boundSql) {if (closed) {throw new ExecutorException("Executor was closed.");}CacheKey cacheKey = new CacheKey();cacheKey.update(ms.getId());cacheKey.update(rowBounds.getOffset());cacheKey.update(rowBounds.getLimit());cacheKey.update(boundSql.getSql());List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();TypeHandlerRegistry typeHandlerRegistry = ms.getConfiguration().getTypeHandlerRegistry();// mimic DefaultParameterHandler logicMetaObject metaObject = null;for (ParameterMapping parameterMapping : parameterMappings) {if (parameterMapping.getMode() != ParameterMode.OUT) {Object value;String propertyName = parameterMapping.getProperty();if (parameterMapping.hasValue()) {value = parameterMapping.getValue();} else if (boundSql.hasAdditionalParameter(propertyName)) {value = boundSql.getAdditionalParameter(propertyName);} else if (parameterObject == null) {value = null;} else {ParamNameResolver paramNameResolver = ms.getParamNameResolver();if (paramNameResolver != null&& typeHandlerRegistry.hasTypeHandler(paramNameResolver.getType(paramNameResolver.getNames()[0]))|| typeHandlerRegistry.hasTypeHandler(parameterObject.getClass())) {value = parameterObject;} else {if (metaObject == null) {metaObject = configuration.newMetaObject(parameterObject);}value = metaObject.getValue(propertyName);}}cacheKey.update(value);}}if (configuration.getEnvironment() != null) {// issue #176cacheKey.update(configuration.getEnvironment().getId());}return cacheKey;}

影響key生成的因素：