0
  • 聊天消息
  • 系統(tǒng)消息
  • 評論與回復(fù)
登錄后你可以
  • 下載海量資料
  • 學(xué)習(xí)在線課程
  • 觀看技術(shù)視頻
  • 寫文章/發(fā)帖/加入社區(qū)
會員中心
創(chuàng)作中心

完善資料讓更多小伙伴認(rèn)識你,還能領(lǐng)取20積分哦,立即完善>

3天內(nèi)不再提示

一文了解MyBatis的查詢原理

OSC開源社區(qū) ? 來源:京東技術(shù) ? 作者:李春廷 ? 2022-10-10 11:42 ? 次閱讀

導(dǎo)讀

本文通過MyBatis一個(gè)低版本的bug(3.4.5之前的版本)入手,分析MyBatis的一次完整的查詢流程,從配置文件的解析到一個(gè)查詢的完整執(zhí)行過程詳細(xì)解讀MyBatis的一次查詢流程,通過本文可以詳細(xì)了解MyBatis的一次查詢過程。在平時(shí)的代碼編寫中,發(fā)現(xiàn)了MyBatis一個(gè)低版本的bug(3.4.5之前的版本),由于現(xiàn)在很多工程中的版本都是低于3.4.5的,因此在這里用一個(gè)簡單的例子復(fù)現(xiàn)問題,并且從源碼角度分析MyBatis一次查詢的流程,讓大家了解MyBatis的查詢原理。

01 問題現(xiàn)象

在今年的敏捷團(tuán)隊(duì)建設(shè)中,我通過Suite執(zhí)行器實(shí)現(xiàn)了一鍵自動化單元測試。Juint除了Suite執(zhí)行器還有哪些執(zhí)行器呢?由此我的Runner探索之旅開始了!

1.1 場景問題復(fù)現(xiàn)

如下圖所示,在示例Mapper中,下面提供了一個(gè)方法queryStudents,從student表中查詢出符合查詢條件的數(shù)據(jù),入?yún)⒖梢詾閟tudent_name或者student_name的集合,示例中參數(shù)只傳入的是studentName的List集合

 List studentNames = new LinkedList<>();
 studentNames.add("lct");
 studentNames.add("lct2");
 condition.setStudentNames(studentNames);

期望運(yùn)行的結(jié)果是
select * from student WHERE student_name IN ( 'lct' , 'lct2' )
但是實(shí)際上運(yùn)行的結(jié)果是

==> Preparing: select * from student WHERE student_name IN ( ? , ? ) AND student_name = ?

==> Parameters: lct(String), lct2(String), lct2(String)

<== Columns: id, student_name, age

<== Row: 2, lct2, 2

<== Total: 1

通過運(yùn)行結(jié)果可以看到,沒有給student_name單獨(dú)賦值,但是經(jīng)過MyBatis解析以后,單獨(dú)給student_name賦值了一個(gè)值,可以推斷出MyBatis在解析SQL并對變量賦值的時(shí)候是有問題的,初步猜測是foreach循環(huán)中的變量的值帶到了foreach外邊,導(dǎo)致SQL解析出現(xiàn)異常,下面通過源碼進(jìn)行分析驗(yàn)證

02 MyBatis查詢原理

理解,首先 MCube 會依據(jù)模板緩存狀態(tài)判斷是否需要網(wǎng)絡(luò)獲取最新模板,當(dāng)獲取到模板后進(jìn)行模板加載,加載階段會將產(chǎn)物轉(zhuǎn)換為視圖樹的結(jié)構(gòu),轉(zhuǎn)換完成后將通過表達(dá)式引擎解析表達(dá)式并取得正確的值,通過事件解析引擎解析用戶自定義事件并完成事件的綁定,完成解析賦值以及事件綁定后進(jìn)行視圖的渲染,最終將目標(biāo)頁面展示到屏幕。

2.1 MyBatis架構(gòu)

2.1.1 架構(gòu)圖

先簡單來看看MyBatis整體上的架構(gòu)模型,從整體上看MyBatis主要分為四大模塊:

接口:主要作用就是和數(shù)據(jù)庫打交道

數(shù)據(jù)處理層:數(shù)據(jù)處理層可以說是MyBatis的核心,它要完成兩個(gè)功能:

通過傳入參數(shù)構(gòu)建動態(tài)SQL語句;

SQL語句的執(zhí)行以及封裝查詢結(jié)果集成List

框架支撐層:主要有事務(wù)管理、連接池管理、緩存機(jī)制和SQL語句的配置方式

引導(dǎo)層:引導(dǎo)層是配置和啟動MyBatis 配置信息的方式。MyBatis 提供兩種方式來引導(dǎo)MyBatis :基于XML配置文件的方式和基于Java API 的方式

2.1.2 MyBatis四大對象

貫穿MyBatis整個(gè)框架的有四大核心對象,ParameterHandler、ResultSetHandler、StatementHandler和Executor,四大對象貫穿了整個(gè)框架的執(zhí)行過程,四大對象的主要作用為:

ParameterHandler:設(shè)置預(yù)編譯參數(shù)

ResultSetHandler:處理SQL的返回結(jié)果集

StatementHandler:處理sql語句預(yù)編譯,設(shè)置參數(shù)等相關(guān)工作

Executor:MyBatis的執(zhí)行器,用于執(zhí)行增刪改查操作

2.2從源碼解讀MyBatis的一次查詢過程

首先給出復(fù)現(xiàn)問題的代碼以及相應(yīng)的準(zhǔn)備過程

2.2.1 數(shù)據(jù)準(zhǔn)備

CREATE TABLE `student`  (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `student_name` varchar(255) NULL DEFAULT NULL,
  `age` int(11) NULL DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1;


-- ----------------------------
-- Records of student
-- ----------------------------
INSERT INTO `student` VALUES (1, 'lct', 1);
INSERT INTO `student` VALUES (2, 'lct2', 2);

2.2.2 代碼準(zhǔn)備

1.mapper配置文件

2.示例代碼

public static void main(String[] args) throws IOException {
        String resource = "mybatis-config.xml";
        InputStream inputStream = Resources.getResourceAsStream(resource);
        //1.獲取SqlSessionFactory對象
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        //2.獲取對象
        SqlSession sqlSession = sqlSessionFactory.openSession();
        //3.獲取接口的代理類對象
        StudentDao mapper = sqlSession.getMapper(StudentDao.class);
        StudentCondition condition = new StudentCondition();
        List studentNames = new LinkedList<>();
        studentNames.add("lct");
        studentNames.add("lct2");
        condition.setStudentNames(studentNames);
        //執(zhí)行方法
        List students = mapper.queryStudents(condition);
    }

2.2.3 查詢過程分析

1.SqlSessionFactory的構(gòu)建

先看SqlSessionFactory的對象的創(chuàng)建過程

//1.獲取SqlSessionFactory對象
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);

代碼中首先通過調(diào)用SqlSessionFactoryBuilder中的build方法來獲取對象,進(jìn)入build方法

 public SqlSessionFactory build(InputStream inputStream) {
    return build(inputStream, null, null);
  }

調(diào)用自身的build方法

bb27fc9c-484c-11ed-a3b6-dac502259ad0.png

圖1 build方法自身調(diào)用調(diào)試圖例

在這個(gè)方法里會創(chuàng)建一個(gè)XMLConfigBuilder的對象,用來解析傳入的MyBatis的配置文件,然后調(diào)用parse方法進(jìn)行解析

bb586698-484c-11ed-a3b6-dac502259ad0.png

圖2 parse解析入?yún)⒄{(diào)試圖例

在這個(gè)方法中,會從MyBatis的配置文件的根目錄中獲取xml的內(nèi)容,其中parser這個(gè)對象是一個(gè)XPathParser的對象,這個(gè)是專門用來解析xml文件的,具體怎么從xml文件中獲取到各個(gè)節(jié)點(diǎn)這里不再進(jìn)行講解。這里可以看到解析配置文件是從configuration這個(gè)節(jié)點(diǎn)開始的,在MyBatis的配置文件中這個(gè)節(jié)點(diǎn)也是根節(jié)點(diǎn)

 




    
           
    
然后將解析好的xml文件傳入parseConfiguration方法中,在這個(gè)方法中會獲取在配置文件中的各個(gè)節(jié)點(diǎn)的配置

bb98ffe6-484c-11ed-a3b6-dac502259ad0.png

圖3 解析配置調(diào)試圖例

以獲取mappers節(jié)點(diǎn)的配置來看具體的解析過程

進(jìn)入mapperElement方法

mapperElement(root.evalNode("mappers"));

bbb688ae-484c-11ed-a3b6-dac502259ad0.png

圖4 mapperElement方法調(diào)試圖例

看到MyBatis還是通過創(chuàng)建一個(gè)XMLMapperBuilder對象來對mappers節(jié)點(diǎn)進(jìn)行解析,在parse方法中

public void parse() {
  if (!configuration.isResourceLoaded(resource)) {
    configurationElement(parser.evalNode("/mapper"));
    configuration.addLoadedResource(resource);
    bindMapperForNamespace();
  }


  parsePendingResultMaps();
  parsePendingCacheRefs();
  parsePendingStatements();
}

通過調(diào)用configurationElement方法來解析配置的每一個(gè)mapper文件

private void configurationElement(XNode context) {
  try {
    String namespace = context.getStringAttribute("namespace");
    if (namespace == null || namespace.equals("")) {
      throw new BuilderException("Mapper's namespace cannot be empty");
    }
    builderAssistant.setCurrentNamespace(namespace);
    cacheRefElement(context.evalNode("cache-ref"));
    cacheElement(context.evalNode("cache"));
    parameterMapElement(context.evalNodes("/mapper/parameterMap"));
    resultMapElements(context.evalNodes("/mapper/resultMap"));
    sqlElement(context.evalNodes("/mapper/sql"));
    buildStatementFromContext(context.evalNodes("select|insert|update|delete"));
  } catch (Exception e) {
    throw new BuilderException("Error parsing Mapper XML. Cause: " + e, e);
  }
}

以解析mapper中的增刪改查的標(biāo)簽來看看是如何解析一個(gè)mapper文件的

進(jìn)入buildStatementFromContext方法

private void buildStatementFromContext(List list, String requiredDatabaseId) {
  for (XNode context : list) {
    final XMLStatementBuilder statementParser = new XMLStatementBuilder(configuration, builderAssistant, context, requiredDatabaseId);
    try {
      statementParser.parseStatementNode();
    } catch (IncompleteElementException e) {
      configuration.addIncompleteStatement(statementParser);
    }
  }
}

可以看到MyBatis還是通過創(chuàng)建一個(gè)XMLStatementBuilder對象來對增刪改查節(jié)點(diǎn)進(jìn)行解析,通過調(diào)用這個(gè)對象的parseStatementNode方法,在這個(gè)方法里會獲取到配置在這個(gè)標(biāo)簽下的所有配置信息,然后進(jìn)行設(shè)置

bbf41318-484c-11ed-a3b6-dac502259ad0.png

圖5 parseStatementNode方法調(diào)試圖例

解析完成以后,通過方法addMappedStatement將所有的配置都添加到一個(gè)MappedStatement中去,然后再將mappedstatement添加到configuration中去

builderAssistant.addMappedStatement(id, sqlSource, statementType, sqlCommandType,
    fetchSize, timeout, parameterMap, parameterTypeClass, resultMap, resultTypeClass,
    resultSetTypeEnum, flushCache, useCache, resultOrdered, 
    keyGenerator, keyProperty, keyColumn, databaseId, langDriver, resultSets);

bc14bf64-484c-11ed-a3b6-dac502259ad0.png

圖6 增加解析完成的mapper方法調(diào)試圖例

可以看到一個(gè)mappedstatement中包含了一個(gè)增刪改查標(biāo)簽的詳細(xì)信息

bc7ef898-484c-11ed-a3b6-dac502259ad0.png

圖7 mappedstatement對象方法調(diào)試圖例

而一個(gè)configuration就包含了所有的配置信息,其中mapperRegistertry和mappedStatements

bcbddaea-484c-11ed-a3b6-dac502259ad0.png

圖8 config對象方法調(diào)試圖例

具體的流程

bcebfc40-484c-11ed-a3b6-dac502259ad0.png

圖9 SqlSessionFactory對象的構(gòu)建過程

2.SqlSession的創(chuàng)建過程

SqlSessionFactory創(chuàng)建完成以后,接下來看看SqlSession的創(chuàng)建過程

SqlSession sqlSession = sqlSessionFactory.openSession();

首先會調(diào)用DefaultSqlSessionFactory的openSessionFromDataSource方法

@Override
public SqlSession openSession() {
  return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false);
}

在這個(gè)方法中,首先會從configuration中獲取DataSource等屬性組成對象Environment,利用Environment內(nèi)的屬性構(gòu)建一個(gè)事務(wù)對象TransactionFactory

private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {
  Transaction tx = null;
  try {
    final Environment environment = configuration.getEnvironment();
    final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);
    tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);
    final Executor executor = configuration.newExecutor(tx, execType);
    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();
  }
}

事務(wù)創(chuàng)建完成以后開始創(chuàng)建Executor對象,Executor對象的創(chuàng)建是根據(jù) executorType創(chuàng)建的,默認(rèn)是SIMPLE類型的,沒有配置的情況下創(chuàng)建了SimpleExecutor,如果開啟二級緩存的話,則會創(chuàng)建CachingExecutor

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;
}

創(chuàng)建executor以后,會執(zhí)行executor = (Executor) interceptorChain.pluginAll(executor)方法,這個(gè)方法對應(yīng)的含義是使用每一個(gè)攔截器包裝并返回executor,最后調(diào)用DefaultSqlSession方法創(chuàng)建SqlSession

bd01a34c-484c-11ed-a3b6-dac502259ad0.png

圖10 SqlSession對象的創(chuàng)建過程

3.Mapper的獲取過程

有了SqlSessionFactory和SqlSession以后,就需要獲取對應(yīng)的Mapper,并執(zhí)行mapper中的方法

StudentDao mapper = sqlSession.getMapper(StudentDao.class);

在第一步中知道所有的mapper都放在MapperRegistry這個(gè)對象中,因此通過調(diào)用org.apache.ibatis.binding.MapperRegistry#getMapper方法來獲取對應(yīng)的mapper

public  T getMapper(Class type, SqlSession sqlSession) {
  final MapperProxyFactory mapperProxyFactory = (MapperProxyFactory) 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);
  }
}

在MyBatis中,所有的mapper對應(yīng)的都是一個(gè)代理類,獲取到mapper對應(yīng)的代理類以后執(zhí)行newInstance方法,獲取到對應(yīng)的實(shí)例,這樣就可以通過這個(gè)實(shí)例進(jìn)行方法的調(diào)用

public class MapperProxyFactory {


  private final Class mapperInterface;
  private final Map methodCache = new ConcurrentHashMap();


  public MapperProxyFactory(Class mapperInterface) {
    this.mapperInterface = mapperInterface;
  }


  public Class getMapperInterface() {
    return mapperInterface;
  }


  public Map getMethodCache() {
    return methodCache;
  }


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


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


}

獲取mapper的流程為

bd1adefc-484c-11ed-a3b6-dac502259ad0.png

圖11 Mapper的獲取過程

4.查詢過程

獲取到mapper以后,就可以調(diào)用具體的方法

//執(zhí)行方法
List students = mapper.queryStudents(condition);

首先會調(diào)用org.apache.ibatis.binding.MapperProxy#invoke的方法,在這個(gè)方法中,會調(diào)用org.apache.ibatis.binding.MapperMethod#execute

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;
    }
    case DELETE: {
      Object param = method.convertArgsToSqlCommandParam(args);
      result = rowCountResult(sqlSession.delete(command.getName(), param));
      break;
    }
    case SELECT:
      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 if (method.returnsCursor()) {
        result = executeForCursor(sqlSession, args);
      } else {
        Object param = method.convertArgsToSqlCommandParam(args);
        result = sqlSession.selectOne(command.getName(), param);
      }
      break;
    case FLUSH:
      result = sqlSession.flushStatements();
      break;
    default:
      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;
}

