脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → mybatis-plus查询

mybatis-plus查询源码详解

 更新时间：2022年03月02日 11:54:07   作者：这个世界太疯狂了  
这篇文章主要介绍了mybatis-plus查询源码解读,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下

配置详情

pom.xml

dependency>
     <groupId>com.baomidou</groupId>
     <artifactId>mybatis-plus-boot-starter</artifactId>
     <version>3.4.1</version>
 </dependency>

mapper

public interface GenTableMapper extends BaseMapper<GenTable> {
}

测试类

@RunWith(SpringRunner.class)
@SpringBootTest(classes = GendemoApplication.class)
public class BlockqueueTestDemo {
    @Autowired
    GenTableMapper genTableMapper;
    @Test
    public void test(){
        List<GenTable> genTables = 
        genTableMapper.selectList(new QueryWrapper<>());
    }
}

debug流程

1.发现 genTableMapper 是一个代理对象类型。

在这里插入图片描述

2.进入代理对象MybatisMapperProxy , 调用其invoke 方法，方法的Class类型为BaseMapper.selectList()

在这里插入图片描述

3.其中cachedInvoker()方法会返回一个PlainMethodInvoker ,它重写了MapperMethodInvoker 接口的invoke()方法

在这里插入图片描述

4.最终会调用MybatisMapperMethod的execute()方法

在这里插入图片描述

public class MybatisMapperMethod {
    public Object execute(SqlSession sqlSession, Object[] args) {
        Object result;
        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);
                    // TODO 这里下面改了
                    if (IPage.class.isAssignableFrom(method.getReturnType())) {
                        result = executeForIPage(sqlSession, args);
                        // TODO 这里上面改了
                    } else {
                        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;
    }
}

5.这是经过判断会进入executeForMany(sqlSession, args)方法，此时方法和参数都显示出来了。sqlSession的类型是SqlSessionTemplate , 为什么要注意这个 sqlSession的类型？因为SqlSession是一个接口，有很多实现类，有时候我们并不知道到底调用了哪个实现类的selectList()方法，这个时候我们看类型就知道了，就可以进入SqlSessionTemplate类，找到selectList()打上断点，debug就过来了。

在这里插入图片描述

6.利用同样的方法，又调用了DefaultSqlSession的selectList()方法。

在这里插入图片描述


7.来到DefaultSqlSession的selectList() 方法中，此时已经进入到mybatis的源码范围了。executor的类型是MybatisCachingExecutor

在这里插入图片描述

8.此时要注意MybatisCachingExecutor 代理类的handler是一个Plugin

在这里插入图片描述

在这里插入图片描述

9.因为我使用到了分页插件，所以会来到com.github.pagehelperPageInterceptor中

在这里插入图片描述

10.由MybatisCachingExecutor来执行查询

在这里插入图片描述

11.MybatisCachingExecutor 委派 BaseExecutor 执行查询

在这里插入图片描述

在这里插入图片描述

12.最终委派到PreparedStatementHandler来处理

在这里插入图片描述

13.最后由DefaultResultSetHandler来封装结果集

@Override
  public List<Object> handleResultSets(Statement stmt) throws SQLException {
    ErrorContext.instance().activity("handling results").object(mappedStatement.getId());

    final List<Object> multipleResults = new ArrayList<>();
    int resultSetCount = 0;
    ResultSetWrapper rsw = getFirstResultSet(stmt);
    List<ResultMap> resultMaps = mappedStatement.getResultMaps();
    int resultMapCount = resultMaps.size();
    validateResultMapsCount(rsw, resultMapCount);
    while (rsw != null && resultMapCount > resultSetCount) {
      ResultMap resultMap = resultMaps.get(resultSetCount);
      handleResultSet(rsw, resultMap, multipleResults, null);
      rsw = getNextResultSet(stmt);
      cleanUpAfterHandlingResultSet();
      resultSetCount++;
    }
    String[] resultSets = mappedStatement.getResultSets();
    if (resultSets != null) {
      while (rsw != null && resultSetCount < resultSets.length) {
        ResultMapping parentMapping = nextResultMaps.get(resultSets[resultSetCount]);
        if (parentMapping != null) {
          String nestedResultMapId = parentMapping.getNestedResultMapId();
          ResultMap resultMap = configuration.getResultMap(nestedResultMapId);
          handleResultSet(rsw, resultMap, null, parentMapping);
        }
        rsw = getNextResultSet(stmt);
        cleanUpAfterHandlingResultSet();
        resultSetCount++;
      }
    return collapseSingleResultList(multipleResults);
  }

总结

为什么要一层一层的封装？一层一层的委派？
这里面和缓存有关，有兴趣的可以自己了解一下。

下一篇打算记录一下 mybatis-plus 的自动配置过程，有兴趣的可以持续关注一下。
文中有错误的地方不吝赐教谢谢。

到此这篇关于mybatis-plus查询源码走读的文章就介绍到这了,更多相关mybatis-plus查询内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • Mybatis的mapper.xml中if标签test判断的用法说明

    Mybatis的mapper.xml中if标签test判断的用法说明

    这篇文章主要介绍了Mybatis的mapper.xml中if标签test判断的用法说明，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-06-06
  • idea中方法、注释、导入类折叠或是展开的设置方法

    idea中方法、注释、导入类折叠或是展开的设置方法

    这篇文章主要介绍了idea中方法、注释、导入类折叠或是展开的设置,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2023-04-04
  • Java实现多用户注册登录的幸运抽奖

    Java实现多用户注册登录的幸运抽奖

    这篇文章主要为大家详细介绍了Java实现多用户注册登录的幸运抽奖，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2020-11-11
  • maven依赖版本没有按照最短路径原则生效的解决方案

    maven依赖版本没有按照最短路径原则生效的解决方案

    这篇文章主要介绍了maven依赖版本没有生效的解决方案，帮助大家更好的理解和使用springboot框架，感兴趣的朋友可以了解下
    2021-01-01
  • Java获取泛型实际类型的方法详解

    Java获取泛型实际类型的方法详解

    这篇文章主要介绍了Java获取泛型实际类型的方法详解,泛型,即“参数化类型”,一提到参数,最熟悉的就是定义方法时有形参列表,普通方法的形参列表中,每个形参的数据类型是确定的,而变量是一个参数,需要的朋友可以参考下
    2023-11-11
  • Netty中解码器的作用及实现详解

    Netty中解码器的作用及实现详解

    这篇文章主要介绍了Netty中解码器的作用及实现详解,本章我们只需要让客户端发送消息的时候循环发送100次,服务端不变,看看服务端是不是接收到了100条消息,需要的朋友可以参考下
    2023-12-12
  • Java异常处理操作实例小结

    Java异常处理操作实例小结

    这篇文章主要介绍了Java异常处理操作,结合实例形式总结分析了java异常处理常见操作情况与相关处理技巧,需要的朋友可以参考下
    2019-07-07
  • Java流形式返回前端的实现示例

    Java流形式返回前端的实现示例

    ​ Java后端开发项目时，需要给前端传一些数据，本文主要介绍了Java流形式返回前端的实现示例，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2023-04-04
  • Java Map接口及其实现类原理解析

    Java Map接口及其实现类原理解析

    这篇文章主要介绍了Java Map接口及其实现类原理解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-03-03
  • java编程之xpath介绍

    java编程之xpath介绍

    这篇文章主要介绍了java编程之xpath介绍，具有一定借鉴价值,需要的朋友可以参考下
    2017-12-12

最新评论