温馨提示:本篇是源码分析Mybatis ShardingJdbc SQL语句执行的前置篇,重点阐述Mybatis执行SQL语句的4大核心组件。 源码分析Mybatis系列目录: 1、源码分析Mybatis MapperProxy初始化【图文并茂】 2、源码分析Mybatis MappedStatement的创建流程
sql执行器,其对应的类全路径:org.apache.ibatis.executor.Executor。
温馨提示:如果图片不清晰,可以浏览该网址:https://blog.csdn.net/prestigeding/article/details/90578125
在Mybatis中,Executor的创建由Configuration对象来创建,具体的代码如下:
1public Executor newExecutor(Transaction transaction) {
2 return newExecutor(transaction, defaultExecutorType); // @1
3}
4
5
6public Executor newExecutor(Transaction transaction, ExecutorType executorType) {
7 executorType = executorType == null ? defaultExecutorType : executorType;
8 executorType = executorType == null ? ExecutorType.SIMPLE : executorType;
9 Executor executor;
10 if (ExecutorType.BATCH == executorType) { // @2
11 executor = new BatchExecutor(this, transaction);
12 } else if (ExecutorType.REUSE == executorType) {
13 executor = new ReuseExecutor(this, transaction);
14 } else {
15 executor = new SimpleExecutor(this, transaction);
16 }
17 if (cacheEnabled) { // @3
18 executor = new CachingExecutor(executor);
19 }
20 executor = (Executor) interceptorChain.pluginAll(executor); // @4
21 return executor;
22}
从上面的代码可以看出,Executor的创建由如下三个关键点: 代码@1:默认的ExecutorType为ExecutorType.SIMPLE,即默认创建的Executory为SimpleExecutor。 代码@2:根据executorType的值创建对应的Executory。 代码@3:如果cacheEnabled为true,则创建CachingExecutory,然后在其内部持有上面创建的Executor,cacheEnabled默认为true,则默认创建的Executor为CachingExecutor,并且其内部包裹着SimpleExecutor。 代码@4:使用InterceptorChain.pluginAll为executor创建代理对象,即Mybatis的拆件机制,将在该系列文章中详细介绍。
在学习StatementHandler之前,我们先来回顾一下JDBC相关的知识。JDBC与语句执行的两大主流对象:java.sql.Statement、java.sql.PrepareStatement对象大家应该不会陌生,该对象的execute方法就是执行SQL语句的入口,通过java.sql.Connection对象创建Statement对象。Mybatis的StatementHandler,是Mybatis创建Statement对象的处理器,即StatementHandler会接管Statement对象的创建。
1public RoutingStatementHandler(Executor executor, MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) {
2
3 switch (ms.getStatementType()) { // @1
4 case STATEMENT:
5 delegate = new SimpleStatementHandler(executor, ms, parameter, rowBounds, resultHandler, boundSql);
6 break;
7 case PREPARED:
8 delegate = new PreparedStatementHandler(executor, ms, parameter, rowBounds, resultHandler, boundSql);
9 break;
10 case CALLABLE:
11 delegate = new CallableStatementHandler(executor, ms, parameter, rowBounds, resultHandler, boundSql);
12 break;
13 default:
14 throw new ExecutorException("Unknown statement type: " + ms.getStatementType());
15 }
16
17}
原来是会根据MappedStatement对象的statementType创建对应的StatementHandler。
1public StatementHandler newStatementHandler(Executor executor, MappedStatement mappedStatement, Object parameterObject, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) {
2 StatementHandler statementHandler = new RoutingStatementHandler(executor, mappedStatement, parameterObject, rowBounds, resultHandler, boundSql); // @1
3 statementHandler = (StatementHandler) interceptorChain.pluginAll(statementHandler); // @2
4 return statementHandler;
5}
该方法的两个关键点如下: 代码@1:创建RoutingStatementHandler对象,在其内部再根据SQL语句的类型,创建对应的StatementHandler对象。 代码@2:对StatementHandler引入拆件机制,该部分将在该专题的后续文章中会详细介绍,这里暂时跳过。
参数处理器。同样我们先来看一下其类图。
这个比较简单,就是处理PreparedStatemet接口的参数化处理,也可以顺便看一下其调用链(该部分会在下一篇中详细介绍)。
1public ParameterHandler newParameterHandler(MappedStatement mappedStatement, Object parameterObject, BoundSql boundSql) {
2 ParameterHandler parameterHandler = mappedStatement.getLang().createParameterHandler(mappedStatement, parameterObject, boundSql);
3 parameterHandler = (ParameterHandler) interceptorChain.pluginAll(parameterHandler); // @1
4 return parameterHandler;
5}
同样该接口也支持插件化机制。
处理结果的Handler。我们同样看一下其类图。
处理Jdbc ResultSet的处理器。
1public ResultSetHandler newResultSetHandler(Executor executor, MappedStatement mappedStatement, RowBounds rowBounds, ParameterHandler parameterHandler,
2 ResultHandler resultHandler, BoundSql boundSql) {
3 ResultSetHandler resultSetHandler = new DefaultResultSetHandler(executor, mappedStatement, parameterHandler, resultHandler, boundSql, rowBounds);
4 resultSetHandler = (ResultSetHandler) interceptorChain.pluginAll(resultSetHandler);
5 return resultSetHandler;
6}
同样支持插件化机制,我们也稍微再看一下其调用链:
可以看出其调用的入口为SQL执行时。
本文作为下一篇《源码分析Mybatis整合ShardingJdbc SQL执行流程》的前置篇,详细介绍Executor、StatementHandler、ParameterHandler、ResultSetHandler的具体职责,以类图为基础详细介绍其核心方法的作用,然后讲述这些对象如何创建并引出Mybatis拆件机制。并引出Mybatis拆件机制。