首页>资讯>正文
【Spring源码】- 08 扩展点之mybatis集成
2023-03-28 21:11:38    来源:腾讯云

概述

mybatis将与spring集成的代码拆分到了mybatis-spring模块,避免mybatisspring之间的耦合,如果你只需要纯粹的使用mybatis api,就避免了必须将spring依赖也耦合进来的问题。mybatis使用中一般是将Sql语句写在xml文件中,为方便操作,我们会创建一个Mapper接口文件进行映射,mybatis提供了采用动态代理方式对Mapper接口类进行包装,这样我们就可以像使用普通对象一样执行各种方法调用。


(资料图片)

mybatisspring集成的一个核心任务就是将这些动态代理包装的Mapper对象注入到IoC容器中,这样其它Bean就可以方便的使用如@Autowired等方式进行依赖注入。

MapperScannerConfigurer

需要将mybatis生成的动态代理对象注入到IoC容器中,自然我们想到之前的BeanFactoryPostProcessor的子类BeanDefinitionRegistryPostProcessor这个扩展类。MapperScannerConfigurer就是实现了BeanDefinitionRegistryPostProcessor接口,然后在该接口中通过类扫描器scanner进行扫描注册。

public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) { if (this.processPropertyPlaceHolders) {     processPropertyPlaceHolders();    }    ClassPathMapperScanner scanner = new ClassPathMapperScanner(registry);    scanner.setAddToConfig(this.addToConfig);    scanner.setAnnotationClass(this.annotationClass);    scanner.setMarkerInterface(this.markerInterface);    scanner.setSqlSessionFactory(this.sqlSessionFactory);    scanner.setSqlSessionTemplate(this.sqlSessionTemplate);    scanner.setSqlSessionFactoryBeanName(this.sqlSessionFactoryBeanName);//指定引用的SqlSessionFactory    scanner.setSqlSessionTemplateBeanName(this.sqlSessionTemplateBeanName);    scanner.setResourceLoader(this.applicationContext);    scanner.setBeanNameGenerator(this.nameGenerator);    scanner.registerFilters();    //basePackage指定扫描Mapper接口包路径    scanner.scan(StringUtils.tokenizeToStringArray(this.basePackage, ConfigurableApplicationContext.CONFIG_LOCATION_DELIMITERS));}

ClassPathMapperScanner这个就是继承之前介绍过的SpringClassPathBeanDefinitionScanner类扫描器进行了扩展,它可以实现将包路径下至少含有一个方法的接口类注册到IoC中。

这里有个问题:注册进入的BeanDefinitionbeanClass指向的都是接口,到后续创建对象时会存在问题,接口是没法创建实例的。所以,ClassPathMapperScanner扫描器在注册完成后,又会对BeanDefinition进行处理。处理逻辑位于ClassPathMapperScanner#processBeanDefinitions()方法中,其核心逻辑见下:

private void processBeanDefinitions(Set beanDefinitions) {    GenericBeanDefinition definition;    for (BeanDefinitionHolder holder : beanDefinitions) {      definition = (GenericBeanDefinition) holder.getBeanDefinition();      String beanClassName = definition.getBeanClassName();      definition.getConstructorArgumentValues().addGenericArgumentValue(beanClassName); // issue #59      definition.setBeanClass(this.mapperFactoryBeanClass);   ...    }}

其中最重要的一条语句:definition.setBeanClass(this.mapperFactoryBeanClass),偷偷的将BeanDefinitionbeanClass替换成了MapperFactoryBean,而不再指向Mapper接口类。同时将Mapper接口类作为参数传入到了MapperFactoryBean中,即调用下面构造方法:

public MapperFactoryBean(Class mapperInterface) {    this.mapperInterface = mapperInterface;}

MapperFactoryBean实现了FactoryBean接口,这样实际上它是通过getObject()方法获取到对象然后注入到IoC容器中。而在getObject()方法中,我们就可以使用mybatis api获取到Mapper接口类的动态代理对象:SqlSession#getMapper()

public T getObject() throws Exception {    return getSqlSession().getMapper(this.mapperInterface);}

上面我们分析了如何将Mapper接口类注入到IoC容器中的实现思路,现在总结下主要有:

基于BeanDefinitionRegistryPostProcessor接口实现扩展,然后动态向IoC容器中注入Bean;在注入时,会使用到ClassPathMapperScanner类扫描器将所有的Mapper接口类解析成BeanDefinition集合注入;为了解决接口不能创建对象问题,再注入后又将BeanDefinitionbeanClass替换成FactoryBean的实现类:MapperFactoryBean,在该实现类中通过mybatis apiSqlSession#getMapper()获取到Mapper接口的动态代理类

扩展点引入

通过MapperScannerConfigurer,解决了如何将Mapper接口类注入到IoC容器的问题,现在还有另外一个问题,这个扩展点只有注册到Spring中才会起作用,那又如何将其注册到Spring中呢?

方式一:最直接方式就是直接创建MapperScannerConfigurer类型的Bean实例,比如:

        

这种方式是最简单直接的,但是使用角度来说不方便,所以,mybatis-spring-1.2新增了两种方式:标签方式和@MapperScan注解方式。

首先来看下标签方式,添加mybatisschema,然后就可以使用:

                                                                    

后台处理类NamespaceHandler标签注册解析器MapperScannerBeanDefinitionParser

public class NamespaceHandler extends NamespaceHandlerSupport {  @Override  public void init() {    registerBeanDefinitionParser("scan", new MapperScannerBeanDefinitionParser());  }}

再看下MapperScannerBeanDefinitionParser解析器:

protected AbstractBeanDefinition parseInternal(Element element, ParserContext parserContext) {    BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(MapperScannerConfigurer.class);    ClassLoader classLoader = ClassUtils.getDefaultClassLoader();    builder.addPropertyValue("processPropertyPlaceHolders", true);    try {      String annotationClassName = element.getAttribute(ATTRIBUTE_ANNOTATION);      if (StringUtils.hasText(annotationClassName)) {        @SuppressWarnings("unchecked")        Class annotationClass = (Class) classLoader            .loadClass(annotationClassName);        builder.addPropertyValue("annotationClass", annotationClass);      }      String markerInterfaceClassName = element.getAttribute(ATTRIBUTE_MARKER_INTERFACE);      if (StringUtils.hasText(markerInterfaceClassName)) {        Class markerInterface = classLoader.loadClass(markerInterfaceClassName);        builder.addPropertyValue("markerInterface", markerInterface);      }      String nameGeneratorClassName = element.getAttribute(ATTRIBUTE_NAME_GENERATOR);      if (StringUtils.hasText(nameGeneratorClassName)) {        Class nameGeneratorClass = classLoader.loadClass(nameGeneratorClassName);        BeanNameGenerator nameGenerator = BeanUtils.instantiateClass(nameGeneratorClass, BeanNameGenerator.class);        builder.addPropertyValue("nameGenerator", nameGenerator);      }      String mapperFactoryBeanClassName = element.getAttribute(ATTRIBUTE_MAPPER_FACTORY_BEAN_CLASS);      if (StringUtils.hasText(mapperFactoryBeanClassName)) {        @SuppressWarnings("unchecked")        Class mapperFactoryBeanClass = (Class) classLoader            .loadClass(mapperFactoryBeanClassName);        builder.addPropertyValue("mapperFactoryBeanClass", mapperFactoryBeanClass);      }    } catch (Exception ex) {      XmlReaderContext readerContext = parserContext.getReaderContext();      readerContext.error(ex.getMessage(), readerContext.extractSource(element), ex.getCause());    }    builder.addPropertyValue("sqlSessionTemplateBeanName", element.getAttribute(ATTRIBUTE_TEMPLATE_REF));    builder.addPropertyValue("sqlSessionFactoryBeanName", element.getAttribute(ATTRIBUTE_FACTORY_REF));    builder.addPropertyValue("lazyInitialization", element.getAttribute(ATTRIBUTE_LAZY_INITIALIZATION));    builder.addPropertyValue("basePackage", element.getAttribute(ATTRIBUTE_BASE_PACKAGE));    return builder.getBeanDefinition();  }

最关键的就是第一句BeanDefinitionBuilder.genericBeanDefinition(MapperScannerConfigurer.class);,又是将MapperScannerConfigurer动态注入到Spring中,下面一堆都是解析标签属性进行依赖注入。

再来看下@MapperScan注解方式,如:@MapperScan(basePackages = "org.simon.demo01.mapper")

@Retention(RetentionPolicy.RUNTIME)@Target(ElementType.TYPE)@Documented@Import(MapperScannerRegistrar.class)public @interface MapperScan {}

@MapperScan注解上面使用了使用了一种非常常见的扩展方式:@Import扩展。通过@Import注解,引入了MapperScannerRegistrar,它是ImportBeanDefinitionRegistrar类型,通常和@Import注解组合使用,实现动态注入功能:

@Override  public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) {    //获取注解上属性    AnnotationAttributes mapperScanAttrs = AnnotationAttributes        .fromMap(importingClassMetadata.getAnnotationAttributes(MapperScan.class.getName()));    if (mapperScanAttrs != null) {      registerBeanDefinitions(mapperScanAttrs, registry, generateBaseBeanName(importingClassMetadata, 0));    }  }  void registerBeanDefinitions(AnnotationAttributes annoAttrs, BeanDefinitionRegistry registry, String beanName) {    //创建一个MapperScannerConfigurer的BeanDefinition    BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(MapperScannerConfigurer.class);    /**     * 下面就是解析注解属性值,通过PropertyValue方式进行依赖注入到Bean中     */    builder.addPropertyValue("processPropertyPlaceHolders", true);    Class annotationClass = annoAttrs.getClass("annotationClass");    if (!Annotation.class.equals(annotationClass)) {      builder.addPropertyValue("annotationClass", annotationClass);    }    Class markerInterface = annoAttrs.getClass("markerInterface");    if (!Class.class.equals(markerInterface)) {      builder.addPropertyValue("markerInterface", markerInterface);    }    ...//各种依赖注入    builder.addPropertyValue("basePackage", StringUtils.collectionToCommaDelimitedString(basePackages));    //将生成的BeanDefinition注册到IoC中    registry.registerBeanDefinition(beanName, builder.getBeanDefinition());}

方法中同样有BeanDefinitionBuilder.genericBeanDefinition(MapperScannerConfigurer.class)这句,动态的将MapperScannerConfigurer注入到Spring中,然后是一堆的解析注解属性进行依赖注入,这样通过@Import+ImportBeanDefinitionRegistrar动态注入,就实现了将MapperScannerConfigurer扩展点注册到Spring中。

SpringBoot自动装配

不论是通过标签方式,还是@MapperScan注解方式,这些是常规的第三方模块与Spring进行集成方式。这种集成方式比较繁琐的是:你不光要通过@MapperScan注解将第三方集成进来,你还需要初始化一些依赖对象,比如这里的DataSourceSqlSessionFactory等。当一个项目集成了很多第三方模块时,每个模块都这样搞一下,配置的工作量就大了,比如最常使用的ssm集成配,传统Spring集成要搞一大堆配置。

所以,SpringBoot提出了一个比较优秀的思想:自动装配。需要什么模块直接把依赖添加进来,自动完成装配,对于个性化可以在属性文件中进行配置,从使用角度来说,即插即用,不需要有太多的编码。第三方程序和spring就像完全融入一体一样,简化项目构建时集成成本,也降低项目配置的复杂性,所以SpringBoot会被越来越多的项目所采用,进而也推动微服务的兴起。

SpringBoot中使用mybatis,直接依赖mybatis-spring-boot-starter,它会把mybatismybatis-springmybatis-spring-boot-autoconfigure三个依赖包都添加进来。前面两个依赖包好理解,这里关键是第三个依赖包,就是通过它实现了mybatis自动装配功能。下面我们来看下SpringBoot是如何实现mybatis的主动装配。

1、首先,定义一个mybatis主动装配配置类,如下:

@org.springframework.context.annotation.Configuration@ConditionalOnClass({ SqlSessionFactory.class, SqlSessionFactoryBean.class })@ConditionalOnSingleCandidate(DataSource.class)@EnableConfigurationProperties(MybatisProperties.class)@AutoConfigureAfter({ DataSourceAutoConfiguration.class, MybatisLanguageDriverAutoConfiguration.class })public class MybatisAutoConfiguration implements InitializingBean {  public MybatisAutoConfiguration(MybatisProperties properties, ObjectProvider interceptorsProvider,      ObjectProvider typeHandlersProvider, ObjectProvider languageDriversProvider,      ResourceLoader resourceLoader, ObjectProvider databaseIdProvider,      ObjectProvider> configurationCustomizersProvider) { ...  }  @Bean  @ConditionalOnMissingBean  public SqlSessionFactory sqlSessionFactory(DataSource dataSource) throws Exception {    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()));    }    applyConfiguration(factory);    ...//省略一堆配置    if (factoryPropertyNames.contains("defaultScriptingLanguageDriver")) {      factory.setDefaultScriptingLanguageDriver(defaultLanguageDriver);    }    return factory.getObject();  }  @Bean  @ConditionalOnMissingBean  public SqlSessionTemplate sqlSessionTemplate(SqlSessionFactory sqlSessionFactory) {    ExecutorType executorType = this.properties.getExecutorType();    if (executorType != null) {      return new SqlSessionTemplate(sqlSessionFactory, executorType);    } else {      return new SqlSessionTemplate(sqlSessionFactory);    }  }    public static class AutoConfiguredMapperScannerRegistrar implements BeanFactoryAware, ImportBeanDefinitionRegistrar {    private BeanFactory beanFactory;    @Override    public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) {      if (!AutoConfigurationPackages.has(this.beanFactory)) {        logger.debug("Could not determine auto-configuration package, automatic mapper scanning disabled.");        return;      }      logger.debug("Searching for mappers annotated with @Mapper");      List packages = AutoConfigurationPackages.get(this.beanFactory);      if (logger.isDebugEnabled()) {        packages.forEach(pkg -> logger.debug("Using auto-configuration base package "{}"", pkg));      }      BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(MapperScannerConfigurer.class);      builder.addPropertyValue("processPropertyPlaceHolders", true);      builder.addPropertyValue("annotationClass", Mapper.class);      builder.addPropertyValue("basePackage", StringUtils.collectionToCommaDelimitedString(packages));      BeanWrapper beanWrapper = new BeanWrapperImpl(MapperScannerConfigurer.class);      Stream.of(beanWrapper.getPropertyDescriptors())          .filter(x -> x.getName().equals("lazyInitialization")).findAny()          .ifPresent(x -> builder.addPropertyValue("lazyInitialization", "${mybatis.lazy-initialization:false}"));      registry.registerBeanDefinition(MapperScannerConfigurer.class.getName(), builder.getBeanDefinition());    }    @Override    public void setBeanFactory(BeanFactory beanFactory) {      this.beanFactory = beanFactory;    }  }  @org.springframework.context.annotation.Configuration  @Import(AutoConfiguredMapperScannerRegistrar.class)  @ConditionalOnMissingBean({ MapperFactoryBean.class, MapperScannerConfigurer.class })  public static class MapperScannerRegistrarNotFoundConfiguration implements InitializingBean {  }}

这里主要利用MapperScannerRegistrarNotFoundConfiguration类上的@Import(AutoConfiguredMapperScannerRegistrar.class)引入,然后在AutoConfiguredMapperScannerRegistrarBeanDefinitionBuilder.genericBeanDefinition(MapperScannerConfigurer.class)这句又是动态注入MapperScannerConfigurer。不过,主动装配配置类中,还会把相关的依赖也一起创建、初始化,比如:SqlSessionFactorySqlSessionTemplate

@EnableConfigurationProperties(MybatisProperties.class)mybatis相关配置引入进来,这样在创建、初始化过程中的定制需求就可以通过配置修改。

2、有了这个主动装配配置类还不行,下一步就是看如何让主动装配配置类生效。SpringBoot提供了SpringFactoriesLoader工厂加载机制,类似于JDK中的SPI机制,实现将模块META-INF/spring.factories文件中配置注入到Spring容器中。mybatis-spring-boot-autoconfigure模块下META-INF/spring.factories文件中就有MybatisAutoConfiguration

org.springframework.boot.autoconfigure.EnableAutoConfiguration=\org.mybatis.spring.boot.autoconfigure.MybatisLanguageDriverAutoConfiguration,\org.mybatis.spring.boot.autoconfigure.MybatisAutoConfiguration

3、使用时依赖添加进来,配置下属性,就可以直接使用,基本不再需要编码:

mybatis.mapper-locations: classpath:mapper/*Mapper.xmlmybatis.type-aliases-package: com.example.demo.entity

总结

从上面来看,mybatisspring集成的关键的是将mybatis-spring模块下MapperScannerConfigurer集成进来,因为,它是一个BeanDefinitionRegistryPostProcessor类型的扩展,内部通过自定义scanner扫描Mapper接口自动注册到IoC容器中,这一点在各种集成方式中是统一一样的。不同点在于:MapperScannerConfigurer扩展类是如何被引入的。传统的Spring方式通过@Mapper注解或自定义标签实现,但是对于一些依赖对象还是需要手工创建,比较繁琐;而SpringBoot利用自动装配,让第三方模块集成变成了一个插件,即插即用,无需太多编码。

分析了mybatis集成方式,从中也学习了如何利用Spring的各种扩展点进行定制,更重要的是也为我们开发自己模块和Spring集成提供了思路。

关键词:

【Spring源码】- 08 扩展点之mybatis集成

mybatis将与spring集成的代码拆分到了mybatis-spring模块,避免mybatis与spring之间的耦合,如果你只需要纯粹的使用mybati2023-03-28

世界观热点:自制织物涂料_送生日礼物给老人送什么好

使用厨房剩余的美术用品和物品,您可以在家中制作多种颜色的自己的织物涂料。无需在工艺品商店花钱尝试获得每种可能的颜色来进行绘画。所有这2023-03-28

每日速讯:网红文和友,只能是长沙限定吗?

网红文和友,只能是长沙限定吗?,“地头蛇”能做成全国“强龙”吗?2023-03-28

全球播报:中材节能:子公司中标950万吨骨料项目

【中材节能:子公司中标950万吨骨料项目】中材节能公告,全资子公司武汉建材院收到润阳新材料发来的《中标通知书》,在润阳新材料润阳年产9502023-03-28

环球看热讯:巴菲特点破中国股市:现在起如果不炒股,5年后,会有多大不同?

巴菲特点破中国股市:现在起如果不炒股,5年后,会有多大不同?,炒股,股价,股民,护盘,牛市,巴菲特,中国股市2023-03-28

凯恩:我现在29岁依然年轻,为英格兰打进100球并非不可能

凯恩:我现在29岁依然年轻,为英格兰打进100球并非不可能,汉堡,希望,依然年轻,哈里·凯恩,俄罗斯足球,足球运动员,英格兰足球,国际足球赛事2023-03-28

steam退款要多久才能到账 steam退款到账时间介绍[多图]-世界快消息

steam游戏申请退款之后多久可以到账?购买了游戏之后发现不好玩或者是不适合自己玩,那么玩家们是可以在规定时间内申请退款的,但是退款的具体2023-03-28

党建上“云端” 组织不“掉线”,湖北鄂州这个村“智慧党建”有新招

党建上“云端”组织不“掉线”,湖北鄂州这个村“智慧党建”有新招---“要借助电信科技、打破时空阻碍,无缝隙覆盖农村党建,提高党员们参与组2023-03-28

醉驾交警大队可以不移交检察院吗

一、醉驾交警大队可以不移交检察院吗醉驾交警大队不可以不移交检察院。醉驾后交警必须移交至检察院。醉驾案7日内侦结并移送检察2023-03-28

全球今热点:魔兽世界防护圣骑士天赋加点_魔兽世界怀旧服防护圣典有什么用

1、防护圣典用于完成防护圣典任务的任务目标之一,任务需要将防护圣典、1块原始黑钻石、2份大块魔光碎片和1份磨损的憎恶缝合2023-03-28

CSGO2怎么下载/CSGO2下载太慢 CSGO2快速下载教程-环球今日讯

CSGO2怎么下载 CSGO2下载太慢CSGO2快速下载教程 早有传闻说CSGO要出续作,吸引来无数玩家的关注,就在近日,此传言被证实为真,官方公布计划2023-03-28

多家企业业务量实现两位数增长 厦门快递业回暖势头强劲_全球时快讯

业务量猛增,快递小哥忙不停。随着国内经济复苏带动生产活动与消费需求回升,快递行业景气度表现逐步提升。厦门市邮政管理局日前发布数据显示2023-03-28

山东邹城释放政策红利助力乡村人才振兴

“多亏了青创服务站提供的‘乡村好青年贷’,让我购置了现代化设备和苗木。现在,香椿已经开始丰收了,我的创业梦也实现了!”在山东省邹城市2023-03-28

人气!易建联全明星周末太受欢迎,多人争相合影,有望重返国家队-时讯

过去的这个周末对于中国篮球来说可谓是太难忘了,CBA的全明星周末在厦门成功举办,这是疫情结束后的首个全明星周末,时隔三年,球场内终于是座2023-03-28

江波龙释疑存储行业新趋势:下半年市场有望好转 AI或将带来新需求 天天消息

据21财经,江波龙高级副总裁、COO王景阳认为,2022年存储市场价格波动大的领域主要集中在消费级产品,而工业级和车规级2023-03-28

工信部:加快配套体系建设,统筹推动锂电产业高质量发展_环球资讯

证券时报网讯,据工信部消息,中国电子技术标准研究院、江西省工业和信息化厅、江西省宜春市人民政府在宜春市召开锂离子电池产业链供应链合作2023-03-27

全球要闻:2023外卖产业大会:从交易规模到客群资产 数字化加速万店品牌诞生

2023外卖产业大会:从交易规模到客群资产数字化加速万店品牌诞生-为了助力外卖商户实现店型升级,美团外卖全面打造店、品、客的三维经营模型,2023-03-27

甘蔗怎么变酸了?-环球最新

1 甘蔗未成熟。虽然说甘蔗的含糖较高,但在未成熟的时候,其中的淀粉还没有经过水解成糖分时,所含的酸性物质较高,就会导致甘蔗吃起来有点酸。22023-03-27

商务部部长王文涛会见苹果公司首席执行官库克_世界热议

商务部部长会见苹果公司CEO库克2023-03-27

美国联邦存款保险公司:第一公民银行接手硅谷银行-环球热头条

美国联邦存款保险公司(FDIC)网站3月26日发布声明,宣布第一公民银行达成收购硅谷银行的协议,根据声明,第一公民银行将接手硅谷银行所有的存款2023-03-27

当前快播:2023中国国际餐饮产业博览会在福州举行

3月24日,2023中国国际餐饮产业餐博会(以下简称“餐博会”)在福州海峡国际会展中心正式拉开帷幕。本届餐博会得到了福州市人民政府、福州市商2023-03-27

队报记者讨论梅西在大巴黎VS国家队:“在阿根廷他...

队报记者讨论梅西在大巴黎VS国家队:“在阿根廷他就像在家里一样,而在巴黎圣日耳曼他就像在工作。一份有时让他感到厌烦的工作,他也并不总是2023-03-27

佳兆业美好:2022年收入17.84亿元,归属股东净利润9338.5万元

佳兆业美好收益同比减少33 1%至17 84亿元;溢利同比增加56 5%至1 07亿元;公司拥有人应占溢利同比增加64 4%至9338 5万元。-日新网2023-03-27

京剧的哇呀呀喂呀呀哇哈哈哈都啥意思? 每日信息

原标题:京剧的哇呀呀喂呀呀哇哈哈哈都啥意思?3月27日是世界戏剧日,京剧里的这些知识,你知道吗:京剧里经常哇呀呀大叫的是哪个行当?京剧人2023-03-27

今日播报!我国首座,启航!

中国海油3月26日发布消息,我国首座深远海浮式风电平台“海油观澜号”在广东珠海福陆码头启航前往海南文昌海域,这标志着我国2023-03-27

滚动
资讯