文档章节

MyBatis-3.4.2-源码分析18:XML解析之RoleMapper userMapper = sqlSession.getMapper(RoleMapper.class)

强子哥哥
 强子哥哥
发布于 2017/04/08 10:44
字数 1187
阅读 21
收藏 1
点赞 0
评论 0

这一节,我们来获取mapper

RoleMapper userMapper = sqlSession.getMapper(RoleMapper.class);
@SuppressWarnings("unchecked")
	public <T> T getMapper(Class<T> type, SqlSession sqlSession) {
		// 这里开始
		final MapperProxyFactory<T> mapperProxyFactory = (MapperProxyFactory<T>) knownMappers.get(type);
		if (mapperProxyFactory == null) {
			throw new BindingException("Type " + type + " is not known to the MapperRegistry.");
		}
		// 找到了mapperProxyFactory
		try {
			// 调用这个方法生成实例
			return mapperProxyFactory.newInstance(sqlSession);
		} catch (Exception e) {
			throw new BindingException("Error getting mapper instance. Cause: " + e, e);
		}
	}
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);
	}

那么,这里,其实就是生成了一个代理对象。

Step completed: "thread=main", test.Test.business(), line=37 bci=17
37    			RoleMapper userMapper = sqlSession.getMapper(RoleMapper.class);
> 
main[1] print userMapper
 userMapper = "org.apache.ibatis.binding.MapperProxy@3f197a46"

接下来,开始调用一个方法,本质是进入了代理对象内部

Role role = userMapper.getRole(1L);
@Override
	public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
		// 这里是用了JDK自身的反射机制
		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);
	}

首先,会根据method生成一个key,根据这个key去查找之前解析xml的结果里,去查是否有找到结果

	public boolean hasStatement(String statementName, boolean validateIncompleteStatements) {
		// 看到这里了
		if (validateIncompleteStatements) {
			// 看到这里了
			buildAllStatements();
			// 看到这里了
		}
		// 看到这里了
		return mappedStatements.containsKey(statementName);
	}
Step completed: "thread=main", org.apache.ibatis.session.Configuration.hasStatement(), line=786 bci=0
786    		if (validateIncompleteStatements) {

main[1] main[1] next
> 
Step completed: "thread=main", org.apache.ibatis.session.Configuration.hasStatement(), line=787 bci=4
787    			buildAllStatements();

main[1] next
> 
Step completed: "thread=main", org.apache.ibatis.session.Configuration.hasStatement(), line=789 bci=8
789    		return mappedStatements.containsKey(statementName);

main[1] print mappedStatements
 mappedStatements = "{interfaces.RoleMapper.deleteUser=org.apache.ibatis.mapping.MappedStatement@50a638b5, interfaces.RoleMapper.getRole=org.apache.ibatis.mapping.MappedStatement@1817d444, insertUser=org.apache.ibatis.mapping.MappedStatement@6ca8564a, interfaces.RoleMapper.insertUser=org.apache.ibatis.mapping.MappedStatement@6ca8564a, getRole=org.apache.ibatis.mapping.MappedStatement@1817d444, deleteUser=org.apache.ibatis.mapping.MappedStatement@50a638b5, updateUser=org.apache.ibatis.mapping.MappedStatement@50b472aa, interfaces.RoleMapper.updateUser=org.apache.ibatis.mapping.MappedStatement@50b472aa}"
main[1] 

找到的话,就直接取出来了

Step completed: "thread=main", org.apache.ibatis.session.Configuration.getMappedStatement(), line=746 bci=18
746    		return mappedStatements.get(id);

main[1] step
> 
Step completed: "thread=main", org.apache.ibatis.session.Configuration.getMappedStatement(), line=739 bci=6
739    		return this.getMappedStatement(id, true);

main[1] step
> 
Step completed: "thread=main", org.apache.ibatis.binding.MapperMethod$SqlCommand.<init>(), line=218 bci=53
218            ms = configuration.getMappedStatement(statementName);

main[1] step
> 
Step completed: "thread=main", org.apache.ibatis.binding.MapperMethod$SqlCommand.<init>(), line=219 bci=55
219          } else if (!mapperInterface.equals(method.getDeclaringClass())) { // issue #35

main[1] print ms
 ms = "org.apache.ibatis.mapping.MappedStatement@1817d444"

好,到这里,我们就生成了1个MappedStatement对象了。

接下来,看执行了什么。

} else {
				//走这个分支
				name = ms.getId();
				//取出type
				type = ms.getSqlCommandType();
				if (type == SqlCommandType.UNKNOWN) {
					throw new BindingException("Unknown execution method for: " + name);
				}
			}
Step completed: "thread=main", org.apache.ibatis.binding.MapperMethod$SqlCommand.<init>(), line=233 bci=174
233            name = ms.getId();

main[1] sep
Unrecognized command: 'sep'.  Try help...
main[1] step
> 
Step completed: "thread=main", org.apache.ibatis.mapping.MappedStatement.getId(), line=210 bci=0
210        return id;

main[1] 
main[1] 
main[1] print id
 id = "interfaces.RoleMapper.getRole"
main[1] step
> 
Step completed: "thread=main", org.apache.ibatis.binding.MapperMethod$SqlCommand.<init>(), line=233 bci=180
233            name = ms.getId();

main[1] step
> 
Step completed: "thread=main", org.apache.ibatis.binding.MapperMethod$SqlCommand.<init>(), line=234 bci=183
234            type = ms.getSqlCommandType();

main[1] print name
 name = "interfaces.RoleMapper.getRole"
main[1] step
> 
Step completed: "thread=main", org.apache.ibatis.mapping.MappedStatement.getSqlCommandType(), line=198 bci=0
198        return sqlCommandType;

main[1] print sqlCommandType
 sqlCommandType = "SELECT"
main[1] step
> 
Step completed: "thread=main", org.apache.ibatis.binding.MapperMethod$SqlCommand.<init>(), line=234 bci=189
234            type = ms.getSqlCommandType();

main[1] step
> 
Step completed: "thread=main", org.apache.ibatis.binding.MapperMethod$SqlCommand.<init>(), line=235 bci=192
235            if (type == SqlCommandType.UNKNOWN) {

main[1] print type
 type = "SELECT"
main[1] print type.getClass()
 type.getClass() = "class org.apache.ibatis.mapping.SqlCommandType"
main[1] 

---------------接下来,处理

this.method = new MethodSignature(config, mapperInterface, method);

看细节

public MethodSignature(Configuration configuration, Class<?> mapperInterface, Method method) {
			// 构造返回类型
			Type resolvedReturnType = TypeParameterResolver.resolveReturnType(method, mapperInterface);
			// 
			if (resolvedReturnType instanceof Class<?>) {
				// 返回类型
				this.returnType = (Class<?>) resolvedReturnType;
				// end
			} else if (resolvedReturnType instanceof ParameterizedType) {
				this.returnType = (Class<?>) ((ParameterizedType) resolvedReturnType).getRawType();
			} else {
				this.returnType = method.getReturnType();
			}
			// 是否返回为空
			this.returnsVoid = void.class.equals(this.returnType);
			// 返回结果是否为集合,数组
			this.returnsMany = (configuration.getObjectFactory().isCollection(this.returnType)
					|| this.returnType.isArray());
			//
			this.returnsCursor = Cursor.class.equals(this.returnType);
			//继续
			this.mapKey = getMapKey(method);
			//
			this.returnsMap = (this.mapKey != null);
			//null
			this.rowBoundsIndex = getUniqueParamIndex(method, RowBounds.class);
			//null
			this.resultHandlerIndex = getUniqueParamIndex(method, ResultHandler.class);
			//看到这里了
			this.paramNameResolver = new ParamNameResolver(configuration, method);
			//end
		}

---最后终于生成了一个MapperMethod

private MapperMethod cachedMapperMethod(Method method) {
		// 这里开始
		MapperMethod mapperMethod = methodCache.get(method);
		if (mapperMethod == null) {
			// 生成一个方法
			mapperMethod = new MapperMethod(mapperInterface, method, sqlSession.getConfiguration());
			//生成以后,放到缓存里,是1个线程安全的map
			methodCache.put(method, mapperMethod);
		}
		return mapperMethod;
		//end
	}

好,我们终于有了1个真正的MapperMethod实例了。

// 一般走这个分支
		// 先拿缓存方法
		final MapperMethod mapperMethod = cachedMapperMethod(method);
		// 开始触发这个方法
		return mapperMethod.execute(sqlSession, args);
	}

接下来,开始触发这个方法,我们来看看如何触发的

首先生成一个BoundSql对象

