Mybaits延迟加载实现原理

1. 实现原理

通过动态代理的形式,创建了目标对象(User)的代理对象,拦截了对象的getting方法,在执行getting方法时,进入拦截器的invoke方法,当发现需要延迟加载时,会把之前存放好的SQL语句进行执行,并调用对象(User)调用set方法存值,然后调用对象本身的get方法取值

2. 验证过程

2.1 封装的结果集对象是代理对象?

当我们使用 fetchType="lazy" 属性开启延迟加载后 通过DEBUG看到 返回的是一个代理对象

img

2.2 如何生成的代理对象 ?

测试用例使用的接口代理开发 打断点跟进去

img

最终都会来到 org.apache.ibatis.session.defaults.DefaultSqlSession#selectList(java.lang.String, java.lang.Object, org.apache.ibatis.session.RowBounds, org.apache.ibatis.session.ResultHandler)

获取到当MapperStatemet后 接着通过 executor 调用 query 方法

executor 是一个接口 有六个实现类 此处是 CachingExecutor 实现类

img

img

org.apache.ibatis.executor.CachingExecutor#query(org.apache.ibatis.mapping.MappedStatement, java.lang.Object, org.apache.ibatis.session.RowBounds, org.apache.ibatis.session.ResultHandler)

boundSql 封装了 sql语句和 参数

key 用作二级缓存key

img

org.apache.ibatis.executor.CachingExecutor#query(org.apache.ibatis.mapping.MappedStatement, java.lang.Object, org.apache.ibatis.session.RowBounds, org.apache.ibatis.session.ResultHandler, org.apache.ibatis.cache.CacheKey, org.apache.ibatis.mapping.BoundSql)

此处的cache 用作二级缓存 同一个namespace共享

flushCacheIfRequired(ms) 是否需要清除缓存

如果开启了二级缓存 则将先走二级缓存 有结果直接返回 没有 再 调用 delegate.query 方法

img

org.apache.ibatis.executor.BaseExecutor#query(org.apache.ibatis.mapping.MappedStatement, java.lang.Object, org.apache.ibatis.session.RowBounds, org.apache.ibatis.session.ResultHandler, org.apache.ibatis.cache.CacheKey, org.apache.ibatis.mapping.BoundSql)

二级缓存没找到数据 走一级缓存 一级缓存也没数据 走数据库查询 queryFromDatabase

img

org.apache.ibatis.executor.BaseExecutor#queryFromDatabase

一级缓存是默认开启的 所以首先调用put方法放置占位符 后面会清除 将真正的数据放进去

img

org.apache.ibatis.executor.BatchExecutor#doQuery

org.apache.ibatis.executor.statement.PreparedStatementHandler#query

关注结果集封装 resultSetHandler.handleResultSets(ps)

img

org.apache.ibatis.executor.resultset.DefaultResultSetHandler#handleResultSets

org.apache.ibatis.executor.resultset.DefaultResultSetHandler#handleResultSet

org.apache.ibatis.executor.resultset.DefaultResultSetHandler#handleRowValues

org.apache.ibatis.executor.resultset.DefaultResultSetHandler#handleRowValuesForSimpleResultMap

org.apache.ibatis.executor.resultset.DefaultResultSetHandler#getRowValue(org.apache.ibatis.executor.resultset.ResultSetWrapper, org.apache.ibatis.mapping.ResultMap, java.lang.String)

img

org.apache.ibatis.executor.resultset.DefaultResultSetHandler#createResultObject(org.apache.ibatis.executor.resultset.ResultSetWrapper, org.apache.ibatis.mapping.ResultMap, org.apache.ibatis.executor.loader.ResultLoaderMap, java.lang.String)

从 configuration 中获取的 ProxyFactory 代理工厂默认是 JavassistProxyFactory

img

img

至此,使用JavassistProxyFactory成功创建了一个代理对象

2.3 延迟加载的实现

代理类走任何方法都会走 invoke 方法 org.apache.ibatis.executor.loader.javassist.JavassistProxyFactory.EnhancedResultObjectProxyImpl#invoke

img

判断当前方法不是 finalize 方法

private static final String FINALIZE_METHOD = "finalize";
private static final String WRITE_REPLACE_METHOD = "writeReplace";

lazyLoadTriggerMethods 在 configuration 中完成初始化 是一个 set集合

img

this.lazyLoadTriggerMethods = configuration.getLazyLoadTriggerMethods();

protected Set<string> lazyLoadTriggerMethods = new HashSet<>(Arrays.asList("equals", "clone", "hashCode", "toString"));</string>

如果是lazyLoadTriggerMethods 集合中的方法 则调用 lazyLoader.loadAll() 加载所有的延迟方法

如果方法是setter方法 则从 lazyLoader map集合中移除该属性的延迟加载

如果是get方法 判断 lazyLoader map中是否有对应的key,

img

有则调用 , 并从 loaderMap 中删除

img

#Java工程师##Java#
全部评论
感谢楼主分享
点赞 回复 分享
发布于 2022-08-17 14:18 陕西

相关推荐

06-11 14:15
已编辑
门头沟学院 后端
田心今心:打招呼改一下,把实习半年以上随时到岗放第一行,因为ssob的hr不点击看的时候只能看前面几个字,你前面几个字hr获取不到什么信息,也就不会点进来看
点赞 评论 收藏
分享
06-13 17:33
门头沟学院 Java
顺序不记了,大致顺序是这样的,有的相同知识点写分开了1.基本数据类型2.基本数据类型和包装类型的区别3.==和equals区别4.ArrayList与LinkedList区别5.hashmap底层原理,put操作时会发生什么6.说出几种树型数据结构7.B树和B+树区别8.jvm加载类机制9.线程池核心参数10.创建线程池的几种方式11.callable与runnable区别12.线程池怎么回收线程13.redis三剑客14.布隆过滤器原理,不要背八股,说说真正使用时遇到了问题没有(我说没有,不知道该怎么回答了)15.堆的内存结构16.自己在写项目时有没有遇见过oom,如何处理,不要背八股,根据真实经验,我说不会17.redis死锁怎么办,watchdog机制如何发现是否锁过期18.如何避免redis红锁19.一个表性别与年龄如何加索引20.自己的项目的QPS怎么测的,有没有真正遇到大数量表21.说一说泛型22.springboot自动装配原理23.springmvc与springboot区别24.aop使用过嘛?动态代理与静态代理区别25.spring循环依赖怎么解决26.你说用过es,es如何分片,怎么存的数据,1000万条数据怎么写入库中27.你说用limit,那么在数据量大之后,如何优化28.rabbitmq如何批次发送,批量读取,答了延迟队列和线程池,都不对29.计网知不知道smtp协议,不知道写了对不对,完全听懵了30.springcloud知道嘛?只是了解反问1.做什么的?短信服务,信息量能到千万级2.对我的建议,基础不错,但是不要只背八股,多去实际开发中理解。面试官人不错,虽然没露脸,但是中间会引导我回答问题,不会的也只是说对我要求没那么高。面完问我在济宁生活有没有困难,最快什么时候到,让人事给我聊薪资了。下午人事打电话,问我27届的会不会跑路,还在想办法如何使我不跑路,不想扣我薪资等。之后我再联系吧,还挺想去的😭,我真不跑路哥😢附一张河科大幽默大专图,科大就是大专罢了
查看30道真题和解析
点赞 评论 收藏
分享
评论
点赞
5
分享

创作者周榜

更多
牛客网
牛客网在线编程
牛客网题解
牛客企业服务