本文共 6880 字，大约阅读时间需要 22 分钟。

Springboot 多数据源配置

1、配置文件

#主数据源配置master.spring.datasource.driver = com.mysql.jdbc.Drivermaster.spring.datasource.url = ...master.spring.datasource.username = ...master.spring.datasource.password = ...master.spring.datasource.initialPoolSize = 1master.spring.datasource.minIdle = 10master.spring.datasource.maxActive = 100#配置另一个数据源second.spring.datasource.driver = com.mysql.jdbc.Driversecond.spring.datasource.url = ...second.spring.datasource.username = ...second.spring.datasource.password = ...second.spring.datasource.initialPoolSize = 1second.spring.datasource.minIdle = 10second.spring.datasource.maxActive = 100

2、创建生成数据源的类

@Configuration@Profile(value = {
   "default", "prod"})public class DataSourceConfig {
       @Value("${master.spring.datasource.url}")    private String url;    @Value("${master.spring.datasource.username}")    private String user;    @Value("${master.spring.datasource.password}")    private String password;    @Value("${master.spring.datasource.driver}")    private String driverClass;    @Value("${master.spring.datasource.initialPoolSize}")    private int initialPoolSize;    @Value("${master.spring.datasource.minIdle}")    private int minIdle;    @Value("${master.spring.datasource.maxActive}")    private int maxActive;    @Value("${second.spring.datasource.url}")    private String url2;    @Value("${second.spring.datasource.username}")    private String user2;    @Value("${second.spring.datasource.password}")    private String password2;    @Value("${second.spring.datasource.driver}")    private String driverClass2;    @Value("${second.spring.datasource.initialPoolSize}")    private int initialPoolSize2;    @Value("${second.spring.datasource.minIdle}")    private int minIdle2;    @Value("${second.spring.datasource.maxActive}")    private int maxActive2;    @Primary    @Bean(name = "localDataSource", destroyMethod = "close", autowire = Autowire.BY_NAME)    public DruidDataSource localDataSource() {
           return getDruidDataSource(url, user, password, initialPoolSize, minIdle, maxActive);    }    @Bean(name = "local2DataSource", destroyMethod = "close", autowire = Autowire.BY_NAME)    public DruidDataSource local2DataSource() {
           return getDruidDataSource(url2, user2, password2, initialPoolSize2, minIdle2, maxActive2);    }		//数据源生成函数    private DruidDataSource getDruidDataSource(String jdbcUrl, String jdbcUser, String jdbcPassword,                                               int initialPoolSize, int minIdle, int maxActive) {
           DruidDataSource druidDataSource = new DruidDataSource();        druidDataSource.setDriverClassName("com.mysql.jdbc.Driver");        druidDataSource.setUrl(jdbcUrl);        druidDataSource.setUsername(jdbcUser);        druidDataSource.setPassword(jdbcPassword);        druidDataSource.setInitialSize(initialPoolSize);        druidDataSource.setMinIdle(minIdle);        druidDataSource.setMaxActive(maxActive);        return druidDataSource;    }}

3、配置数据源1

@Configuration//注意basePackages中的路径一定要扫描到数据源1repository具体的文件夹下，xxx是自己的路径@MapperScan(basePackages = {
   "com.xxx.xxx.xxx.xxx"},        sqlSessionTemplateRef = "localSqlSessionTemplate")@EnableApolloConfig("mysql")public class LocalDaoConfiguration {
       @Primary    @Bean(name = "localSqlSessionFactory")    public SqlSessionFactory sqlSessionFactory(@Qualifier("localDataSource") DataSource dataSource) throws Exception {
           SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();        sqlSessionFactoryBean.setDataSource(dataSource);        ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();      	//xxx数据源1 xml是自己的路径        Resource[] resources = resolver.getResources("classpath:mapping/xxx/*.xml");        Resource[] resArray = Arrays.copyOf(resources, resources.length);        sqlSessionFactoryBean.setMapperLocations(resArray);        return sqlSessionFactoryBean.getObject();    }    @Primary    @Bean(name = "localTransactionManager")    public DataSourceTransactionManager transactionManager(@Qualifier("localDataSource") DataSource dataSource) {
           DataSourceTransactionManager dataSourceTransactionManager = new DataSourceTransactionManager();        dataSourceTransactionManager.setDataSource(dataSource);        return dataSourceTransactionManager;    }    @Primary    @Bean(name = "localTransactionTemplate")    public TransactionTemplate transactionTemplate(            @Qualifier("localTransactionManager") DataSourceTransactionManager transactionManager) {
           TransactionTemplate transactionTemplate = new TransactionTemplate(transactionManager);        return transactionTemplate;    }    @Primary    @Bean(name = "localSqlSessionTemplate")    public SqlSessionTemplate testSqlSessionTemplate(            @Qualifier("localSqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
           return new SqlSessionTemplate(sqlSessionFactory);    }}

4、配置数据源2

@Configuration//注意basePackages中的路径一定要扫描到数据源2repository具体的文件夹下，xxx是自己的路径@MapperScan(basePackages = {
   "com.xxx.xxx.xxx.xxx"},        sqlSessionTemplateRef = "local2SqlSessionTemplate")@EnableApolloConfig("mysql")public class LocalDaoConfiguration {
       @Primary    @Bean(name = "local2SqlSessionFactory")    public SqlSessionFactory sqlSessionFactory(@Qualifier("local2DataSource") DataSource dataSource) throws Exception {
           SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();        sqlSessionFactoryBean.setDataSource(dataSource);        ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();      	//xxx是数据源2 自己的路径        Resource[] resources = resolver.getResources("classpath:mapping/xxx/*.xml");        Resource[] resArray = Arrays.copyOf(resources, resources.length);        sqlSessionFactoryBean.setMapperLocations(resArray);        return sqlSessionFactoryBean.getObject();    }    @Primary    @Bean(name = "local2TransactionManager")    public DataSourceTransactionManager transactionManager(@Qualifier("local2DataSource") DataSource dataSource) {
           DataSourceTransactionManager dataSourceTransactionManager = new DataSourceTransactionManager();        dataSourceTransactionManager.setDataSource(dataSource);        return dataSourceTransactionManager;    }    @Primary    @Bean(name = "local2TransactionTemplate")    public TransactionTemplate transactionTemplate(            @Qualifier("local2TransactionManager") DataSourceTransactionManager transactionManager) {
           TransactionTemplate transactionTemplate = new TransactionTemplate(transactionManager);        return transactionTemplate;    }    @Primary    @Bean(name = "local2SqlSessionTemplate")    public SqlSessionTemplate testSqlSessionTemplate(            @Qualifier("local2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
           return new SqlSessionTemplate(sqlSessionFactory);    }}

5、就可以愉快的运行了

转载地址：http://cwjqb.baihongyu.com/