@
目录
- SpringBoot配置多数据源实战
- 需求来源：
- 简单粗暴3步使用步骤：
- 思路讲解：
- 目录结构：
- 使用注意点：
SpringBoot配置多数据源实战
需求来源：
当相关业务场景想实现同时操作2个甚至多个不同数据库表的时候，就需要配置多个数据源。
简单粗暴3步使用步骤：
1.修改包名结构
2.application.properties配置2套数据源，注意加前缀
3.修改DataSourceOmniConfig里面的注解@MapperScan和@Bean(name = "transactionManager")即可，其他不用改可直接使用
思路讲解：
springboot默认支持一个数据库，所以可简写（具体参照自己项目即可），但是当想实现配置多数据源的时候，application.properties配置文件需要修改前缀，用于自定义工厂进行扫描产生Bean
目录结构：
使用注意点：
| 1.DataSourceOmniConfig和DataSourcePlatformConfig中，其中一个要使用注解@Primary，代表哪个是主要的数据源 |
|---|
| 2.使用只需修改其中的注解属性@MapperScan(basePackages=xxxx） |
| 3.主要数据源中事务那里要改成这样@Bean(name = "transactionManager")，不改会报错显示缺少事务支持 |
| 4.配置文件中url前要加jdbc，例如spring.datasource01.jdbc-url |
DataSourceOmniConfigpackage com.geespace.omni.datasource;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.beans.factory.annotation.Qualifier;
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;
import org.springframework.context.annotation.Primary;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;/*** 表示这个类为一个配置类,配置Mybatis的接口类放的地方* @author: liudz* @date: 2020/8/13*/
@Configuration
@MapperScan(basePackages = "com.geespace.omni.dao.database1", sqlSessionFactoryRef = "db01SqlSessionFactory")
public class DataSourceOmniConfig {/*** 将这个对象放入Spring容器中,读取application.properties中的配置参数映射成为一个对象,prefix表示参数的前缀* @author: liudz* @date: 2020/8/13* @return 执行结果*/@Bean(name = "db01DataSource")@ConfigurationProperties(prefix = "spring.datasource01")@Primarypublic DataSource testDataSource() {return DataSourceBuilder.create().build();}/*** 将这个对象放入Spring容器中* @param dataSource dataSource* @author: liudz* @date: 2020/8/13* @return 执行结果* @throws Exception Exception*/@Bean(name = "db01SqlSessionFactory")@Primarypublic SqlSessionFactory testSqlSessionFactory(@Qualifier("db01DataSource") DataSource dataSource)throws Exception {SqlSessionFactoryBean bean = new SqlSessionFactoryBean();bean.setDataSource((dataSource));return bean.getObject();}/*** 将这个对象放入Spring容器中* @param dataSource dataSource* @author: liudz* @date: 2020/8/13* @return 执行结果* @throws Exception Exception*/@Bean(name = "transactionManager")@Primarypublic DataSourceTransactionManager testTransactionManager(@Qualifier("db01DataSource") DataSource dataSource) {return new DataSourceTransactionManager(dataSource);}/*** 将这个对象放入Spring容器中* @param sqlSessionFactory sqlSessionFactory* @author: liudz* @date: 2020/8/13* @return 执行结果* @throws Exception Exception*/@Bean(name = "db01SqlSessionTemplate")@Primarypublic SqlSessionTemplate testSqlSessionTemplate(@Qualifier("db01SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {return new SqlSessionTemplate(sqlSessionFactory);}
}DataSourcePlatformConfigpackage com.geespace.omni.datasource;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.beans.factory.annotation.Qualifier;
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;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;/*** 表示这个类为一个配置类, 配置Mybatis的接口类放的地方* @author: liudz* @date: 2020/8/13*/
@Configuration
@MapperScan(basePackages = "com.geespace.omni.dao.database2", sqlSessionFactoryRef = "db02SqlSessionFactory")
public class DataSourcePlatformConfig {/**** @author liudz* @date 2020/8/13* @return 执行结果**/@Bean(name = "db02DataSource")@ConfigurationProperties(prefix = "spring.datasource02")public DataSource testDataSource() {return DataSourceBuilder.create().build();}/*** @param dataSource dataSource* @author liudz* @date 2020/8/13* @return 执行结果* @throws Exception Exception**/@Bean(name = "db02SqlSessionFactory")public SqlSessionFactory testSqlSessionFactory(@Qualifier("db02DataSource") DataSource dataSource)throws Exception {SqlSessionFactoryBean bean = new SqlSessionFactoryBean();bean.setDataSource((dataSource));return bean.getObject();}/*** @param dataSource dataSource* @author liudz* @date 2020/8/13* @return 执行结果**/@Bean(name = "db02TransactionManager")public DataSourceTransactionManager testTransactionManager(@Qualifier("db02DataSource") DataSource dataSource) {return new DataSourceTransactionManager(dataSource);}/*** @param sqlSessionFactory sqlSessionFactory* @author liudz* @date 2020/8/13* @return 执行结果* @throws Exception Exception**/@Bean(name = "db02SqlSessionTemplate")public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("db02SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {return new SqlSessionTemplate(sqlSessionFactory);}
}
重要信息
- 官网：https://ais.cn/u/vEbMBz