Step completed: "thread=main", org.apache.ibatis.builder.StaticSqlSource.getBoundSql(), line=46 bci=0
46        return new BoundSql(configuration, sql, parameterMappings, parameterObject);

main[1] print sql
 sql = "select * from t_user where id=?"
main[1] print parameterMappings
 parameterMappings = "[ParameterMapping{property='id', mode=IN, javaType=class java.lang.Integer, jdbcType=null, numericScale=null, resultMapId='null', jdbcTypeName='null', expression='null'}]"
main[1] print parameterObject
 parameterObject = "1"
main[1] 

真正触发executor的doQuery

private <E> List<E> queryFromDatabase(MappedStatement ms, Object parameter, RowBounds rowBounds,
			ResultHandler resultHandler, CacheKey key, BoundSql boundSql) throws SQLException {
		// 从数据库查询
		List<E> list;
		localCache.putObject(key, EXECUTION_PLACEHOLDER);
		try {
			// 看到这里了
			list = doQuery(ms, parameter, rowBounds, resultHandler, boundSql);
		} finally {
			localCache.removeObject(key);
		}
		localCache.putObject(key, list);
		if (ms.getStatementType() == StatementType.CALLABLE) {
			localOutputParameterCache.putObject(key, parameter);
		}
		return list;
	}
Step completed: "thread=main", org.apache.ibatis.executor.BaseExecutor.queryFromDatabase(), line=338 bci=12
338    			list = doQuery(ms, parameter, rowBounds, resultHandler, boundSql);

main[1] print localCache
 localCache = "org.apache.ibatis.cache.impl.PerpetualCache@c2f3a6f7"
main[1] step
> 
Step completed: "thread=main", org.apache.ibatis.executor.SimpleExecutor.doQuery(), line=59 bci=0
59        Statement stmt = null;

所以,重点就是在各个SimpleExecutor,BatchExecutor,ReuseExecutor的方法里。

这个核心的部分放在下一节。

© 著作权归作者所有

共有 人打赏支持
强子哥哥

强子哥哥

粉丝 859
博文 925
码字总数 640910
作品 8
南京
架构师
mybatis源码分析之mapper动态代理

上一篇:mybatis源码分析之SqlSession的创建过程 https://my.oschina.net/u/657390/blog/663991 重点分析了SqlSession的创建过程.SqlSession创建成功后: 以上两段代码最终将得到相同的结果. 对...

udbwcso
2016/09/19
1K
4
mybatis入门小程序2

工程结构 UserMapper.xml代码 UserMapper.java代码 db.properties文件 SqlMapConfig.xml 测试testMapper.java 还有一下其他的文件在上一篇中已经写过了,这里就不写了 mybatis的jar包下载可以...

小城渔翁
2015/09/07
402
0
MyBatis 源码整理

如何构建SqlSessionFactory -->SqlSessionFactoryBuilder().build(reader); 多态 重载 核心--创建XMLConfigBuilder 通过它得到Configuration配置对象。然后利用对象作为参数生产SqlSessionF...

zheng_pat
2015/09/23
24
0
mybatis学习总结(二)

一、使用MyBatis对表执行CRUD操作——基于XML的实现 1、定义sql映射xml文件   userMapper.xml文件的内容如下:

pengcaijian
2015/11/12
0
0
mybatis学习笔记(7)-输出映射

mybatis学习笔记(7)-输出映射 标签: mybatis [TOC] 本文主要讲解mybatis的输出映射。 输出映射有两种方式 resultType 使用进行输出映射,只有查询出来的列名和pojo中的属性名一致,该列才可...

brianway
2016/02/28
131
0
Mybatis执行流程(一)

搭建一个简单的Mybatis+Maven项目 Maven依赖 代码 配置文件 通过SqlSessionFactory获取SqlSession 执行流程图 源码走读 获取reader 获取SqlSessionFactory build()方法 解析配置返回configu...

wjk_snail
2016/06/22
57
0
mybatis学习笔记(6)-输入映射

mybatis学习笔记(6)-输入映射 标签: mybatis [TOC] 本文主要讲解mybatis的输入映射。 通过parameterType指定输入参数的类型,类型可以是 简单类型 hashmap pojo的包装类型 传递pojo的包装对...

brianway
2016/02/28
105
0
【深入浅出MyBatis系列一】MyBatis入门

深入浅出MyBatis系列 【深入浅出MyBatis系列一】MyBatis入门 【深入浅出MyBatis系列二】配置简介(MyBatis源码篇) 【深入浅出MyBatis系列三】Mapper映射文件配置 【深入浅出MyBatis系列四】...

