百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术分类 > 正文

十年之重修MyBatis原理

ztj100 2025-05-11 19:43 20 浏览 0 评论

弱小和无知并不是生存的障碍,傲慢才是。

---- ---- 面试者

总结

在MyBatis与Springboot整合之后,MyBatis的启动同样是依托SpringBoot的自动装载。主要涉及两个流程,其一是Mapper接口的注册过程,在申明@MapperScan()注解时,在beanDefinitions注册的过程中会触发Mapper的注册,在bean实例化时,Mapper接口会被实例化为一个MapperProxy代理类,其二是mapper.xml文件的加载,在自动装载MybatisAutoConfiguration时,会触发SqlSessionFactory的注入加载,期间会解析xml文件,并且将申明的sql与id以kv形式缓存。

在调用mapper接口时,会通过代理类MapperProxy进行调用,基于调用的接口名称找到要自信的SQL,然后层层包装调用,最后交由Druid进行执行(Druid持有连接,Mybatis包装到最后的PreparedStatement之后,交由Druid提交执行)。

MyBatis启动

Mapper接口注入

Bash
 // 我们在Application.class中添加的@MapperScan()注解,包含了一个@Import({MapperScannerRegistrar.class})
// 该类实现了ImportBeanDefinitionRegistrar接口,会自动调用registerBeanDefinitions方法进行注册bean
void registerBeanDefinitions(AnnotationMetadata annoMeta, AnnotationAttributes annoAttrs, BeanDefinitionRegistry registry, String beanName) {
  BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(MapperScannerConfigurer.class);
 	// ......
  // 这里自注册了MapperScannerConfigurer,是一个bean后置处理器类,
  // 初始化时会自动调用这个类的postProcessBeanDefinitionRegistry方法
  registry.registerBeanDefinition(beanName, builder.getBeanDefinition());
}

public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) {
  // ......
  scanner.registerFilters();
  // 这里进行扫描,直接调用了spring自带的扫描逻辑方法,并完成bean的扫描;
  // 然后修改Mapper接口,将beanClass设置为MapperFactoryBean工厂
  // 当业务层bean依赖了mapper,进行依赖初始化时,会基于MapperFactoryBean把依赖的mapper初始化一个代理实例
  scanner.scan(StringUtils.tokenizeToStringArray(this.basePackage, ",; \t\n"));
}

Mapper.xml文件扫描

Bash
// 通过自动装载逻辑,初始化MybatisAutoConfiguration时,由于SqlSessionFactory添加了@bean
// 在初始化SqlSessionFactory时,便会加载xml文件
// SqlSessionFactoryBean进行实例化时,调用了afterPropertiesSet,
// 然后对存储在mapperLocations的mapper文件进行解析,生成MappedStatement,结合id以kv形式存在了Configuration对象mappedStatements属性中
@Bean
@ConditionalOnMissingBean
public SqlSessionFactory sqlSessionFactory(DataSource dataSource) throws Exception {
   // 加载xml文件
  Resource[] mapperLocations = this.properties.resolveMapperLocations();
  if (!ObjectUtils.isEmpty(mapperLocations)) {
    factory.setMapperLocations(mapperLocations);
  }
 
}

MyBatis接口调用

// mppaer接口调用时,会初始化PlainMethodInvoker,构造函数里会根据接口名称去Configuration里找到对应的sql;
// 然后调用到invoke方法,MapperMethod示例里边两个属性,一个SqlCommand 一个MethodSignature
// SqlCommand包括接口名称和执行类型是select还是update等
// MethodSignature方法签名,包含接口返回类型和参数
private static class PlainMethodInvoker implements MapperMethodInvoker {
  private final MapperMethod mapperMethod;

  public PlainMethodInvoker(MapperMethod mapperMethod) {
    this.mapperMethod = mapperMethod;
  }

  public Object invoke(Object proxy, Method method, Object[] args, SqlSession sqlSession) throws Throwable {
    return this.mapperMethod.execute(sqlSession, args);
  }
}

// 进行sql类型判定,这里以Select为例
public Object execute(SqlSession sqlSession, Object[] args) {
  Object result;
  switch (this.command.getType()) {
    case INSERT:
      Object param = this.method.convertArgsToSqlCommandParam(args);
      result = this.rowCountResult(sqlSession.insert(this.command.getName(), param));
      break;
    case UPDATE:
      Object param = this.method.convertArgsToSqlCommandParam(args);
      result = this.rowCountResult(sqlSession.update(this.command.getName(), param));
      break;
    case DELETE:
      Object param = this.method.convertArgsToSqlCommandParam(args);
      result = this.rowCountResult(sqlSession.delete(this.command.getName(), param));
      break;
    case SELECT:
      if (this.method.returnsVoid() && this.method.hasResultHandler()) {
        this.executeWithResultHandler(sqlSession, args);
        result = null;
      } else if (this.method.returnsMany()) {
        result = this.executeForMany(sqlSession, args);
      } else if (this.method.returnsMap()) {
        result = this.executeForMap(sqlSession, args);
      } else if (this.method.returnsCursor()) {
        result = this.executeForCursor(sqlSession, args);
      } else {
        Object param = this.method.convertArgsToSqlCommandParam(args);
        result = sqlSession.selectOne(this.command.getName(), param);
        if (this.method.returnsOptional() && (result == null || !this.method.getReturnType().equals(result.getClass()))) {
          result = Optional.ofNullable(result);
        }
      }
      break;
    case FLUSH:
      result = sqlSession.flushStatements();
      break;
    default:
      throw new BindingException("Unknown execution method for: " + this.command.getName());
  }

  if (result == null && this.method.getReturnType().isPrimitive() && !this.method.returnsVoid()) {
    throw new BindingException("Mapper method '" + this.command.getName() + "' attempted to return null from a method with a primitive return type (" + this.method.getReturnType() + ").");
  } else {
    return result;
  }
}

// sqlsession持有defaultsqlsession,进一步执行查询
private <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds, ResultHandler handler) {
  List var6;
  try {
    // 再次从Configuration中,找出接口对应的MappedStatement
    MappedStatement ms = this.configuration.getMappedStatement(statement);
    this.dirty |= ms.isDirtySelect();
    // 交由执行器执行
    var6 = this.executor.query(ms, this.wrapCollection(parameter), rowBounds, handler);
  } catch (Exception e) {
    throw ExceptionFactory.wrapException("Error querying database.  Cause: " + e, e);
  } finally {
    ErrorContext.instance().reset();
  }

  return var6;
}
// 调用PreparedStatementHandler 的query方法,期间会构造statement = DruidPooledPreparedStatement
// 由连接池druid包装的PreparedStatement
public <E> List<E> query(Statement statement, ResultHandler resultHandler) throws SQLException {
  PreparedStatement ps = (PreparedStatement)statement;
  // 这里边执行的就是jdbc那一套了
  ps.execute();
  // 处理返回结果
  return this.resultSetHandler.handleResultSets(ps);
}

举杯邀明月,对影成三人。

相关推荐

SpringBoot整合SpringSecurity+JWT

作者|Sans_https://juejin.im/post/5da82f066fb9a04e2a73daec一.说明SpringSecurity是一个用于Java企业级应用程序的安全框架,主要包含...

「计算机毕设」一个精美的JAVA博客系统源码分享

前言大家好,我是程序员it分享师,今天给大家带来一个精美的博客系统源码!可以自己买一个便宜的云服务器,当自己的博客网站,记录一下自己学习的心得。开发技术博客系统源码基于SpringBoot,shiro...

springboot教务管理系统+微信小程序云开发附带源码

今天给大家分享的程序是基于springboot的管理,前端是小程序,系统非常的nice,不管是学习还是毕设都非常的靠谱。本系统主要分为pc端后台管理和微信小程序端,pc端有三个角色:管理员、学生、教师...

SpringBoot+LayUI后台管理系统开发脚手架

源码获取方式:关注,转发之后私信回复【源码】即可免费获取到!项目简介本项目本着避免重复造轮子的原则,建立一套快速开发JavaWEB项目(springboot-mini),能满足大部分后台管理系统基础开...

Spring Boot的Security安全控制——认识SpringSecurity!

SpringBoot的Security安全控制在Web项目开发中,安全控制是非常重要的,不同的人配置不同的权限,这样的系统才安全。最常见的权限框架有Shiro和SpringSecurity。Shi...

前同事2024年接私活已入百万,都是用这几个开源的SpringBoot项目

前言不得不佩服SpringBoot的生态如此强大,今天给大家推荐几款优秀的后台管理系统,小伙伴们再也不用从头到尾撸一个项目了。SmartAdmin...

值得学习的15 个优秀开源的 Spring Boot 学习项目

SpringBoot算是目前Java领域最火的技术栈了,除了书呢?当然就是开源项目了,今天整理15个开源领域非常不错的SpringBoot项目供大家学习,参考。高富帅的路上只能帮你到这里了,...

开发企业官网就用这个基于SpringBoot的CMS系统,真香

前言推荐这个项目是因为使用手册部署手册非常...

2021年超详细的java学习路线总结—纯干货分享

本文整理了java开发的学习路线和相关的学习资源,非常适合零基础入门java的同学,希望大家在学习的时候,能够节省时间。纯干货,良心推荐!第一阶段:Java基础...

jeecg-boot学习总结及使用心得(jeecgboot简单吗)

jeecg-boot学习总结及使用心得1.jeecg-boot是一个真正前后端分离的模版项目,便于二次开发,使用的都是较流行的新技术,后端技术主要有spring-boot2.x、shiro、Myb...

后勤集团原料管理系统springboot+Layui+MybatisPlus+Shiro源代码

本项目为前几天收费帮学妹做的一个项目,JavaEEJSP项目,在工作环境中基本使用不到,但是很多学校把这个当作编程入门的项目来做,故分享出本项目供初学者参考。一、项目描述后勤集团原料管理系统spr...

白卷开源SpringBoot+Vue的前后端分离入门项目

简介白卷是一个简单的前后端分离项目,主要采用Vue.js+SpringBoot技术栈开发。除了用作入门练习,作者还希望该项目可以作为一些常见Web项目的脚手架,帮助大家简化搭建网站的流程。...

Spring Security 自动踢掉前一个登录用户,一个配置搞定

登录成功后,自动踢掉前一个登录用户,松哥第一次见到这个功能,就是在扣扣里边见到的,当时觉得挺好玩的。自己做开发后,也遇到过一模一样的需求,正好最近的SpringSecurity系列正在连载,就结...

收藏起来!这款开源在线考试系统,我爱了

大家好,我是为广大程序员兄弟操碎了心的小编,每天推荐一个小工具/源码,装满你的收藏夹,每天分享一个小技巧,让你轻松节省开发效率,实现不加班不熬夜不掉头发,是我的目标!今天小编推荐一款基于Spr...

Shiro框架:认证和授权原理(shiro权限认证流程)

优质文章,及时送达前言Shiro作为解决权限问题的常用框架,常用于解决认证、授权、加密、会话管理等场景。本文将对Shiro的认证和授权原理进行介绍:Shiro可以做什么?、Shiro是由什么组成的?举...

取消回复欢迎 发表评论: