当前位置：首页 > news >正文

【12.MyBatis源码剖析与架构实战】11.嵌套查询循环引⽤源码剖析

news 2026/4/28 3:33:17

MyBatis 嵌套查询循环引用源码深度剖析（含流程图）

在 MyBatis 中，当两个实体相互引用（如User↔Address），且双方都通过<association>的select属性配置了嵌套查询时，若没有特殊处理，查询时会发生无限递归，最终导致栈溢出。MyBatis 通过一级缓存（localCache）和ResultLoaderMap加载状态标记巧妙地解决了循环引用问题，确保在同一个SqlSession内，同一个对象只创建一次，并且循环引用能够正确建立。

一、循环引用示例

考虑以下实体与映射：

publicclassUser{privateLongid;privateStringname;privateAddressaddress;// 持有 Address}publicclassAddress{privateLongid;privateStringstreet;privateUseruser;// 持有 User}

Mapper XML：

<!-- UserMapper.xml --><resultMapid="userMap"type="User"><idcolumn="id"property="id"/><resultcolumn="name"property="name"/><associationproperty="address"column="address_id"select="com.example.AddressMapper.selectById"fetchType="eager"/></resultMap><!-- AddressMapper.xml --><resultMapid="addressMap"type="Address"><idcolumn="id"property="id"/><resultcolumn="street"property="street"/><associationproperty="user"column="user_id"select="com.example.UserMapper.selectById"fetchType="eager"/></resultMap>

当调用UserMapper.selectById(1)时，会触发以下调用链：

查询User（id=1, address_id=100）
加载User.address→ 执行AddressMapper.selectById(100)
查询Address（id=100, user_id=1）
加载Address.user→ 执行UserMapper.selectById(1)，回到步骤1

若不加控制，将无限循环。

二、MyBatis 解决循环引用的核心机制

2.1 一级缓存（`localCache`）

每个SqlSession有一个PerpetualCache实例（存储在BaseExecutor.localCache）。
当从ResultSet构建一个对象时，会根据主键生成CacheKey，并在构建完成后放入localCache。
后续任何查询（包括嵌套查询）在构建相同主键的对象时，会优先从localCache中获取，而不是重新创建。

2.2`createRowKey`：生成对象缓存键

DefaultResultSetHandler.createRowKey方法根据ResultMap中配置的<id>列（或如果无显式 id，则使用所有列），从当前ResultSet行提取值，生成唯一的CacheKey。

privateCacheKeycreateRowKey(ResultMapresultMap,ResultSetWrapperrsw,StringcolumnPrefix)throwsSQLException{finalCacheKeycacheKey=newCacheKey();finalList<ResultMapping>idMappings=resultMap.getIdResultMappings();for(ResultMappingidMapping:idMappings){finalStringcolumn=prependPrefix(idMapping.getColumn(),columnPrefix);if(column!=null){finalObjectvalue=getColumnValue(rsw,idMapping.getJavaType(),column);cacheKey.update(column);cacheKey.update(value);}}returncacheKey;}

2.3`getRowValue`中的缓存复用

在DefaultResultSetHandler.getRowValue中，会首先尝试从localCache获取已创建的对象：

privateObjectgetRowValue(ResultSetWrapperrsw,ResultMapresultMap,StringcolumnPrefix,ObjectpartialValue,ResultMappingparentMapping)throwsSQLException{finalStringresultMapId=resultMap.getId();finalCacheKeyrowKey=createRowKey(resultMap,rsw,columnPrefix);// 尝试从一级缓存获取ObjectrowValue=partialValue!=null?partialValue:localCache.getObject(rowKey);if(rowValue!=null&&rowValue!=EXECUTION_PLACEHOLDER){// 如果已经存在，直接返回（避免重复创建）returnrowValue;}// 否则创建对象并放入缓存...rowValue=createResultObject(rsw,resultMap,lazyLoader,columnPrefix);if(rowKey!=null){localCache.putObject(rowKey,rowValue);}// 填充属性...returnrowValue;}