深刻淺出MyBatis:MyBatis解析和運行原理

本篇文章是「深刻淺出MyBatis:技術原理與實踐」書籍的總結筆記。java

上一篇介紹了反射和動態代理基礎,主要是爲本篇文章作個鋪墊,反射使配置和靈活性大大提升,能夠給不少配置設置參數,動態代理能夠在運行時建立代理對象,作一些特殊的處理。sql

文章索引:
數據庫

  1. JDBC和MyBatis介紹
  2. MyBatis的全部配置
  3. 「映射器」全瞭解
  4. 反射和動態代理基礎
  5. MyBatis插件和開發過程

本篇會介紹MyBatis解析和運行原理,下一篇介紹插件及應用,目的是更好地編寫插件,經過本篇的介紹,你會了解到:緩存

  • 構建SqlSessionFactory過程
  • 映射器的動態代理
  • SqlSession的4大對象
  • sql執行的過程

SqlSessionFactory和SqlSession是MyBatis的核心組件,在文章 JDBC和MyBatis介紹 中有詳細說明。微信

構建SqlSessionFactory過程

構建主要分爲2步:app

  • 經過XMLConfigBuilder解析配置的XML文件,讀出配置參數,包括基礎配置XML文件和映射器XML文件;
  • 使用Configuration對象建立SqlSessionFactory,SqlSessionFactory是一個接口,提供了一個默認的實現類DefaultSqlSessionFactory。

說白了,就是將咱們的全部配置解析爲Configuration對象,在整個生命週期內,能夠經過該對象獲取須要的配置。ide

因爲插件須要頻繁訪問映射器的內部組成,會重點這部分,瞭解這塊配置抽象出來的對象:post

MappedStatement

它保存映射器的一個節點(select|insert|delete|update),包括配置的SQL,SQL的id、緩存信息、resultMap、parameterType、resultType等重要配置內容。ui

它涉及的對象比較多,通常不去修改它。this

SqlSource

它是MappedStatement的一個屬性,主要做用是根據參數和其餘規則組裝SQL,也是很複雜的,通常也不用修改它。

BoundSql

對於參數和SQL,主要反映在BoundSql類對象上,在插件中,經過它獲取到當前運行的SQL和參數以及參數規則,做出適當的修改,知足特殊的要求。

BoundSql提供3個主要的屬性:parameterObject、parameterMappings和sql,下面分別來介紹。

parameterObject爲參數自己,能夠傳遞簡單對象、POJO、Map或@Param註解的參數:

  • 傳遞簡單對象(int、float、String等),會把參數轉換爲對應的類,好比int會轉換爲Integer;
  • 若是傳遞的是POJO或Map,paramterObject就是傳入的POJO或Map不變;
  • 若是傳遞多個參數,沒有@Param註解,parameterObject就是一個Map<String,Object>對象,相似這樣的形式{"1":p1 , "2":p2 , "3":p3 ... "param1":p1 , "param2":p2 , "param3",p3 ...},因此在編寫的時候可使用#{param1}或#{1}去引用第一個參數;
  • 若是傳遞多個參數,有@Param註解,與沒有註解的相似,只是將序號的key替換爲@Param指定的name;

parameterMappings,它是一個List,元素是ParameterMapping對象,這個對象會描繪sql中的參數引用,包括名稱、表達式、javaType、jdbcType、typeHandler等信息。

sql,是寫在映射器裏面的一條sql。

有了Configuration對象,構建SqlSessionFactory就簡單了:

sqlSessionFactory = new SqlSessionFactoryBuilder().bulid(inputStream);
複製代碼

SqlSession運行過程

映射器的動態代理

Mapper映射是經過動態代理來實現的,使用JDK動態代理返回一個代理對象,供調用者訪問。

首先看看實現InvocationHandler接口的類,它是執行本代理方法的關鍵,能夠看到,Mapper是一個接口,會生成MapperMethod對象,調用execute方法。

public class MapperProxy<T> implements InvocationHandler, Serializable {
  
  .....
  
  @Override
  public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
    try {
      if (Object.class.equals(method.getDeclaringClass())) {
        return method.invoke(this, args);
      } else if (isDefaultMethod(method)) {
        return invokeDefaultMethod(proxy, method, args);
      }
    } catch (Throwable t) {
      throw ExceptionUtil.unwrapThrowable(t);
    }
    final MapperMethod mapperMethod = cachedMapperMethod(method);
    return mapperMethod.execute(sqlSession, args);
  }
}
複製代碼

