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

Mybatis执行流程以及整合Spring源码分析

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

一,简述

mybatis的作用就是操作数据库,其实就是封装参数,生成sql,执行sql,封装结果,其实基本就是这几个大的步骤,mybatis和spring是怎么整合的呢,以及如何一步一步执行的,具体请看下面原理分析

二,源码分析

2.1:SqlSessionFactoryBean

具体是在mybatis-spring整合包中,SqlSessionFactoryBean是加载mybatis配置文件以及生成sqlSession的入口

2.2:FactoryBean

spring源码有所了解的应该清楚这个factoryBean是一个生成特殊复杂的bean,以及和beanFactory的区:别,factoryBean中的一个重要的方法就是getObject方法,其实就是根据这个方法返回一个特殊的自定义的bean对象,而且bean创建的时候,会创建一个&sqlSessionFactoryBean 和sqlSessionFactory对象,就是会创建本身bean携带&和getObject返回的对象,而且getObject是使用的时候才会被调用的,使用的时候才会创建这个bean交给spring来管理

调用getObejct获取sqlsessionfactory对象

    public SqlSessionFactory FactoryBean() throws Exception {
        if (this.sqlSessionFactory == null) {
            this.afterPropertiesSet();
        }

        return this.sqlSessionFactory;
    }

创建一个DefaultSqlSessionFactory,所以在何时创建的,就在这里

以上就是和spring结合情况下,创建出来sqlSessionFactory的过程,其实就是创建一个SqlSessionFactoryBean对象,然后调用getObject的方法,就可以做到加载mybatis的配置以及数据的封装的,以及获取一个sqlSessionFactory对象,交个spring来管理

2.3:Spring中创建SqlSessionFactory对象

创建一个SqlSessionFactory,具体代码执行的逻辑如下,其实就是做了一些数据的封装,并调用getObject的方法,然后交给spring管理

2.4:spring-boot创建SqlSessionFactory对象

MybatisAutoConfiguration

    @Bean
    @ConditionalOnMissingBean
    public SqlSessionFactory sqlSessionFactory(DataSource dataSource) throws Exception {
      //还是这个对象SqlSessionFactoryBean 来处理的,最后还是getObejct获取的
        SqlSessionFactoryBean factory = new SqlSessionFactoryBean();
        factory.setDataSource(dataSource);
        factory.setVfs(SpringBootVFS.class);
        if (StringUtils.hasText(this.properties.getConfigLocation())) {
            factory.setConfigLocation(this.resourceLoader.getResource(this.properties.getConfigLocation()));
        }

        this.applyConfiguration(factory);
        if (this.properties.getConfigurationProperties() != null) {
            factory.setConfigurationProperties(this.properties.getConfigurationProperties());
        }

        if (!ObjectUtils.isEmpty(this.interceptors)) {
            factory.setPlugins(this.interceptors);
        }

        if (this.databaseIdProvider != null) {
            factory.setDatabaseIdProvider(this.databaseIdProvider);
        }

        if (StringUtils.hasLength(this.properties.getTypeAliasesPackage())) {
            factory.setTypeAliasesPackage(this.properties.getTypeAliasesPackage());
        }

        if (this.properties.getTypeAliasesSuperType() != null) {
            factory.setTypeAliasesSuperType(this.properties.getTypeAliasesSuperType());
        }

        if (StringUtils.hasLength(this.properties.getTypeHandlersPackage())) {
            factory.setTypeHandlersPackage(this.properties.getTypeHandlersPackage());
        }

        if (!ObjectUtils.isEmpty(this.typeHandlers)) {
            factory.setTypeHandlers(this.typeHandlers);
        }

        if (!ObjectUtils.isEmpty(this.properties.resolveMapperLocations())) {
            factory.setMapperLocations(this.properties.resolveMapperLocations());
        }

        Set<String> factoryPropertyNames = (Set)Stream.of((new BeanWrapperImpl(SqlSessionFactoryBean.class)).getPropertyDescriptors()).map(FeatureDescriptor::getName).collect(Collectors.toSet());
        Class<? extends LanguageDriver> defaultLanguageDriver = this.properties.getDefaultScriptingLanguageDriver();
        if (factoryPropertyNames.contains("scriptingLanguageDrivers") && !ObjectUtils.isEmpty(this.languageDrivers)) {
            factory.setScriptingLanguageDrivers(this.languageDrivers);
            if (defaultLanguageDriver == null && this.languageDrivers.length == 1) {
                defaultLanguageDriver = this.languageDrivers[0].getClass();
            }
        }

        if (factoryPropertyNames.contains("defaultScriptingLanguageDriver")) {
            factory.setDefaultScriptingLanguageDriver(defaultLanguageDriver);
        }

        this.applySqlSessionFactoryBeanCustomizers(factory);
    	//具体还是在这里做出来的
        return factory.getObject();
    }

2.5:SqlSessionTemplate创建

MybatisAutoConfiguration中SqlSessionTemplate中创建

2.6:SqlSessionTemplate创建

创建SqlSessionTemplate 的时候,SqlSessionFactory为上文提到的DefaultSqlSessionFactory,SqlSession为这里生成的代理对象,继续根据代理对象是哪一个呢?

SqlSessionInterceptor

代理对象为这个类,看一下里面的invoke方法

invoke

代理调用

getSqlSession

获取sqlSession

openSession

获取Executor

newExecutor

InterceptorChain链执行

pluginAll

目标的增强

小结:

源码看到了这里,基本是生成了sqlSessionFactrory,SqlSessionTemplate,以及SqlSession(其实是代理),以及代理对象的invoke的执行,基本就是一些后续执行的前提,所以这些bean的创建基本都应该有所了解了

三,mappper的代理对象生成

在调用的时候,我们只是写了一个mapper接口,并未写实现,但是mapper中的方法和xml中的方法都是对应的,会将mapper全类名接口+方法名作为key存放在map中,每一个都是一个MappedStatement对象,存放在configuration的全局配置中,根据key获取到MappedStatement对象,根据代理对象执行相应的逻辑

MapperScannerConfigurer

postProcessBeanDefinitionRegistry

ClassPathMapperScanner 进行扫描,this.basePackage是扫描的包,一般就是mapper接口所在的包,springboot中是默认启动类当前包下的类被扫描 com.clover.**.mapper

scan

doScan

执行的含义就是生成bean对象

processBeanDefinitions

修改beanClass为MapperFactoryBean.class,这样创建对象的时候,就会调用MapperFactoryBean中的方法


执行afterPropertiesSet方法,然后就是往cinfiguration中添加mapper接口对象

MapperFactoryBean

实现了FactoryBean,获取mapper的时候,调用getobject方法,获取代理对象

getMapper

newInstance

获取mapper的代理对象,都是MapperProxy进行的代理,所以到此为止,就可以知道,启动的时候,已经做到了mapper的对象是从MapperProxy代理对象进行跟踪进行的

三,调用执行代理对象mapperProxy

MapperProxy

invoke

每一个mapper调用方法的时候,就会调用invoke执行,然后调用到MapperMethod的excute方法,根据类型执行相应的增删改查

MapperMethod

execute

判断类型,其实这个类型就是mapperXml定义的标签以及id和与之对应的方法名一一对应的,到了这里,可能就比较熟悉了,因为对于sql的增删改查相比都是比较的熟悉,这里其实就是下面可以猜测到的,拼装sql,和参数,然后执行sql,返回结果,处理返回结果

比如一个executeForMany为例

SqlSessionTemplate调用selectList,然后使用代理对象调用

此时的sqlsesion就是sqlSessionTemplate

代理对象为SqlSessionInterceptor,此时调用就是invoke方法

invoke方法调用

*首先获取sqlSession,然后 里面大致的流程就是新建一个DefaultSqlSession对象,并创建一个Executor的对象或者代理对象,比如pageHelper就是代理了此对象Executor

*获取Executor对象,并检查是否是需要代理

*执行代理方法

*处理一下事务的逻辑

四,mybatis的执行流程总结

执行流程图

mapperMethod执行:主要是请求参数的解析

excutor:主要是指StatementHandler的创建,包含 BoundSql 的创建、ParameterHandler和 ResultSetHandler 的创建。

statementHandler 执行:主要执行sql 并对结果集进行处理

参数组装是在excutor创建之前,拦截器是在创建excutor的时候,所以前期就是参数组装,BoundSql创建 是在StatementHandler创建的时候,在ParameterHandler和 ResultSetHandler 之前。

相关推荐

使用Python编写Ping监测程序(python 测验)

Ping是一种常用的网络诊断工具,它可以测试两台计算机之间的连通性;如果您需要监测某个IP地址的连通情况,可以使用Python编写一个Ping监测程序;本文将介绍如何使用Python编写Ping监测程...

批量ping!有了这个小工具,python再也香不了一点

号主:老杨丨11年资深网络工程师,更多网工提升干货,请关注公众号:网络工程师俱乐部下午好,我的网工朋友。在咱们网工的日常工作中,经常需要检测多个IP地址的连通性。不知道你是否也有这样的经历:对着电脑屏...

python之ping主机(python获取ping结果)

#coding=utf-8frompythonpingimportpingforiinrange(100,255):ip='192.168.1.'+...

网站安全提速秘籍!Nginx配置HTTPS+反向代理实战指南

太好了,你直接问到重点场景了:Nginx+HTTPS+反向代理,这个组合是现代Web架构中最常见的一种部署方式。咱们就从理论原理→实操配置→常见问题排查→高级玩法一层层剖开说,...

Vue开发中使用iframe(vue 使用iframe)

内容:iframe全屏显示...

Vue3项目实践-第五篇(改造登录页-Axios模拟请求数据)

本文将介绍以下内容:项目中的public目录和访问静态资源文件的方法使用json文件代替http模拟请求使用Axios直接访问json文件改造登录页,配合Axios进行登录请求,并...

Vue基础四——Vue-router配置子路由

我们上节课初步了解Vue-router的初步知识,也学会了基本的跳转,那我们这节课学习一下子菜单的路由方式,也叫子路由。子路由的情况一般用在一个页面有他的基础模版,然后它下面的页面都隶属于这个模版,只...

Vue3.0权限管理实现流程【实践】(vue权限管理系统教程)

作者:lxcan转发链接:https://segmentfault.com/a/1190000022431839一、整体思路...

swiper在vue中正确的使用方法(vue中如何使用swiper)

swiper是网页中非常强大的一款轮播插件,说是轮播插件都不恰当,因为它能做的事情太多了,swiper在vue下也是能用的,需要依赖专门的vue-swiper插件,因为vue是没有操作dom的逻辑的,...

Vue怎么实现权限管理?控制到按钮级别的权限怎么做?

在Vue项目中实现权限管理,尤其是控制到按钮级别的权限控制,通常包括以下几个方面:一、权限管理的层级划分...

【Vue3】保姆级毫无废话的进阶到实战教程 - 01

作为一个React、Vue双修选手,在Vue3逐渐稳定下来之后,是时候摸摸Vue3了。Vue3的变化不可谓不大,所以,本系列主要通过对Vue3中的一些BigChanges做...

Vue3开发极简入门(13):编程式导航路由

前面几节文章,写的都是配置路由。但是在实际项目中,下面这种路由导航的写法才是最常用的:比如登录页面,服务端校验成功后,跳转至系统功能页面;通过浏览器输入URL直接进入系统功能页面后,读取本地存储的To...

vue路由同页面重定向(vue路由重定向到外部url)

在Vue中,可以使用路由的重定向功能来实现同页面的重定向。首先,在路由配置文件(通常是`router/index.js`)中,定义一个新的路由,用于重定向到同一个页面。例如,我们可以定义一个名为`Re...

那个 Vue 的路由,路由是干什么用的?

在Vue里,路由就像“页面导航的指挥官”,专门负责管理页面(组件)的切换和显示逻辑。简单来说,它能让单页应用(SPA)像多页应用一样实现“不同URL对应不同页面”的效果,但整个过程不会刷新网页。一、路...

Vue3项目投屏功能开发!(vue投票功能)

最近接了个大屏项目,产品想在不同的显示器上展示大屏项目不同的页面,做出来的效果图大概长这样...

取消回复欢迎 发表评论: