mybatis延迟加载原理(mybatis工作原理及流程)

1. 目的

本文主要解读MyBatis 延迟加载实现原理

2. 延迟加载如何使用

Setting 参数配置

设置参数描述有效值默认值lazyLoadingEnabled延迟加载的全局开关。当开启时,所有关联对象都会延迟加载。 特定关联关系中可通过设置fetchType属性来覆盖该项的开关状态。true、
falsefalseaggressiveLazyLoading当开启时,任何方法的调用都会加载该对象的所有属性。否则,每个属性会按需加载(参考lazyLoadTriggerMethods).true、falsefalse (true in ≤3.4.1)lazyLoadTriggerMethods指定哪个对象的方法触发一次延迟加载。用逗号分隔的方法列表。equals,clone,hashCode,toString

配置


Mapper 配置

 select * from users where id = #{id}
 

User 实体对象

public class User implements Cloneable {
 private Integer id;
 private String name;
 private User lazy1;
 private User lazy2;
 private List lazy3;
 public int setterCounter;
 
 省略...
 }

执行解析:

  • 调用getUser查询数据,从查询结果集解析数据到User对象,当数据解析到lazy1,lazy2,lazy3判断需要执行关联查询
  • lazyLoadingEnabled=true,将创建lazy1,lazy2,lazy3对应的Proxy延迟执行对象lazyLoader,并保存
  • 当逻辑触发lazyLoadTriggerMethods 对应的方法(equals,clone,hashCode,toString)则执行延迟加载
  • 如果aggressiveLazyLoading=true,只要触发到对象任何的方法,就会立即加载所有属性的加载

3. 延迟加载原理实现

延迟加载主要是通过动态代理的形式实现,通过代理拦截到指定方法,执行数据加载。

MyBatis延迟加载主要使用:Javassist,Cglib实现,类图展示:

mybatis延迟加载原理(mybatis工作原理及流程)

4. 延迟加载源码解析

Setting 配置加载:

public class Configuration {
/** aggressiveLazyLoading:
 * 当开启时,任何方法的调用都会加载该对象的所有属性。否则,每个属性会按需加载(参考lazyLoadTriggerMethods).
 * 默认为true
 * */
 protected boolean aggressiveLazyLoading;
 /**
 * 延迟加载触发方法
 */
 protected Set lazyLoadTriggerMethods = new HashSet(Arrays.asList(new String[] { "equals", "clone", "hashCode", "toString" }));
 /** 是否开启延迟加载 */
 protected boolean lazyLoadingEnabled = false;
 
 /**
 * 默认使用Javassist代理工厂
 * @param proxyFactory
 */
 public void setProxyFactory(ProxyFactory proxyFactory) {
 if (proxyFactory == null) {
 proxyFactory = new JavassistProxyFactory();
 }
 this.proxyFactory = proxyFactory;
 }
 
 //省略...
}

延迟加载代理对象创建

DefaultResultSetHandler

//#mark 创建结果对象
 private Object createResultObject(ResultSetWrapper rsw, ResultMap resultMap, ResultLoaderMap lazyLoader, String columnPrefix) throws SQLException {
 this.useConstructorMappings = false; // reset previous mapping result
 final List> constructorArgTypes = new ArrayList>();
 final List constructorArgs = new ArrayList();
 //#mark 创建返回的结果映射的真实对象
 Object resultObject = createResultObject(rsw, resultMap, constructorArgTypes, constructorArgs, columnPrefix);
 if (resultObject != null && !hasTypeHandlerForResultObject(rsw, resultMap.getType())) {
 final List propertyMappings = resultMap.getPropertyResultMappings();
 for (ResultMapping propertyMapping : propertyMappings) {
 // issue gcode #109 && issue #149 判断属性有没配置嵌套查询,如果有就创建代理对象
 if (propertyMapping.getNestedQueryId() != null && propertyMapping.isLazy()) {
 //#mark 创建延迟加载代理对象
 resultObject = configuration.getProxyFactory().createProxy(resultObject, lazyLoader, configuration, objectFactory, constructorArgTypes, constructorArgs);
 break;
 }
 }
 }
 this.useConstructorMappings = resultObject != null && !constructorArgTypes.isEmpty(); // set current mapping result
 return resultObject;
 }

代理功能实现

由于Javasisst和Cglib的代理实现基本相同,这里主要介绍Javasisst

ProxyFactory接口定义

public interface ProxyFactory {

void setProperties(Properties properties);

/**

* 创建代理

* @param target 目标结果对象

* @param lazyLoader 延迟加载对象

* @param configuration 配置

* @param objectFactory 对象工厂

* @param constructorArgTypes 构造参数类型

* @param constructorArgs 构造参数值

* @return

*/

Object createProxy(Object target, ResultLoaderMap lazyLoader, Configuration configuration, ObjectFactory objectFactory, List> constructorArgTypes, ListconstructorArgs);

}

JavasisstProxyFactory实现

public class JavassistProxyFactory implements org.apache.ibatis.executor.loader.ProxyFactory {
 
 /**
 * 接口实现
 * @param target 目标结果对象
 * @param lazyLoader 延迟加载对象
 * @param configuration 配置
 * @param objectFactory 对象工厂
 * @param constructorArgTypes 构造参数类型
 * @param constructorArgs 构造参数值
 * @return
 */
 @Override
 public Object createProxy(Object target, ResultLoaderMap lazyLoader, Configuration configuration, ObjectFactory objectFactory, List> constructorArgTypes, List constructorArgs) {
 return EnhancedResultObjectProxyImpl.createProxy(target, lazyLoader, configuration, objectFactory, constructorArgTypes, constructorArgs);
 }
 //省略...
 
 /**
 * 代理对象实现,核心逻辑执行
 */
 private static class EnhancedResultObjectProxyImpl implements MethodHandler {
 
 /**
 * 创建代理对象
 * @param type
 * @param callback
 * @param constructorArgTypes
 * @param constructorArgs
 * @return
 */
 static Object crateProxy(Class> type, MethodHandler callback, List> constructorArgTypes, List constructorArgs) {
 ProxyFactory enhancer = new ProxyFactory();
 enhancer.setSuperclass(type);
 try {
 //通过获取对象方法,判断是否存在该方法
 type.getDeclaredMethod(WRITE_REPLACE_METHOD);
 // ObjectOutputStream will call writeReplace of objects returned by writeReplace
 if (log.isDebugEnabled()) {
 log.debug(WRITE_REPLACE_METHOD + " method was found on bean " + type + ", make sure it returns this");
 }
 } catch (NoSuchMethodException e) {
 //没找到该方法,实现接口
 enhancer.setInterfaces(new Class[]{WriteReplaceInterface.class});
 } catch (SecurityException e) {
 // nothing to do here
 }
 Object enhanced;
 Class>[] typesArray = constructorArgTypes.toArray(new Class[constructorArgTypes.size()]);
 Object[] valuesArray = constructorArgs.toArray(new Object[constructorArgs.size()]);
 try {
 //创建新的代理对象
 enhanced = enhancer.create(typesArray, valuesArray);
 } catch (Exception e) {
 throw new ExecutorException("Error creating lazy proxy. Cause: " + e, e);
 }
 //设置代理执行器
 ((Proxy) enhanced).setHandler(callback);
 return enhanced;
 }
 
 
 /**
 * 代理对象执行
 * @param enhanced 原对象
 * @param method 原对象方法
 * @param methodProxy 代理方法
 * @param args 方法参数
 * @return
 * @throws Throwable
 */
 @Override
 public Object invoke(Object enhanced, Method method, Method methodProxy, Object[] args) throws Throwable {
 final String methodName = method.getName();
 try {
 synchronized (lazyLoader) {
 if (WRITE_REPLACE_METHOD.equals(methodName)) { 
 //忽略暂未找到具体作用
 Object original;
 if (constructorArgTypes.isEmpty()) {
 original = objectFactory.create(type);
 } else {
 original = objectFactory.create(type, constructorArgTypes, constructorArgs);
 }
 PropertyCopier.copyBeanProperties(type, enhanced, original);
 if (lazyLoader.size() > 0) {
 return new JavassistSerialStateHolder(original, lazyLoader.getProperties(), objectFactory, constructorArgTypes, constructorArgs);
 } else {
 return original;
 }
 } else {
 //延迟加载数量大于0
 if (lazyLoader.size() > 0 && !FINALIZE_METHOD.equals(methodName)) {
 //aggressive 一次加载性所有需要要延迟加载属性或者包含触发延迟加载方法
 if (aggressive || lazyLoadTriggerMethods.contains(methodName)) {
 log.debug("==> laze lod trigger method:" + methodName + ",proxy method:" + methodProxy.getName() + " class:" + enhanced.getClass());
 //一次全部加载
 lazyLoader.loadAll();
 } else if (PropertyNamer.isSetter(methodName)) {
 //判断是否为set方法,set方法不需要延迟加载
 final String property = PropertyNamer.methodToProperty(methodName);
 lazyLoader.remove(property);
 } else if (PropertyNamer.isGetter(methodName)) {
 final String property = PropertyNamer.methodToProperty(methodName);
 if (lazyLoader.hasLoader(property)) {
 //延迟加载单个属性
 lazyLoader.load(property);
 log.debug("load one :" + methodName);
 }
 }
 }
 }
 }
 return methodProxy.invoke(enhanced, args);
 } catch (Throwable t) {
 throw ExceptionUtil.unwrapThrowable(t);
 }
 }
 }

5. 注意事项

  1. IDEA调试问题 当配置aggressiveLazyLoading=true,在使用IDEA进行调试的时候,如果断点打到代理执行逻辑当中,你会发现延迟加载的代码永远都不能进入,总是会被提前执行。 主要产生的原因在aggressiveLazyLoading,因为在调试的时候,IDEA的Debuger窗体中已经触发了延迟加载对象的方法。

如图:调试还未进入lazyLoader.loadAll(); 实际日志已经显示延迟加载已经完成,代码与日志通过颜色区分。

秒鲨号所有文章资讯、展示的图片素材等内容均为注册用户上传(部分报媒/平媒内容转载自网络合作媒体),仅供学习参考。用户通过本站上传、发布的任何内容的知识产权归属用户或原始著作权人所有。如有侵犯您的版权,请联系我们反馈!本站将在三个工作日内改正。
(0)

大家都在看

  • 咖啡起源于哪个国家(咖啡最早起源于哪个国家)

    咖啡是咖啡豆经过烘焙和研磨后冲泡而成的带有咖啡因的饮料,咖啡作为世界三大饮料之一,其在国内也越来越流行,星巴克、瑞幸等咖啡巨头在国内门店也越开越多;拿铁、卡布奇诺、玛奇朵…一个个耳…

    2022年3月17日 投稿
  • 创业人物故事(名人创业故事)

    来源:四川日报-川观新闻 川观新闻记者 樊邦平 对于眉山市东坡区多悦镇正山口村的返乡创业女孩张富熔而言,2021年12月8日这一天本该是一个普通的日子,但在这天上午9时左右,一则简…

    2022年8月6日 投稿
  • 40万存银行一年利息多少(40万存银行死期一年利息多少钱)

    跟着年纪的增加,咱们手中的存款越来越多,理财就显得很重要了,咱们都知道假如不去打理自己的钱,遇到通货膨胀的时分,钱是会价值降低的,其实理财并没有咱们幻想的那么难,只需有心必定是能够…

    2022年5月21日
  • 李靓蕾家世简历如何(她的家世背景如何)

    给天王王力宏生了三个孩子携手走过8年婚姻路的李靓蕾实在是忍受不了了,发表了5000字长文怒揭掉王力宏的伪善面具,约炮、召妓、妈宝男、父亲角色缺失通通给抖了出来,盖世英雄王力宏瞬间人…

    2022年7月31日
  • 手机游戏排行榜前十名(最新手游排行榜前十名)

    一转眼已到2021年12月份,相信这一年玩手游的玩家又增加了不少,作为热爱手游的玩家,总会关注一些游戏榜单,而整个2021年不管是下载榜还是热搜榜,很多手游常年霸榜,比如《王者荣耀…

    2022年6月23日 投稿
  • 股票k线图入门图解(k线图解大全)

    HARMONY,鸿蒙的英文说法,意为和谐,在美国不断打压华为的大时代背景下,华为以“和谐”来命名鸿蒙,彰显的是东方哲学与智慧。润和软件竖起妖股大旗,5天里4个20cm涨停,股价暴涨…

    2022年3月23日 投稿
  • 黄金哪个牌子好(黄金哪个牌子最好最纯)

    我有幸在周大福地区做了13年品牌管理,在六福集团同属品牌做了2年区域营销工作,还在金大福总部做过大半年工作。这中间也对无数个珠宝品牌做过市调及暗访,当然也包括周生生、周六福、金六福…

    2022年5月3日 投稿
  • 小超市怎么开(如何开小超市或便利店)

    下面分几点来说明一下详细的开店流程: 一、办证 先去工商部门申请《名称预先核准通知书》,然后继续在工商局申请《食品流通许可证》,同时去烟草局办《烟草零售经营许可证》,办好这些证件之…

    2022年4月22日
  • 花呗分期付款利息是多少(花呗分期付款利息高吗)

    支付宝的花呗,是蚂蚁集团推出的一款消费类信贷产品。当我们开通花呗后,就可以获得一定的消费额度,可以享受先消费后还款的服务。 花呗类似于银行的信用卡,也有着免息还款期,当我们产生消费…

    2022年4月16日
  • 橙子软文:问答营销都适合哪些行业来做

    问答营销属于互动营销的方式,通过第三方口碑进行品牌营销,营销的方式既能与潜在消费者产生互动也可以植入商家广告,是做品牌口碑,营销互动很好的方式之一,通过在问答平台上搜索行业相关的问…

    2022年3月25日
品牌推广 在线咨询
返回顶部