!特别声明!:这篇文章只是单纯用来应对面试,并不能用来当作深度解析的文章来看。本人才疏学浅,文章也可能有不对的地方,望指正。
此源码分析使用的是Java11
基本使用流程:
String resource = "mybatis-config.xml";
InputStream inputStream = Resources.getResourceAsStream(resource);
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
SqlSession sqlSession = sqlSessionFactory.openSession();
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
User userById = mapper.getUserById(1);
我们在使用 mybatis时,基本使用用法如上所示
我们一步一步的来看
String resource = "mybatis-config.xml";
InputStream inputStream = Resources.getResourceAsStream(resource);
这一步,不做细讲,就是简单的将我们的xml配置文件转化为输入流对象。
第一步
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
这一步,我们调用了 SqlSessionFactoryBuilder
对象的build()
方法。进入源码分析
1.1 SqlSessionFactoryBuilder
对象的build()
方法源码分析
我们首先进入 第一条语句的源码
XMLConfigBuilder parser = new XMLConfigBuilder(inputStream, environment, properties);
1.2 XMLConfigBuilder()
函数源码分析
private XMLConfigBuilder(XPathParser parser, String environment, Properties props) {
super(new Configuration());
ErrorContext.instance().resource("SQL Mapper Configuration");
this.configuration.setVariables(props);
this.parsed = false;
this.environment = environment;
this.parser = parser;
}
这个函数大致作用就是 构建了一个Configuration对象,然后给XMLConfigBuilder对象的属性赋值
(注意:Configuration对象类似于单例模式,就是整个Mybatis中只有一个Configuration对象。,这个对象很重要)
XMLConfigBuilder parser = new XMLConfigBuilder(inputStream, environment, properties);
这条语句就到这里结束,就是创建了 一个 XMLConfigBuilder 类的实例,并给属性赋值,同时创建了一个 Configuration对象
接着我们分析第二条语句
return build(parser.parse());
里面先是 调用了 第一条语句创建的对象的parse()
方法,我们进入源码进行分析
1.3 parser.parse()
源码分析
public Configuration parse() {
if (parsed) {
throw new BuilderException("Each XMLConfigBuilder can only be used once.");
}
parsed = true;
parseConfiguration(parser.evalNode("/configuration"));
return configuration;
}
parseConfiguration(parser.evalNode("/configuration"));
我们可以看到其实整个 parse()
函数就调用了这一个方法。
我们给parseConfiguration()
提供的参数是一个 Xnode
对象,对应的是我们配置文件中的一级标签 <configuration>
。我们的配置文件大概构造如下:
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<!--核心配置文件-->
<configuration>
......
<environments default="development">
......
</environments>
<mappers>
......
</mappers>
</configuration>
我们继续进入源码
1.4 parseConfiguration()
源码分析
我们可以看到,我们提供的 root 参数就是 <configuration>
的节点对象。然后这个parseConfiguration()
函数对 配置文件中 <configuration>
标签下的二级标签进行了一些操作,进行了哪些操作呢?我们随便进入一个源码进行查看,此处以 <properties>
标签为例,我们进入propertiesElement()
函数的源码
1.5 propertiesElement()
源码分析
<properties resource="db.properties">
<property name="username" value="root"/>
<property name="password" value="111111"/>
</properties>
xml文件中的一种用法,此处仅为了方便理解下面的代码
private void propertiesElement(XNode context) throws Exception {
if (context != null) {
//此处创建了一个 Properties 类的对象。
//我们知道 在 mybatis的配置文件中,可以通过 <properties>文件引入别的文件:例如数据库
Properties defaults = context.getChildrenAsProperties();
//我们看一下 context对象有没有这两种属性
String resource = context.getStringAttribute("resource");
String url = context.getStringAttribute("url");
//全都为 null 说明没有引入别的文件
if (resource != null && url != null) {
throw new BuilderException("The properties element cannot specify both a URL and a resource based property file reference. Please specify one or the other.");
}
//否则的话,把引入的文件的内容 交给 defaults 对象 (大致这样理解就行)
if (resource != null) {
defaults.putAll(Resources.getResourceAsProperties(resource));
} else if (url != null) {
defaults.putAll(Resources.getUrlAsProperties(url));
}
//我们在解析创建XMLConfigBuilder对象的时候创建了 一个 configuration对象
Properties vars = configuration.getVariables();
//看看 configu中是否已经存在别的引文的文件
//如果有,把内容也交给 defaults 对象
if (vars != null) {
defaults.putAll(vars);
}
//用 defaults 再去更新 parse和configuration对象中的对应属性
parser.setVariables(defaults);
configuration.setVariables(defaults);
}
}
总的来说propertiesElement()
函数的工作就是 解析配置文件中的<properties>
标签的信息,生成相应的对象,更新 configuration
对象的相应属性。
那么其他的函数操作应该作用基本相似,解析相应的标签的内容,将内容赋值给 configuration
对象的对应属性。
别的标签的具体实现我们就不再深入去看了,但是有一个我们还是需要去看 <mapper>
标签。
这个标签可谓是 配置文件的核心了。
我们去看一下
1.6 mapperElement(XNode parent)
源码分析
在看源码前,我们需要知道一件事情
mapper映射的几种方式
<--! 1使用类路径 -->
<mappers>
<mapper resource="org/mybatis/builder/AuthorMapper.xml"/>
<mapper resource="org/mybatis/builder/BlogMapper.xml"/>
<mapper resource="org/mybatis/builder/PostMapper.xml"/>
</mappers>
<--! 2使用绝对url路径 -->
<mappers>
<mapper url="file:///var/mappers/AuthorMapper.xml"/>
<mapper url="file:///var/mappers/BlogMapper.xml"/>
<mapper url="file:///var/mappers/PostMapper.xml"/>
</mappers>
<--! 3使用java类名 -->
<mappers>
<mapper class="org.mybatis.builder.AuthorMapper"/>
<mapper class="org.mybatis.builder.BlogMapper"/>
<mapper class="org.mybatis.builder.PostMapper"/>
</mappers>
<--! 4自动扫描包下所有映射器 -->
<mappers>
<package name="org.mybatis.builder"/>
</mappers>
我们紧接着看源码
private void mapperElement(XNode parent) throws Exception {
//可以没有 mappers 标签
if (parent != null) {
// child 就是 mappers 下的 mapper 标签
for (XNode child : parent.getChildren()) {
//如果有 package 属性,说明 用是是自动扫描
if ("package".equals(child.getName())) {
String mapperPackage = child.getStringAttribute("name");
//把相应的属性值 交给 configuration 对象即可
configuration.addMappers(mapperPackage);
} else {
String resource = child.getStringAttribute("resource");
String url = child.getStringAttribute("url");
String mapperClass = child.getStringAttribute("class");
//<mapper resource="org/mybatis/builder/AuthorMapper.xml"/>
if (resource != null && url == null && mapperClass == null) {
ErrorContext.instance().resource(resource);
InputStream inputStream = Resources.getResourceAsStream(resource);
XMLMapperBuilder mapperParser = new XMLMapperBuilder(inputStream, configuration, resource, configuration.getSqlFragments());
mapperParser.parse();
} else //<mapper url="file:///var/mappers/AuthorMapper.xml"/>
if (resource == null && url != null && mapperClass == null) {
ErrorContext.instance().resource(url);
InputStream inputStream = Resources.getUrlAsStream(url);
XMLMapperBuilder mapperParser = new XMLMapperBuilder(inputStream, configuration, url, configuration.getSqlFragments());
mapperParser.parse();
} else //<mapper class="org.mybatis.builder.PostMapper"/>
if (resource == null && url == null && mapperClass != null) {
Class<?> mapperInterface = Resources.classForName(mapperClass);
configuration.addMapper(mapperInterface);
} else { // 都没有就抛出异常
throw new BuilderException("A mapper element may only specify a url, resource or class, but not more than one.");
}
}
}
}
}
其实这个函数也是用来解析<mappers>
标签的,不过就是根据不同的映射方式,进行不同的方法解析。至于具体干了什么,此处不去探究(主要是因为我菜,看不懂)
至此 , parse()
的作用我们有了一个大致的了解,就是将配置文件中的各种标签的信息都解析到 configuration
对象中, 并且返回configuration
对象
public Configuration parse() {
if (parsed) {
throw new BuilderException("Each XMLConfigBuilder can only be used once.");
}
parsed = true;
parseConfiguration(parser.evalNode("/configuration"));
return configuration;
}
return build(parser.parse());
这句代码中外层还有一个 build()
函数,我们看一下这个函数干啥了。源码就一句
public SqlSessionFactory build(Configuration config) {
return new DefaultSqlSessionFactory(config);
}
根据 parser.parse()
返回的configuration
创建一个 DefaultSqlSessionFactory
对象。具体怎么创建的我们不去探究(菜,懂?)
至此。我们的第一大步到此结束
小结:
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
这一步,就是解析我们的xml配置文件,并且将解析的内容赋值给 一个 configuration
对象。同时,使用这个 configuration
对象,创建一个 DefaultSqlSessionFactory
对象。
此行代码可以这样理解
SqlSessionFactory sqlSessionFactory = new DefaultSqlSessionFactory();
第二步
SqlSession sqlSession = sqlSessionFactory.openSession();
通过第一步 , 我们知道 sqlSessionFactory
这个对象是 DefaultSqlSessionFactory
类的实例,所以我们去 DefaultSqlSessionFactory
类中去探究一下 openSession()
具体做了什么。
2.1 sqlSessionFactory.openSession()
源码分析
//直接调用的是这个
@Override
public SqlSession openSession() {
return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false);
}
//间接调用这个
private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {
Transaction tx = null;
try {
//从 configuration 中 获得 environment 标签下的信息
//在 mybatis的配置文件中,environment 标签 存放的都是一些数据库的信息
final Environment environment = configuration.getEnvironment();
//创建一个事务工厂
final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);
//创建一个事务对象,工厂模式
tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);
// 创建一个执行器
final Executor executor = configuration.newExecutor(tx, execType);
//返回 一个 DefaultSqlSession 对象
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();
}
}
源码比较简单,本质就是返回了一个 DefaultSqlSession
类的实例对象。
这个对象有两个比较重要的属性(DefaultSqlSession
类的源码中就有,直接可以看到的)
private final Configuration configuration;
private final Executor executor;
那么
SqlSession sqlSession = sqlSessionFactory.openSession();
就可以理解为
SqlSession sqlSession = new DefaultSqlSession();
小结:
SqlSession sqlSession = sqlSessionFactory.openSession();
主要工作就是创建一个 DefaultSqlSession
实例对象,赋值给 sqlSession
。
此处我们稍微看下 executor
的构建源码(可跳过)
2.2 configuration.newExecutor(tx, execType)
源码解析(可跳过)
public Executor newExecutor(Transaction transaction, ExecutorType executorType) {
executorType = executorType == null ? defaultExecutorType : executorType;
executorType = executorType == null ? ExecutorType.SIMPLE : executorType;
Executor executor;
//第一步,确实executor的类型
//SIMPLE, REUSE, BATCH
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;
}
大概了解即可,不必深究(我也不会,主打就是一个菜)
第三步
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
我们的 sqlSession
是DefaultSqlSession
类的实例,我们直接去看 DefaultSqlSession
类的getMapper()
方法
@Override
public <T> T getMapper(Class<T> type) {
return configuration.getMapper(type, this);
}
他是调用了 configuration
对象的getMapper()
。我们继续深入
public <T> T getMapper(Class<T> type, SqlSession sqlSession) {
return mapperRegistry.getMapper(type, sqlSession);
}
configuration
对象又调用的 mapperRegistry
对象的getMapper()
方法。我们继续深入。
3.1 mapperRegistry.getMapper(type, sqlSession)
源码分析
public <T> T getMapper(Class<T> type, SqlSession sqlSession) {
//一个 mapper代理工厂
final MapperProxyFactory<T> mapperProxyFactory = (MapperProxyFactory<T>) 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);
}
}
看到Proxy
这个单词有没有很熟悉,代理
getMapper()
的返回值我们可以大胆猜测是一个代理对象。而这个对象代理的就是 sqlSession
return mapperProxyFactory.newInstance(sqlSession);
至于是不是,我们进入源码分析
3.2 mapperProxyFactory.newInstance(sqlSession)
源码分析
为了区分,我们假设上面的函数为newInstance1
,下面的为newInstance2
。
直接调用newInstance2
,间接调用 newInstance1
//这是间接调用的函数
// newInstance1
protected T newInstance(MapperProxy<T> mapperProxy) {
return (T) Proxy.newProxyInstance(mapperInterface.getClassLoader(), new Class[] { mapperInterface }, mapperProxy);
}
// newInstance2
// 这是直接调用的函数
public T newInstance(SqlSession sqlSession) {
final MapperProxy<T> mapperProxy = new MapperProxy<>(sqlSession, mapperInterface, methodCache);
return newInstance(mapperProxy);
}
其实,看到这里,我们就可以结束第三步了
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
第三步就是得到了 sqlSession
的代理对象。
第四步
User userById = mapper.getUserById(1);
让我们的代理对象去执行函数。实际上是我们的真实对象去执行其对应的函数(动态代理的知识)。
具体实现就在代理对象的 invoke()
函数中。
在第三步中,我们源码进行到了这一步。我们获得了代理对象。
//这是间接调用的函数
// newInstance1
protected T newInstance(MapperProxy<T> mapperProxy) {
return (T) Proxy.newProxyInstance(mapperInterface.getClassLoader(), new Class[] { mapperInterface }, mapperProxy);
}
// newInstance2
// 这是直接调用的函数
public T newInstance(SqlSession sqlSession) {
final MapperProxy<T> mapperProxy = new MapperProxy<>(sqlSession, mapperInterface, methodCache);
return newInstance(mapperProxy);
}
newProxyInstance()
的基本形式如下
public static Object newProxyInstance(ClassLoader loader,
Class<?>[] interfaces,
InvocationHandler h)
我们进行对比一下 newInstance1
,可以看出
mapperProxy
对象占据了InvocationHandler h
对象的位置。那么我们可以大胆猜测,mapperProxy对象的类一定是实现了 InvocationHandler
的接口的,并且重写了一个很重要的 invoke()
函数
我们进入 new MapperProxy()
进行分析。
4.1 new MapperProxy()
源码分析
事实证明,我们的猜测完全正确。
public class MapperProxy<T> implements InvocationHandler, Serializable {}
然后我们看一下重写的invoke()
方法
@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 {
//自定义的方法(我只是这样理解,至于是不是,我不确定)
return cachedInvoker(method).invoke(proxy, method, args, sqlSession);
}
} catch (Throwable t) {
throw ExceptionUtil.unwrapThrowable(t);
}
}
我们看一下 cachedInvoker(method).invoke()
的源码
private MapperMethodInvoker cachedInvoker(Method method) throws Throwable {
try {
// A workaround for https://bugs.openjdk.java.net/browse/JDK-8161372
// It should be removed once the fix is backported to Java 8 or
// MyBatis drops Java 8 support. See gh-1929
MapperMethodInvoker invoker = methodCache.get(method);
if (invoker != null) {
return invoker;
}
return methodCache.computeIfAbsent(method, m -> {
if (m.isDefault()) {
try {
if (privateLookupInMethod == null) {
return new DefaultMethodInvoker(getMethodHandleJava8(method));
} else {
return new DefaultMethodInvoker(getMethodHandleJava9(method));
}
} catch (IllegalAccessException | InstantiationException | InvocationTargetException
| NoSuchMethodException e) {
throw new RuntimeException(e);
}
} else {
return new PlainMethodInvoker(new MapperMethod(mapperInterface, method, sqlSession.getConfiguration()));
}
});
} catch (RuntimeException re) {
Throwable cause = re.getCause();
throw cause == null ? re : cause;
}
}
是不是看不懂,我也看不懂。但是有一个跟 sqlSession
相关的
return new PlainMethodInvoker(new MapperMethod(mapperInterface, method, sqlSession.getConfiguration()));
就是这一句(这只是我找的一个借口)(其实我也不知道为啥用这一句,我们就直接看,别管为啥了,),那我们进入 MapperMethod
类的源码看看吧。
private final SqlCommand command;
private final MethodSignature method;
public MapperMethod(Class<?> mapperInterface, Method method, Configuration config) {
this.command = new SqlCommand(config, mapperInterface, method);
this.method = new MethodSignature(config, mapperInterface, method);
}
MapperMethod
类中有两个属性,我们分别进入源码看看两个对象中存放的是什么。
4.2 new SqlCommand()
源码分析
public static class SqlCommand {
//两个属性
private final String name; // sql对应的namespace+id
private final SqlCommandType type; // sql 语句的类型。
public SqlCommand(Configuration configuration, Class<?> mapperInterface, Method method) {
//代理对象执行的方法名
final String methodName = method.getName();
final Class<?> declaringClass = method.getDeclaringClass();
//我们先去这个函数看看具体做了什么。
//源码在下面一点点
MappedStatement ms = resolveMappedStatement(mapperInterface, methodName, declaringClass,
configuration);
if (ms == null) {
if (method.getAnnotation(Flush.class) != null) {
name = null;
type = SqlCommandType.FLUSH;
} else {
throw new BindingException("Invalid bound statement (not found): "
+ mapperInterface.getName() + "." + methodName);
}
} else {
//获得 sql标签的 id 和 sql 标签的类型(select 啥啥的)。
name = ms.getId();
type = ms.getSqlCommandType();
if (type == SqlCommandType.UNKNOWN) {
throw new BindingException("Unknown execution method for: " + name);
}
}
}
private MappedStatement resolveMappedStatement(Class<?> mapperInterface, String methodName,
Class<?> declaringClass, Configuration configuration) {
//这就是经常提到的 namespace+id 可以唯一确定一个 sql 语句
//这个方法就是 将 namespace+id 作为一个 key 去获得一个 ,appedStatement对象
// Map<String, MappedStatement> mappedStatements; 这是configuration对象中的一个属性
String statementId = mapperInterface.getName() + "." + methodName;
if (configuration.hasStatement(statementId)) {
return configuration.getMappedStatement(statementId);
} else if (mapperInterface.equals(declaringClass)) {
return null;
}
//这个我看不懂
for (Class<?> superInterface : mapperInterface.getInterfaces()) {
if (declaringClass.isAssignableFrom(superInterface)) {
MappedStatement ms = resolveMappedStatement(superInterface, methodName,
declaringClass, configuration);
if (ms != null) {
return ms;
}
}
}
return null;
}
}
看不懂没关系,只要记住 command
中存放的是 sql 语句的 id
以及 类型
即可。
new MethodSignature
的源码我们就不看了,method
对象存放的是sql语句的返回值类型
以及参数
我们赶紧回到 MapperMethod
类的源码来,不要过多去纠结 SqlCommand
类和 MethodSignature
的源码了。我们知道里面主要有啥就行了。
private final SqlCommand command;
private final MethodSignature method;
public MapperMethod(Class<?> mapperInterface, Method method, Configuration config) {
this.command = new SqlCommand(config, mapperInterface, method);
this.method = new MethodSignature(config, mapperInterface, method);
}
此处先停止。我们先回到 MapperProxy
的invoke()
方法。我们必须要明白,我们第四步是要搞清楚到底是执行了哪个方法
@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 {
//自定义的方法(我只是这样理解,至于是不是,我不确定)
return cachedInvoker(method).invoke(proxy, method, args, sqlSession);
}
} catch (Throwable t) {
throw ExceptionUtil.unwrapThrowable(t);
}
}
cachedInvoker(method)
是一个方法的返回对象。
return new PlainMethodInvoker(new MapperMethod(mapperInterface, method, sqlSession.getConfiguration()));
这个方法的返回对象是 PlainMethodInvoker
类型的
那么
return cachedInvoker(method).invoke(proxy, method, args, sqlSession);
//就相当于
return new PlainMethodInvoker().invoke(proxy, method, args, sqlSession);
//就相当于最终我们返回的是 PlainMethodInvoker 对象的 invoke()函数的返回值
我们进入PlainMethodInvoker
类的源码去看一下
4.3 PlainMethodInvoker
类源码分析
private static class PlainMethodInvoker implements MapperMethodInvoker {
private final MapperMethod mapperMethod;
public PlainMethodInvoker(MapperMethod mapperMethod) {
super();
this.mapperMethod = mapperMethod;
}
@Override
public Object invoke(Object proxy, Method method, Object[] args, SqlSession sqlSession) throws Throwable {
return mapperMethod.execute(sqlSession, args);
}
}
看看我们发现了什么
@Override
public Object invoke(Object proxy, Method method, Object[] args, SqlSession sqlSession) throws Throwable {
return mapperMethod.execute(sqlSession, args);
}
最终返回的结果居然是 mapperMethod.execute()
函数的返回值。
我们进入 mapperMethod.execute()
源码中看看~
4.4 mapperMethod.execute()
源码分析
public Object execute(SqlSession sqlSession, Object[] args) {
Object result;
//根据 comman的type属性,确实我们的sql类型
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);
if (method.returnsOptional()
&& (result == null || !method.getReturnType().equals(result.getClass()))) {
result = Optional.ofNullable(result);
}
}
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;
}
我你们可以在上面源码中看到很多这样的代码!
result = rowCountResult(sqlSession.insert(command.getName(), param));
我们发现 我们 的返回结果又变成了 sqlSession
执行相应函数的返回结果。还记的我们前面提到的吗? sqlSession
是 DefaultSqlSession
类的实例。我们去DefaultSqlSession
类中去找这些方法!!
以 sqlSession.update(command.getName(), param)
为例
进入源码分析
4.5 sqlSession.update(command.getName(), param)
源码分析
@Override
public int update(String statement, Object parameter) {
try {
dirty = true;
MappedStatement ms = configuration.getMappedStatement(statement);
return executor.update(ms, wrapCollection(parameter));
} catch (Exception e) {
throw ExceptionFactory.wrapException("Error updating database. Cause: " + e, e);
} finally {
ErrorContext.instance().reset();
}
}
我们发现 sqlSession.update()
的本质是交给 exectuor
去执行。至于执行器怎么去执行的,我们就不再探究了!(我不会)。到此第四步其实已经执行完了。可能有点乱,我们来小结一下。
小结:
User userById = mapper.getUserById(1);
我们知道, mapper.getUserById(1)
回去执行对应 mapper.xml
文件中对应的sql语句。第四步的原理解析实际上就是解析二者是怎么匹配的。
我们知道 代理对象执行方法时,其实执行的是 invoke()
方法。
@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 {
//自定义的方法(我只是这样理解,至于是不是,我不确定)
return cachedInvoker(method).invoke(proxy, method, args, sqlSession);
}
} catch (Throwable t) {
throw ExceptionUtil.unwrapThrowable(t);
}
}
下面我们用个流程图去说明,就不再看源码了。
简单概括! 代理对象调用方法的过程底层是 :通过 mapperMethod对象的属性(command
和method
) ,匹配 sqlSession
对象应该执行的函数。 同时 sqlSession
将具体的实现交给 执行器 executor
去执行。
这一步的口述我也很难用文字去表述清楚。大家多看几遍应该能理解。
分析就到这里啦,exectuor
的底层就不再分析了,我也不会。
至于 mappedStatement
是从哪来的 大家可以看一下这篇文章 点击这里