陶邦仁
2015/12/22
4.1K
0
Springmvc集成 mybatis

1.准备工作 1)创建user表以及插入数据 2 )mybatis相关jar引入 <dependency> </dependency> <!--mybatis spring 插件 --><dependency> </dependency> 3)工程异常类DemoException定义 路径地......

warlockssss
2016/09/13
26
1
springboot(六):如何优雅的使用mybatis

这两天启动了一个新项目因为项目组成员一直都使用的是mybatis,虽然个人比较喜欢jpa这种极简的模式,但是为了项目保持统一性技术选型还是定了 mybatis。到网上找了一下关于spring boot和myb...

纯洁的微笑
2016/11/07
5.7K
41

没有更多内容

加载失败,请刷新页面

加载更多

下一页

微信小程序Java登录流程(ssm实现具体功能和加解密隐私信息问题解决方案)

文章有不当之处,欢迎指正,如果喜欢微信阅读,你也可以关注我的微信公众号:好好学java,获取优质学习资源。 一、登录流程图 二、小程序客户端 doLogin:function(callback = () =>{}){let ...

公众号_好好学java
34分钟前
0
1
流利阅读笔记28-20180717待学习

“我不干了!” 英国脱欧大臣递交辞呈 雪梨 2018-07-17 1.今日导读 7 月 6 日,英国政府高官齐聚英国首相的官方乡间别墅——契克斯庄园,讨论起草了一份关于英国政府脱欧立场的白皮书。可是没...

aibinxiao
今天
6
0
OSChina 周二乱弹 —— 理解超算排名这个事,竟然超出了很多人的智商

Osc乱弹歌单(2018)请戳(这里) 【今日歌曲】 @-冰冰棒- :分享Ed Sheeran/Beyoncé的单曲《Perfect Duet (with Beyoncé)》 《Perfect Duet (with Beyoncé)》- Ed Sheeran/Beyoncé 手机...

小小编辑
今天
138
7
Android 获取各大音乐平台的真实下载地址

废话 电脑使用谷歌浏览器或者QQ浏览器的时候。。。。。。。说不清楚,还是看图吧 大概意思就是,只要网页上需要播放,只要能播放并且开始播放,这个过程就肯定会请求到相关的音乐资源,然后就...

她叫我小渝
今天
0
0
shell中的函数、shell中的数组、告警系统需求分析

shell中的函数 格式: 格式: function f_name() { command } 函数必须要放在最前面 示例1(用来打印参数) 示例2(用于定义加法) 示例3(用于显示IP) shell中的数组 shell中的数组1 定义数...

Zhouliang6
今天
2
0
用 Scikit-Learn 和 Pandas 学习线性回归

      对于想深入了解线性回归的童鞋,这里给出一个完整的例子,详细学完这个例子,对用scikit-learn来运行线性回归,评估模型不会有什么问题了。 1. 获取数据,定义问题     没有...

wangxuwei
今天
1
0
MAC安装MAVEN

一:下载maven压缩包(Zip或tar可选),解压压缩包 二:打开终端输入:vim ~/.bash_profile(如果找不到该文件新建一个:touch ./bash_profile) 三:输入i 四:输入maven环境变量配置 MAVEN_HO...

WALK_MAN
今天
0
0
33.iptables备份与恢复 firewalld的9个zone以及操作 service的操作

10.19 iptables规则备份和恢复 10.20 firewalld的9个zone 10.21 firewalld关于zone的操作 10.22 firewalld关于service的操作 10.19 iptables规则备份和恢复: ~1. 保存和备份iptables规则 ~2...

王鑫linux
今天
2
0
大数据教程(2.11):keeperalived+nginx高可用集群搭建教程

上一章节博主为大家介绍了目前大型互联网项目的系统架构体系,相信大家应该注意到其中很重要的一块知识nginx技术,在本节博主将为大家分享nginx的相关技术以及配置过程。 一、nginx相关概念 ...

em_aaron
今天
1
1
Apache Directory Studio连接Weblogic内置LDAP

OBIEE默认使用Weblogic内置LDAP管理用户及组。 要整理已存在的用户及组,此前办法是导出安全数据,文本编辑器打开认证文件,使用正则表达式获取用户及组的信息。 后来想到直接用Apache Dire...

wffger
今天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部