首先根據(jù)SQL的類型增刪改查決定執(zhí)行哪個(gè)方法,在此執(zhí)行的是SELECT方法,在SELECT中根據(jù)方法的返回值類型決定執(zhí)行哪個(gè)方法,可以看到在select中沒有selectone單獨(dú)方法,都是通過selectList方法,通過調(diào)用org.apache.ibatis.session.defaults.DefaultSqlSession#selectList(java.lang.String, java.lang.Object)方法來獲取到數(shù)據(jù)

@Override
public  List 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();
  }
}

在selectList中,首先從configuration對象中獲取MappedStatement,在statement中包含了Mapper的相關(guān)信息,然后調(diào)用org.apache.ibatis.executor.CachingExecutor#query()方法

bd79d010-484c-11ed-a3b6-dac502259ad0.png

圖12 query()方法調(diào)試圖示

在這個(gè)方法中,首先對SQL進(jìn)行解析根據(jù)入?yún)⒑驮糞QL,對SQL進(jìn)行拼接

bdc8acf8-484c-11ed-a3b6-dac502259ad0.png

圖13 SQL拼接過程代碼圖示

調(diào)用MapperedStatement里的getBoundSql最終解析出來的SQL為

bde17670-484c-11ed-a3b6-dac502259ad0.png

圖14 SQL拼接過程結(jié)果圖示

接下來調(diào)用org.apache.ibatis.parsing.GenericTokenParser#parse對解析出來的SQL進(jìn)行解析

be180d5c-484c-11ed-a3b6-dac502259ad0.png

圖15 SQL解析過程圖示

最終解析的結(jié)果為

be404ad8-484c-11ed-a3b6-dac502259ad0.png

圖16 SQL解析結(jié)果圖示

最后會調(diào)用SimpleExecutor中的doQuery方法,在這個(gè)方法中,會獲取StatementHandler,然后調(diào)用org.apache.ibatis.executor.statement.PreparedStatementHandler#parameterize這個(gè)方法進(jìn)行參數(shù)和SQL的處理,最后調(diào)用statement的execute方法獲取到結(jié)果集,然后 利用resultHandler對結(jié)進(jìn)行處理

bef01c9c-484c-11ed-a3b6-dac502259ad0.png

圖17 SQL處理結(jié)果圖示

查詢的主要流程為

bf1a73a2-484c-11ed-a3b6-dac502259ad0.png

bf2f3a6c-484c-11ed-a3b6-dac502259ad0.png

圖18 查詢流程處理圖示

5.查詢流程總結(jié)

總結(jié)整個(gè)查詢流程如下

bf749d46-484c-11ed-a3b6-dac502259ad0.png

圖19 查詢流程抽象

2.3場景問題原因及解決方案

2.3.1 個(gè)人排查

這個(gè)問bug出現(xiàn)的地方在于綁定SQL參數(shù)的時(shí)候再源碼中位置為

 @Override
 public  List 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);
}

由于所寫的SQL是一個(gè)動態(tài)綁定參數(shù)的SQL,因此最終會走到org.apache.ibatis.scripting.xmltags.DynamicSqlSource#getBoundSql這個(gè)方法中去

public BoundSql getBoundSql(Object parameterObject) {
  BoundSql boundSql = sqlSource.getBoundSql(parameterObject);
  List parameterMappings = boundSql.getParameterMappings();
  if (parameterMappings == null || parameterMappings.isEmpty()) {
    boundSql = new BoundSql(configuration, boundSql.getSql(), parameterMap.getParameterMappings(), parameterObject);
  }


  // check for nested result maps in parameter mappings (issue #30)
  for (ParameterMapping pm : boundSql.getParameterMappings()) {
    String rmId = pm.getResultMapId();
    if (rmId != null) {
      ResultMap rm = configuration.getResultMap(rmId);
      if (rm != null) {
        hasNestedResultMaps |= rm.hasNestedResultMaps();
      }
    }
  }


  return boundSql;
}

在這個(gè)方法中,會調(diào)用 rootSqlNode.apply(context)方法,由于這個(gè)標(biāo)簽是一個(gè)foreach標(biāo)簽,因此這個(gè)apply方法會調(diào)用到org.apache.ibatis.scripting.xmltags.ForEachSqlNode#apply這個(gè)方法中去

@Override
public boolean apply(DynamicContext context) {
  Map bindings = context.getBindings();
  final Iterable  iterable = evaluator.evaluateIterable(collectionExpression, bindings);
  if (!iterable.iterator().hasNext()) {
    return true;
  }
  boolean first = true;
  applyOpen(context);
  int i = 0;
  for (Object o : iterable) {
    DynamicContext oldContext = context;
    if (first) {
      context = new PrefixedContext(context, "");
    } else if (separator != null) {
      context = new PrefixedContext(context, separator);
    } else {
        context = new PrefixedContext(context, "");
    }
    int uniqueNumber = context.getUniqueNumber();
    // Issue #709 
    if (o instanceof Map.Entry) {
      @SuppressWarnings("unchecked") 
      Map.Entry mapEntry = (Map.Entry) o;
      applyIndex(context, mapEntry.getKey(), uniqueNumber);
      applyItem(context, mapEntry.getValue(), uniqueNumber);
    } else {
      applyIndex(context, i, uniqueNumber);
      applyItem(context, o, uniqueNumber);
    }
    contents.apply(new FilteredDynamicContext(configuration, context, index, item, uniqueNumber));
    if (first) {
      first = !((PrefixedContext) context).isPrefixApplied();
    }
    context = oldContext;
    i++;
  }
  applyClose(context);
  return true;
}

當(dāng)調(diào)用appItm方法的時(shí)候?qū)?shù)進(jìn)行綁定,參數(shù)的變量問題都會存在bindings這個(gè)參數(shù)中區(qū)

private void applyItem(DynamicContext context, Object o, int i) {
  if (item != null) {
    context.bind(item, o);
    context.bind(itemizeItem(item, i), o);
  }
}

進(jìn)行綁定參數(shù)的時(shí)候,綁定完成foreach的方法的時(shí)候,可以看到bindings中不止綁定了foreach中的兩個(gè)參數(shù)還額外有一個(gè)參數(shù)名字studentName->lct2,也就是說最后一個(gè)參數(shù)也是會出現(xiàn)在bindings這個(gè)參數(shù)中的,

private void applyItem(DynamicContext context, Object o, int i) {
  if (item != null) {
    context.bind(item, o);
    context.bind(itemizeItem(item, i), o);
  }
}

bf86da60-484c-11ed-a3b6-dac502259ad0.png

圖20 參數(shù)綁定過程

最后判定

org.apache.ibatis.scripting.xmltags.IfSqlNode#apply

@Override
public boolean apply(DynamicContext context) {
  if (evaluator.evaluateBoolean(test, context.getBindings())) {
    contents.apply(context);
    return true;
  }
  return false;
}

可以看到在調(diào)用evaluateBoolean方法的時(shí)候會把context.getBindings()就是前邊提到的bindings參數(shù)傳入進(jìn)去,因?yàn)楝F(xiàn)在這個(gè)參數(shù)中有一個(gè)studentName,因此在使用Ognl表達(dá)式的時(shí)候,判定為這個(gè)if標(biāo)簽是有值的因此將這個(gè)標(biāo)簽進(jìn)行了解析

bfb17dba-484c-11ed-a3b6-dac502259ad0.png

圖21 單個(gè)參數(shù)綁定過程

最終綁定的結(jié)果為

c015c9be-484c-11ed-a3b6-dac502259ad0.png

圖22 全部參數(shù)綁定過程

因此這個(gè)地方綁定參數(shù)的地方是有問題的,至此找出了問題的所在。

2.3.2 官方解釋

翻閱MyBatis官方文檔進(jìn)行求證,發(fā)現(xiàn)在3.4.5版本發(fā)行中bug fixes中有這樣一句

c05977d6-484c-11ed-a3b6-dac502259ad0.png

圖23 此問題官方修復(fù)github記錄

修復(fù)了foreach版本中對于全局變量context的修改的bug

issue地址為https://github.com/mybatis/mybatis-3/pull/966

修復(fù)方案為https://github.com/mybatis/mybatis-3/pull/966/commits/84513f915a9dcb97fc1d602e0c06e11a1eef4d6a

可以看到官方給出的修改方案,重新定義了一個(gè)對象,分別存儲全局變量和局部變量,這樣就會解決foreach會改變?nèi)肿兞康膯栴}。

c07f0e10-484c-11ed-a3b6-dac502259ad0.png

圖24 此問題官方修復(fù)代碼示例

2.3.3 修復(fù)方案

升級MyBatis版本至3.4.5以上

如果保持版本不變的話,在foreach中定義的變量名不要和外部的一致

03 源碼閱讀過程總結(jié)

理解,首先 MCube 會依據(jù)模板緩存狀態(tài)判斷是否需要網(wǎng)絡(luò)獲取最新模板,當(dāng)獲取到模板后進(jìn)行模板加載,加載階段會將產(chǎn)物轉(zhuǎn)換為視圖樹的結(jié)構(gòu),轉(zhuǎn)換完成后將通過表達(dá)式引擎解析表達(dá)式并取得正確的值,通過事件解析引擎解析用戶自定義事件并完成事件的綁定,完成解析賦值以及事件綁定后進(jìn)行視圖的渲染,最終將目標(biāo)頁面展示到屏幕。

MyBatis源代碼的目錄是比較清晰的,基本上每個(gè)相同功能的模塊都在一起,但是如果直接去閱讀源碼的話,可能還是有一定的難度,沒法理解它的運(yùn)行過程,本次通過一個(gè)簡單的查詢流程從頭到尾跟下來,可以看到MyBatis的設(shè)計(jì)以及處理流程,例如其中用到的設(shè)計(jì)模式:

c0bbc3fa-484c-11ed-a3b6-dac502259ad0.png

圖25 MyBatis代碼結(jié)構(gòu)圖

組合模式:如ChooseSqlNode,IfSqlNode等

模板方法模式:例如BaseExecutor和SimpleExecutor,還有BaseTypeHandler和所有的子類例如IntegerTypeHandler

Builder模式:例如 SqlSessionFactoryBuilder、XMLConfigBuilder、XMLMapperBuilder、XMLStatementBuilder、CacheBuilder

工廠模式:例如SqlSessionFactory、ObjectFactory、MapperProxyFactory

代理模式:MyBatis實(shí)現(xiàn)的核心,比如MapperProxy、ConnectionLogger

審核編輯:湯梓紅

聲明:本文內(nèi)容及配圖由入駐作者撰寫或者入駐合作網(wǎng)站授權(quán)轉(zhuǎn)載。文章觀點(diǎn)僅代表作者本人,不代表電子發(fā)燒友網(wǎng)立場。文章及其配圖僅供工程師學(xué)習(xí)之用,如有內(nèi)容侵權(quán)或者其他違規(guī)問題,請聯(lián)系本站處理。 舉報(bào)投訴
  • 源碼
    +關(guān)注

    關(guān)注

    8

    文章

    626

    瀏覽量

    28965
  • mybatis
    +關(guān)注

    關(guān)注

    0

    文章

    58

    瀏覽量

    6691
收藏 人收藏

    評論

    相關(guān)推薦

    Mybatis的內(nèi)部設(shè)計(jì)介紹

    Mybatis源碼分析-整體設(shè)計(jì)()
    發(fā)表于 06-06 09:43

    MyBatis的整合

    SpringBoot-15-之整合MyBatis-注解篇+分頁
    發(fā)表于 10-28 08:09

    Mybatis是什么

    Mybatis
    發(fā)表于 06-04 15:33

    Mybatis緩存之級緩存

    本文主要講mybatis級緩存,級緩存是SqlSession級別的緩存。mybatis提供查詢緩存,用于減輕數(shù)據(jù)壓力,提高數(shù)據(jù)庫性能。
    發(fā)表于 11-27 20:44 ?1172次閱讀
    <b class='flag-5'>Mybatis</b>緩存之<b class='flag-5'>一</b>級緩存

    mybatis對多配置

    本文詳細(xì)介紹了mybatis關(guān)聯(lián)配置(對多配置)。
    發(fā)表于 02-24 13:53 ?1439次閱讀

    在使用MyBatis中SQL語句優(yōu)化總結(jié)

    MyBatis 作為款優(yōu)秀的持久層框架,它支持自定義SQL、存儲過程以及高級映射。它免除了幾乎所有的 JDBC 代碼以及設(shè)置參數(shù)和獲取結(jié)果集的工作。還可以通過簡單的 XML 或注解來配置和映射原始
    的頭像 發(fā)表于 02-04 15:20 ?2683次閱讀

    MyBatis流式查詢輕松幫你解決分頁慢的問題

    作者丨捏造的信仰 segmentfault.com/a/1190000022478915 Part1基本概念 流式查詢指的是查詢成功后不是返回個(gè)集合而是返回個(gè)迭代器,應(yīng)用每次從迭代
    的頭像 發(fā)表于 08-04 15:52 ?4060次閱讀

    easy-mybatis Mybatis的增強(qiáng)框架

    ./oschina_soft/gitee-easy-mybatis.zip
    發(fā)表于 06-14 09:45 ?1次下載
    easy-<b class='flag-5'>mybatis</b> <b class='flag-5'>Mybatis</b>的增強(qiáng)框架

    Fluent Mybatis、原生MybatisMybatis Plus對比

    使用fluent mybatis可以不用寫具體的xml文件,通過java api可以構(gòu)造出比較復(fù)雜的業(yè)務(wù)sql語句,做到代碼邏輯和sql邏輯的合。不再需要在Dao中組裝查詢或更新操作,在xml或
    的頭像 發(fā)表于 09-15 15:41 ?1333次閱讀

    源碼學(xué)習(xí)之MyBatis的底層查詢原理

    可以詳細(xì)了解MyBatis查詢過程。在平時(shí)的代碼編寫中,發(fā)現(xiàn)了MyBatis個(gè)低版本的b
    的頭像 發(fā)表于 10-10 11:42 ?661次閱讀

    掌握MyBatis的動態(tài)SQL使用與原理

    摘要:使用動態(tài) SQL 并非件易事,但借助可用于任何 SQL 映射語句中的強(qiáng)大的動態(tài) SQL 語言,MyBatis 顯著地提升了這特性的易用性。
    的頭像 發(fā)表于 01-06 11:27 ?846次閱讀

    MyBatis-Plus為什么不支持聯(lián)表

    MyBatis Plus Join`款專門解決MyBatis Plus 關(guān)聯(lián)查詢問題的擴(kuò)展框架,他并不款全新的框架,而是基于`
    的頭像 發(fā)表于 02-28 15:19 ?2231次閱讀
    <b class='flag-5'>MyBatis</b>-Plus為什么不支持聯(lián)表

    SpringBoot+Mybatis如何實(shí)現(xiàn)流式查詢

    使用mybatis作為持久層的框架時(shí),通過mybatis執(zhí)行查詢數(shù)據(jù)的請求執(zhí)行成功后,mybatis返回的結(jié)果集不是個(gè)集合或?qū)ο?,而?/div>
    的頭像 發(fā)表于 06-12 09:57 ?1027次閱讀

    帶你了解 DAC

    了解 DAC
    的頭像 發(fā)表于 12-07 15:10 ?7958次閱讀
    <b class='flag-5'>一</b><b class='flag-5'>文</b>帶你<b class='flag-5'>了解</b> DAC

    mybatis框架的主要作用

    。MyBatis框架的主要作用包括以下幾個(gè)方面。 數(shù)據(jù)庫操作的簡化和標(biāo)準(zhǔn)化: MyBatis框架提供了種簡單的方式來執(zhí)行數(shù)據(jù)庫操作,包括插入、更新、刪除和查詢等操作。通過使用
    的頭像 發(fā)表于 12-03 14:49 ?1816次閱讀