Java | MyBatis 配置多数据源
共 6533字,需浏览 14分钟
·
2021-05-09 18:33
Mybatis 配置多数据源
Table of Contents
前言使用步骤1. 引入库2. 配置多数据源3. 配置
前言
在开发一些报表项目时,很容易涉及到从多个数据源获取数据,这里介绍一下如何给 Mybatis
在配置多数据源.
使用步骤
1. 引入库
正常引入 mybatis 依赖即可
2. 配置多数据源
spring:
datasource:
report1:
driver-class-name: com.mysql.jdbc.Driver
jdbc-url: jdbc:mysql://127.0.0.1:3306/report_1
username: root
password: 123456
report2:
driver-class-name: com.mysql.jdbc.Driver
jdbc-url: jdbc:mysql://127.0.0.1:3306/report_2
username: root
password: 123456
3. 配置
配置report1
import com.github.pagehelper.PageInterceptor;
import java.util.Properties;
import javax.sql.DataSource;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
@MapperScan(basePackages = {
"com.example.demo.mapper.report1"}, sqlSessionFactoryRef = "sqlSessionFactoryReport1")
public class ReportMybatisConfiguration {
@Bean(name = "reportDB")
@ConfigurationProperties(prefix = "spring.datasource.report1")
public DataSource dataSource1() {
return DataSourceBuilder.create().build();
}
@Bean
public SqlSessionFactory sqlSessionFactoryReport1() throws Exception {
SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
factoryBean.setDataSource(dataSource1());
PageInterceptor pageInterceptor = new PageInterceptor();
Properties properties = new Properties();
properties.setProperty("helperDialect", "mysql");
properties.setProperty("reasonable", "true");
properties.setProperty("supportMethodsArguments", "true");
properties.setProperty("params", "count=countSql");
pageInterceptor.setProperties(properties);
factoryBean.setPlugins(pageInterceptor);
return factoryBean.getObject();
}
@Bean
public SqlSessionTemplate sqlSessionTemplateReport1() throws Exception {
return new SqlSessionTemplate(sqlSessionFactoryReport1());
}
}
配置report2
import com.github.pagehelper.PageInterceptor;
import java.util.Properties;
import javax.sql.DataSource;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
@MapperScan(basePackages = {
"com.example.demo.mapper.report2"}, sqlSessionFactoryRef = "sqlSessionFactoryReport2")
public class Report2MybatisConfiguration {
@Bean(name = "report2DB")
@ConfigurationProperties(prefix = "spring.datasource.report2")
public DataSource dataSource2() {
return DataSourceBuilder.create().build();
}
@Bean
public SqlSessionFactory sqlSessionFactoryReport2() throws Exception {
SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
factoryBean.setDataSource(dataSource2());
org.apache.ibatis.session.Configuration configuration = new org.apache.ibatis.session.Configuration();
configuration.setMapUnderscoreToCamelCase(true);
factoryBean.setConfiguration(configuration);
PageInterceptor pageInterceptor = new PageInterceptor();
Properties properties = new Properties();
properties.setProperty("helperDialect", "mysql");
properties.setProperty("reasonable", "true");
properties.setProperty("supportMethodsArguments", "true");
properties.setProperty("params", "count=countSql");
pageInterceptor.setProperties(properties);
factoryBean.setPlugins(pageInterceptor);
return factoryBean.getObject();
}
@Bean
public SqlSessionTemplate sqlSessionTemplateReport2() throws Exception {
return new SqlSessionTemplate(sqlSessionFactoryReport2());
}
}
这样我们就配置完了,在配置的过程中加入 PageInterceptor
分页插件,如果不需要可以删除 PageInterceptor
关联代码
这样配置后,在包 com.example.demo.mapper.report1
编写的 mapper
则使用 report1
库, 同理在 包 com.example.demo.mapper.report1
编写的 mapper
则使用 report2
库。
这样就完成了多数据源的配置,同理也可以配置更多的数据源
最近的时间不太多,接下来将写几篇关于日常工作中用到的一些技术以及如何与 Spring Boot 整合的文章,计划如下:
数据库表结构管理 flayway
MyBatis 的整合使用
Spring Data REST 快速构建一个 restful 项目
使用 Spring Integration 来配置分布式锁
Sentinel 的单机使用和 Sentinel Dashboard 的搭建
使用 maven git commit 插件来生成打包版本号,方便线程排查
关于 Spring Boot 和 Spring Cloud 匹配版本的查看方法
如果快速将一个 Spring Boot 项目,改成Spring Cloud 项目
使用 Spring Boot Admin 来监控我们的 Spring Cloud 项目
风控规则集的开发实践