spring boot下mybatis配置双数据源的实例
最近项目上遇到需要双数据源的来实现需求，并且需要基于spring boot，mybatis的方式来实现，在此做简单记录。
单一数据源配置
单一数据源配置的话并没有什么特别的，在spring boot框架下，只需要在配置文件内添加对应的配置项即可，spring boot会自动初始化需要用到的bean。
配置信息如下。这里使用的是德鲁伊的数据源配置方式
#datasource配置 spring.datasource.type=com.alibaba.druid.pool.DruidDataSource spring.datasource.driver-class-name=com.mysql.jdbc.Driver spring.datasource.url=jdbc:mysql://xxx spring.datasource.username=root spring.datasource.password=123456 #mybatis配置 #mybatis xmlMapper文件路径 mybatis.mapper-locations=classpath:META-INF/mybatis/mapper/*Mapper.xml mybatis.configuration.map-underscore-to-camel-case=true #mappers mapper接口文件路径 多个接口时逗号隔开 mapper.mappers=com.xxxx.xxxx mapper.not-empty=false mapper.identity=MYSQL
在使用mapper的时候，直接使用spring的注解注入即可。
多个数据源配置
假如需要新增配置一个数据源，那么在spring boot 框架下如何实现呢？在多数据源的情况下，数据源配置需要添加两份，数据源、mybatis等使用到的bean不能再依赖spring boot替我们完成。
多数据源配置文件
配置文件改成如下，第二个数据源的配置前缀需要自定义为另外的。
#datasource 1配置 spring.datasource.type=com.alibaba.druid.pool.DruidDataSource spring.datasource.driver-class-name=com.mysql.jdbc.Driver spring.datasource.url=jdbc:mysql://xxx spring.datasource.username=root spring.datasource.password=123456 #datasource 2配置,前缀改为second以区分第一个数据源 second.datasource.type=com.alibaba.druid.pool.DruidDataSource second.datasource.driver-class-name=com.mysql.jdbc.Driver second.datasource.url=jdbc:mysql://xxx second.datasource.username=root second.datasource.password=123456
多数据源配置类
编写第一个数据源使用的配置类，如下所示。
对于Datasource的bean定义，需要使用@ConfigurationProperties(prefix = "spring.datasource")前缀匹配来指定使用第一个数据源的配置，同时还需要使用注解@Primary来指定当有依赖注入需要注入datasource时，优先使用@Primary注解修饰的datasource。
对于SqlSessionFactory定义，我们无法依赖spring boot做自动化配置实现，有一些动作需要我们手动处理。首先是mapper.xml文件路径的指定,这样mapper接口才能注册到mybatis容器中；假如你定义的的mapper接口没有对应的MapperXml，你还需要手动指定mapper接口的包路径作为参数，调用addMappers的方法，进行扫描注册，手动注册接口到mybatis容器中，一般这个过程在解析MapperXml文件时会由mybatis框架实现。
还有就是SqlSessionTemplate,DataSourceTransactionManager的定义，第一个数据源都需要配置为优先注入。
上面所有的配置第一个数据源相关bean优先注入都是为了方便spring容器，管理第一个数据源的mapper接口的代理类实例bean。spring boot实现Mapper代理类实例的注册时，是从容器中获取一个SqlSessionTemplatebean，然后调用SqlSessionTemplate.getMapper()方法获取一个实例的，因此SqlSessionTemplate优先注入者，spring容器管理的Mapper代理类就是对应数据源定义的。所以第一个数据源的Mapper使用时，可以直接使用@Resource注解或者别的依赖注解来使用。
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import javax.sql.DataSource;
/**
* @author garine
* @date 2018年11月16日
**/
@Configuration
public class OdsMybatisConfig {
@Bean
@ConfigurationProperties(prefix = "spring.datasource")
@Primary
public DataSource odsDataSource(){
return DataSourceBuilder.create().build();
}
@Bean
@Primary
public SqlSessionFactory odsSqlSessionFactory(DataSource dataSource) throws Exception {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(dataSource);
//设置mapper.xml文件路径
bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:META-INF/mybatis/mapper/*Mapper.xml"));
//设置mapper接口的扫描包路径
//sqlSessionFactory.getConfiguration().addMappers("com.xxx.mapper");
return bean.getObject();
}
@Bean
@Primary
public DataSourceTransactionManager odsTransactionManager(DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
@Bean
@Primary
public SqlSessionTemplate odsSqlSessionTemplate(SqlSessionFactory sqlSessionFactory) throws Exception {
return new SqlSessionTemplate(sqlSessionFactory);
}
}
下面是第二个数据源的配置类。针对第二个数据源配置，方法内容基本一致，但是需要注意的是，由于第一个数据源设置了优先配置，那么所有依赖注入默认都将注入第一个数据源的配置，所以第二个数据源配置需要额外指定使用何种bean注入。
datasource的定义需要使用 @Qualifier注解指定值，在依赖注入时使用 @Qualifier和指定值就可以注入目标bean。wmsSqlSessionFactory方法 使用@Qualifier(“wmsDatasource”)注解可以注入第二个数据源bean。
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import javax.sql.DataSource;
/**
* @author garine
* @date 2018年11月16日
**/
@Configuration
public class WmsMybatisConfig {
@Bean
@ConfigurationProperties(prefix = "second.datasource")
@Qualifier("wmsDatasource")
public DataSource wmsDataSource(){
return DataSourceBuilder.create().build();
}
@Bean
@Qualifier("wmsSqlSessionFactory")
public SqlSessionFactory wmsSqlSessionFactory(@Qualifier("wmsDataSource") DataSource dataSource) throws Exception {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(dataSource);
bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:META-INF/mybatis/wms/mapper/*Mapper.xml"));
bean.getObject();
SqlSessionFactory sqlSessionFactory = bean.getObject();
//设置wms数据源额外的mapper.java注册
//sqlSessionFactory.getConfiguration().addMappers("com.xx.maper");
return sqlSessionFactory;
}
@Bean
public DataSourceTransactionManager wmsTransactionManager(@Qualifier("wmsDataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
@Bean
@Qualifier("wmsSqlSessionTemplate")
public SqlSessionTemplate wmsSqlSessionTemplate( @Qualifier("wmsSqlSessionFactory") SqlSessionFactory wmsSqlSessionFactory) throws Exception {
return new SqlSessionTemplate(wmsSqlSessionFactory);
}
}
通过上面的配置就可以实现双数据源配置，下面是使用方式。
- 第一个数据源定义的maper由spring容器管理，可以直接使用@Resource注解使用
- 第二个数据源使用可能比较麻烦，代码如下
//依赖注入第二个数据源的SqlSession
@Resource
@Qualifier("wmsSqlSessionTemplate")
SqlSessionTemplate wmsSqlSessionTemplate;
//使用时手动获取Mapper然后调用接口方法
wmsSqlSessionTemplate.getMapper(ReturnResultRecoderMapper.class).selectTest()
最后需要注意一点就是，使用上面的配置方式，mybatis的结果处理器对下划线结果集合并没有自动转换为驼峰方式，需要手动在sql中定义别名。
例如实体
class People{
private String peopleGender;
}
mybatis执行sql，结果集映射为People类。
sekect people_gender from people；
people_gender这个结果无法自动映射到peopleGender，需要执行以下sql才能映射上
sekect people_gender as peopleGendler from people；
所以这个配置过程应该是漏了某些配置导致结果处理器的名称映射不起作用，这个问题先mark。
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
这篇文章主要为大家详细介绍了java线程池实现批量下载文件，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2019-07-07
这篇文章主要介绍了JPA中JpaRepository接口的使用方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-11-11
这篇文章主要介绍了Java算法之归并排序的相关资料,归并排序是一种递归排序算法,通过将数组分成更小的子数组,递归地排序这些子数组,然后将它们合并成有序数组,文中通过代码介绍的非常详细,需要的朋友可以参考下2025-04-04
这篇文章主要介绍了Java实现字符串倒序输出的常用方法,通过三个实例从不同角度实现该功能,有不错的借鉴价值,需要的朋友可以参考下2014-09-09
这篇文章主要介绍了详解如何全注解方式构建SpringMVC项目，利用Eclipse构建SpringMVC项目，非常具有实用价值，需要的朋友可以参考下2018-10-10
Sa-Token是一款轻量级Java权限认证框架,它简化了权限管理,提高了开发效率,本文通过实例介绍了Sa-Token的基本概念、与其他框架的比较、基本语法和高级用法,并探讨了其核心原理和实际应用场景,感兴趣的朋友一起看看吧2024-09-09
这篇文章主要为大家介绍了Sharding Jdbc批量操作引发fullGC解决，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-11-11
这篇文章主要介绍了Java 使用@Autowired注解自动注入bean的操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-06-06
本篇文章给大家详细分析了Java的static与final关键字知识点以及相关代码分享，有需要的读者跟着学习下吧。2018-03-03
在企业项目的数据库操作中,分页查询是一个常见需求,尤其当数据量庞大时,MyBatis作为我们Java开发者的持久层框架,为分页提供了灵活的支持,本篇文章我们将深入探讨MyBatis的分页机制,使我们在实际开发项目中运用自如,需要的朋友可以参考下2023-12-12
最新评论