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

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

ztj100 2025-05-11 19:43 15 浏览 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 之前。

相关推荐

sharding-jdbc实现`分库分表`与`读写分离`

一、前言本文将基于以下环境整合...

三分钟了解mysql中主键、外键、非空、唯一、默认约束是什么

在数据库中,数据表是数据库中最重要、最基本的操作对象,是数据存储的基本单位。数据表被定义为列的集合,数据在表中是按照行和列的格式来存储的。每一行代表一条唯一的记录,每一列代表记录中的一个域。...

MySQL8行级锁_mysql如何加行级锁

MySQL8行级锁版本:8.0.34基本概念...

mysql使用小技巧_mysql使用入门

1、MySQL中有许多很实用的函数,好好利用它们可以省去很多时间:group_concat()将取到的值用逗号连接,可以这么用:selectgroup_concat(distinctid)fr...

MySQL/MariaDB中如何支持全部的Unicode?

永远不要在MySQL中使用utf8,并且始终使用utf8mb4。utf8mb4介绍MySQL/MariaDB中,utf8字符集并不是对Unicode的真正实现,即不是真正的UTF-8编码,因...

聊聊 MySQL Server 可执行注释,你懂了吗?

前言MySQLServer当前支持如下3种注释风格:...

MySQL系列-源码编译安装(v5.7.34)

一、系统环境要求...

MySQL的锁就锁住我啦!与腾讯大佬的技术交谈,是我小看它了

对酒当歌,人生几何!朝朝暮暮,唯有己脱。苦苦寻觅找工作之间,殊不知今日之事乃我心之痛,难道是我不配拥有工作嘛。自面试后他所谓的等待都过去一段时日,可惜在下京东上的小金库都要见低啦。每每想到不由心中一...

MySQL字符问题_mysql中字符串的位置

中文写入乱码问题:我输入的中文编码是urf8的,建的库是urf8的,但是插入mysql总是乱码,一堆"???????????????????????"我用的是ibatis,终于找到原因了,我是这么解决...

深圳尚学堂:mysql基本sql语句大全(三)

数据开发-经典1.按姓氏笔画排序:Select*FromTableNameOrderByCustomerNameCollateChinese_PRC_Stroke_ci_as//从少...

MySQL进行行级锁的?一会next-key锁,一会间隙锁,一会记录锁?

大家好,是不是很多人都对MySQL加行级锁的规则搞的迷迷糊糊,一会是next-key锁,一会是间隙锁,一会又是记录锁。坦白说,确实还挺复杂的,但是好在我找点了点规律,也知道如何如何用命令分析加...

一文讲清怎么利用Python Django实现Excel数据表的导入导出功能

摘要:Python作为一门简单易学且功能强大的编程语言,广受程序员、数据分析师和AI工程师的青睐。本文系统讲解了如何使用Python的Django框架结合openpyxl库实现Excel...

用DataX实现两个MySQL实例间的数据同步

DataXDataX使用Java实现。如果可以实现数据库实例之间准实时的...

MySQL数据库知识_mysql数据库基础知识

MySQL是一种关系型数据库管理系统;那废话不多说,直接上自己以前学习整理文档:查看数据库命令:(1).查看存储过程状态:showprocedurestatus;(2).显示系统变量:show...

如何为MySQL中的JSON字段设置索引

背景MySQL在2015年中发布的5.7.8版本中首次引入了JSON数据类型。自此,它成了一种逃离严格列定义的方式,可以存储各种形状和大小的JSON文档,例如审计日志、配置信息、第三方数据包、用户自定...

取消回复欢迎 发表评论: