调用流程概述：#
mybatis 的前身是 ibatis，原生的 ibatis 执行 curd 操作是固定的操作，使用 SQLSession 接口中的方法进行增删查改，我们先阅读 Ibatis 部分的代码，后续 mybatis [plus] 都是在此基础上扩展了 MapperProxy 以及预设 sql 语句动态 sql 条件等封装，我们看一下 ibatis 的 Session 核心接口：
public interface SqlSession extends Closeable {
<E> List<E> selectList(String statement);
<K, V> Map<K, V> selectMap(String statement, Object parameter, String mapKey);
<T> Cursor<T> selectCursor(String statement);
int insert(String statement);
int update(String statement);
int delete(String statement);
}
这个接口里面最终要的四类方法为（selectList、selectMap、selectCursor）、insert、delete、update。
但其实最终执行 sql 语句的为 Executor 中的方法
public interface Executor {
int update(MappedStatement ms, Object parameter) throws SQLException;
<E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler,
CacheKey cacheKey, BoundSql boundSql) throws SQLException;
<E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler)
throws SQLException;
<E> Cursor<E> queryCursor(MappedStatement ms, Object parameter, RowBounds rowBounds) throws SQLException;
}
其中分为 query 和 update 方法，最后由实际子类的 doQuery、doUpdate 执行真正的 sql 语句，其中进一步交给了 StatementHandler 对象处理
public interface StatementHandler {
Statement prepare(Connection connection, Integer transactionTimeout) throws SQLException;
void parameterize(Statement statement) throws SQLException;
void batch(Statement statement) throws SQLException;
int update(Statement statement) throws SQLException;
<E> List<E> query(Statement statement, ResultHandler resultHandler) throws SQLException;
<E> Cursor<E> queryCursor(Statement statement) throws SQLException;
BoundSql getBoundSql();
ParameterHandler getParameterHandler();
}
可以看到里面最终到达 update 或者 query 方法
所以调用逻辑为 SqlSession->Executor->StatementHandler，每个 SqlSession 有一个 Executor，每个 Executor 有一个 StatementHandler（configuration 中获得的，经过插件的包装，后面会说）；
SqlSession 的创建过程：
其中的核心为 Configuration，整个 ibatis 都围绕这这个 Configuration 类，非常重要负责 Executor、ParameterHandler、ResultSetHandler 的创建，MapperStatements 的保存
一、二级缓存#
一级缓存
存在与执行器中，每次创建都会携带，所以每次会话都会有一级缓存的存在：BaseExecutor.java
public <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql) throws SQLException {
ErrorContext.instance().resource(ms.getResource()).activity("executing a query").object(ms.getId());
if (closed) {
throw new ExecutorException("Executor was closed.");
}
if (queryStack == 0 && ms.isFlushCacheRequired()) {
clearLocalCache();
}
List<E> list;
try {
queryStack++;
list = resultHandler == null ? (List<E>) localCache.getObject(key) : null;
if (list != null) {
handleLocallyCachedOutputParameters(ms, key, parameter, boundSql);
} else {
list = queryFromDatabase(ms, parameter, rowBounds, resultHandler, key, boundSql);
}
} finally {
queryStack--;
}
if (queryStack == 0) {
for (DeferredLoad deferredLoad : deferredLoads) {
deferredLoad.load();
}
// issue #601
deferredLoads.clear();
if (configuration.getLocalCacheScope() == LocalCacheScope.STATEMENT) {
// issue #482
clearLocalCache();
}
}
return list;
}
在查询之前，会先去缓存里面查找，其中 key 值与四个方面有关
CacheKey key = createCacheKey(ms, parameter, rowBounds, boundSql);
只有当 sql 语句、参数、分页、与绑定参数的 sql 一样才会匹配；
二级缓存
存在与 ms 中的 cache 属性当中，只有当 configuration 中的 cacheEnable 为 true 才会创建 cacheExecutor
// Configuration.java
public Executor newExecutor(Transaction transaction, ExecutorType executorType) {
executorType = executorType == null ? defaultExecutorType : 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;
}
// 默认为true
同时 ms 中的 useCache 为 true，才会实际操作 ms 中的 cache
// CachingExecutor.java
public <E> List<E> query(MappedStatement ms, Object parameterObject, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql)
throws SQLException {
Cache cache = ms.getCache();
if (cache != null) {
flushCacheIfRequired(ms);
if (ms.isUseCache() && resultHandler == null) {
ensureNoOutParams(ms, boundSql);
@SuppressWarnings("unchecked")
List<E> list = (List<E>) tcm.getObject(cache, key);
if (list == null) {
list = delegate.query(ms, parameterObject, rowBounds, resultHandler, key, boundSql);
tcm.putObject(cache, key, list); // issue #578 and #116
}
return list;
}
}
return delegate.query(ms, parameterObject, rowBounds, resultHandler, key, boundSql);
}
// 默认也为true
可以看到，只有当 cach 不为 null 才会实际操作缓存，在解析 mapper.xml 的时候才会判断是否设置了 cache 类型
// XMLMapperBuilder.java
private void configurationElement(XNode context) {
try {
String namespace = context.getStringAttribute("namespace");
if (namespace == null || namespace.isEmpty()) {
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. The XML location is '" + resource + "'. Cause: " + e, e);
}
}
// 类型有很多种
此文由 Mix Space 同步更新至 xLog
原始链接为 https://me.liuyaowen.club/posts/default/Mybatisplus