MyBatis 源碼分析——SqlSession接口和Executor類

mybatis框架在操作數據的時候，離不開SqlSession接口實例類的作用。可以說SqlSession接口實例是開發過程中打交道最多的一個類。即是DefaultSqlSession類。如果筆者記得沒有錯的話，早期是沒有什么getMapper方法的。增刪改查各志有對應的方法進行操作。雖然現在改進了很多，但是也保留了很多。我們依舊可以看到類似於selectList這樣子的方法。源碼的例子里面就可以找到。如下

    SqlSession session = sqlMapper.openSession(TransactionIsolationLevel.SERIALIZABLE);
    try {
      List<Author> authors = session.selectList("org.apache.ibatis.domain.blog.mappers.AuthorMapper.selectAllAuthors");
      assertEquals(2, authors.size());
    } finally {
      session.close();

當然從某種意義上來講，寫起有一點煩。但是不可否認他的功能的確存在。這也是筆者為什么比較喜歡用動態代理來進行數據上的操作。至少可觀性上筆者認為比較好吧。

不管是哪一種數據上的操作都離不開SqlSession接口實例。所以深入查看qlSession接口實例就顯得相當的重要。筆者選擇了DefaultSqlSession類的selectList方法作為入口點進行切入。代碼如下。

 public <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds) {
    try {
      MappedStatement ms = configuration.getMappedStatement(statement);
      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();
    }
  }

源碼的意思是從configuration變理里面獲得，在通過Executor類的query方法獲得相應的結果。讓我們想想上一章中講過MappedStatement類是用於存放select節點或是update節點的信息。也就是說這里傳入statement參數表示將要去執行哪一個select節點。傳入的參數自然就是select節點id對應的值。那么Executor類又是什么。如果比較認真的人來查看源碼的話，你會發現基本上都會用到Executor類實例。在一次嘆氣——架構之美。

DefaultSqlSession類的成員executor是在構造函數里面給他賦值的。所以我們又要回頭去查看一下是在什么時候實例化了DefaultSqlSession類。筆者在第一章結尾的時候也講到過關於Executor類。從源碼中我們可以看到他是通過Configuration類的newExecutor方法來得到的。代碼如下

public Executor newExecutor(Transaction transaction, ExecutorType executorType) {
    executorType = executorType == null ? defaultExecutorType : executorType;
    executorType = executorType == null ? ExecutorType.SIMPLE : executorType;
    Executor executor;
    if (ExecutorType.BATCH == executorType) {
      executor = new BatchExecutor(this, transaction);
    } else if (ExecutorType.REUSE == executorType) {
      executor = new ReuseExecutor(this, transaction);
    } else {
      executor = new SimpleExecutor(this, transaction);
    }
    if (cacheEnabled) {
      executor = new CachingExecutor(executor);
    }
    executor = (Executor) interceptorChain.pluginAll(executor);
    return executor;
  }

完了。沒有想到Executor類還有分種類的。說實話筆者若是沒有去查看源碼真不會知道原來Executor類還有分種類的。看上面的源碼筆者剛開始認為有四種。但是發現最后一個跟上面的三個實例上有一點不同。為了更進一步確認筆者不得不去查看一下官網上面的API。筆者把內容復制過來。如下。

ExecutorType.SIMPLE: 這個執行器類型不做特殊的事情。它為每個語句的執行創建一個新的預處理語句。
ExecutorType.REUSE: 這個執行器類型會復用預處理語句。
ExecutorType.BATCH: 這個執行器會批量執行所有更新語句,如果 SELECT 在它們中間執行還會標定它們是 必須的,來保證一個簡單並易於理解的行為。

看樣子官網解釋的很清楚了。筆者就不在這里多言了。那么默認情況下mybatis框架又是調用哪一個Executor子類呢？其實這一點是可以在源碼上找到的。如下

Configuration類：

protected ExecutorType defaultExecutorType = ExecutorType.SIMPLE;

相信大家都明白了如果都沒有指定相應的Executor類的類型的話，mybatis框架會去調用SimpleExecutor類。

對於Executor類我先了解到這里。因為后面大量要用到他，同時也只有結合后面的功能才明白Executor類的作用。從上面DefaultSqlSession類的selectList方法中我們可以發現最后會去調用Executor類的query方法。

return executor.query(ms, wrapCollection(parameter), rowBounds, Executor.NO_RESULT_HANDLER);

對於變量ms筆者就不多說了。wrapCollection方法卻是值得注意的。他意思是先判斷變理parameter是否是Collection類型，如果是，就是新建一個StrictMap類型並以“collection”為key進行存放。又查一下是不是List類型。如果是，就以“list”為key進行存放。接下就是判斷是不是數組類型，如果是，就是新建一個StrictMap類型並以“array”為key進行存放。最后返回回StrictMap類實例。當然如果上面都不是的話，就直接返回parameter了。如果不清楚為什么設計者要這樣子做不要緊，筆者這個時候也不知道為什么。所以筆者只要記得他做了什么。RowBounds類型變理rowBounds一般用於分頁。默認是0到2147483647值，相信這個夠你用了吧。ResultHandler是用於處理返回的結果，這里直接就不要處理返回的結果了。所以筆者就不用講了。

BaseExecutor類：

  public <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler) throws SQLException {
    BoundSql boundSql = ms.getBoundSql(parameter);
    CacheKey key = createCacheKey(ms, parameter, rowBounds, boundSql);
    return query(ms, parameter, rowBounds, resultHandler, key, boundSql);
 }

類似於SimpleExecutor這樣子類並不是直接的繼承了Executor類。而是通過BaseExecutor類這一層之后到繼承Executor類。所以query方法調用的時候並不是調用SimpleExecutor類的。而是調用BaseExecutor類的。當然你從SimpleExecutor類也找不到query方法。顯然是經過BaseExecutor類進行處理相關的信息之后，在去調用Executor子類的doQuery方法。所以我們可以找到SimpleExecutor類的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());
      return handler.<E>query(stmt, resultHandler) ; 
    } finally {
      closeStatement(stmt);
    }
  }

 從源碼上來看筆者只認識倆個類一個是Configuration類和Statement類。Statement類是屬於JDBC的知識點。Configuration類是屬於mybatis框架的配置信息部分。意思就是通過MappedStatement獲得Configuration類的信息。在通過Configuration類新建StatementHandler接口實例。而StatementHandler接口實例就是用來處理生成Statement類的。很明顯就是執行SQL語句就是在StatementHandler接口實例里面。

筆者來一個小結：動態代理的方式事實上最后還是動用SqlSession接口實例的方法。所以只有了解了SqlSession接口實例的方法就是可以進一步深入。而SqlSession接口實例執行方法的過程中又會去執行Executor類的方法。而關於Configuration類的作用可以說是任務時候都有可以初動用。當前最后的任務暫時是交給了Executor類的子類。

好了。到了這里面，關於SqlSession接口和Executor類的作用就有一個大概的像想空間。當然只望一下就明白SqlSession接口和Executor類的話，筆者覺得有一點難。至少筆者沒有這樣子的能力。在筆者看來SqlSession接口和Executor類的工作在doQuery方法的時候，就已經圓完的結束了。雖然筆者並沒有說出SqlSession接口和Executor類的作用。主要還是靠你們自己去理解了。接下就來就是了解一下StatementHandler接口的作用。