看下面的代碼,MapperMethod採用命令模式,根據不一樣的sql操做,作不一樣的處理。

public class MapperMethod {
  public Object execute(SqlSession sqlSession, Object[] args) {
    Object result;
    switch (command.getType()) {
      case INSERT: {
      Object param = method.convertArgsToSqlCommandParam(args);
        result = rowCountResult(sqlSession.insert(command.getName(), param));
        break;
      }
      case UPDATE: {
        Object param = method.convertArgsToSqlCommandParam(args);
        result = rowCountResult(sqlSession.update(command.getName(), param));
        break;
        
        ......
        
      }
    }
  }
複製代碼

最後看下,生成代理類的方法,就是使用JDK動態代理Proxy來建立的。

public class MapperProxyFactory<T> {

  public T newInstance(SqlSession sqlSession) {
    final MapperProxy<T> mapperProxy = new MapperProxy<T>(sqlSession, mapperInterface, methodCache);
    return newInstance(mapperProxy);
  }

  @SuppressWarnings("unchecked")
  protected T newInstance(MapperProxy<T> mapperProxy) {
    return (T) Proxy.newProxyInstance(mapperInterface.getClassLoader(), new Class[] { mapperInterface }, mapperProxy);
  }

}

複製代碼

總結下映射器的調用過程,返回的Mapper對象是代理對象,當調用它的某個方法時,實際上是調用MapperProxy#invoke方法,而映射器的XML文件的命名空間對應的就是這個接口的全路徑,會根據全路徑和方法名,便可以綁定起來,定位到sql,最後會使用SqlSession接口的方法使它可以執行查詢。

SqlSession下的四大對象

經過上面的分析,映射器就是一個動態代理對象,進入到了MapperMethod的execute方法,它通過簡單的判斷就進入了SqlSession的刪除、更新、插入、選擇等方法,這些方法如何執行是下面要介紹的內容。

Mapper執行的過程是經過Executor、StatementHandler、ParameterHandler和ResultHandler來完成數據庫操做和結果返回的,理解他們是編寫插件的關鍵:

  • Executor:執行器,由它統一調度其餘三個對象來執行對應的SQL;
  • StatementHandler:使用數據庫的Statement執行操做;
  • ParameterHandler:用於SQL對參數的處理;
  • ResultHandler:進行最後數據集的封裝返回處理;

在MyBatis中存在三種執行器:

  • SIMPLE:簡易執行器,默認的執行器;
  • REUSE:執行重用預處理語句;
  • BATCH:執行重用語句和批量更新,針對批量專用的執行器;

以SimpleExecutor爲例,說明執行過程

public class SimpleExecutor extends BaseExecutor {

  /** * 執行查詢操做 */
  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(this, ms, parameter, rowBounds, resultHandler, boundSql);
      stmt = prepareStatement(handler, ms.getStatementLog());
      return handler.<E>query(stmt, resultHandler);
    } finally {
      closeStatement(stmt);
    }
  }
  
  /** * 初始化StatementHandler */
  private Statement prepareStatement(StatementHandler handler, Log statementLog) throws SQLException {
    Statement stmt;
    Connection connection = getConnection(statementLog);
    stmt = handler.prepare(connection);
    handler.parameterize(stmt);
    return stmt;
  }
  
  /** * 執行查詢 */
  @Override
  public <E> List<E> query(Statement statement, ResultHandler resultHandler) throws SQLException {
    String sql = boundSql.getSql();
    statement.execute(sql);
    return resultSetHandler.<E>handleResultSets(statement);
  }
}
複製代碼

能夠看到最後會委託給StatementHandler會話器進行處理,它是一個接口,實際建立的是RoutingStatementHandler對象,但它不是真實的服務對象,它是經過適配器模式找到對應的StatementHandler執行的。在MyBatis中,StatementHandler和Executor同樣分爲三種:SimpleStatementHandler、PreparedStatementHandler、CallableStatementHandler。

Executor會先調用StatementHandler的prepare方法預編譯SQL語句,同時設置一些基本運行的參數。而後調用parameterize()方法啓用ParameterHandler設置參數,完成預編譯,跟着執行查詢,用ResultHandler封裝結果返回給調用者。

參數處理器和結果處理器比較簡單,就不在此介紹了。

下一篇會介紹插件及其應用,主要是在sql執行的過程當中,在四大對象的基礎上進行擴展。

MyBatis插件和開發過程

歡迎掃描下方二維碼,關注個人我的微信公衆號 ~

情情說
相關文章
相關標籤/搜索