【12】Spring Boot系列之多数据源配置（方法2）

川长思鸟来 2022-03-27 10:40 87阅读 0赞

（1）application.properties配置

#多数据源配置
    #ds1
    app.datasource.first.driver-class-name=com.mysql.cj.jdbc.Driver
    app.datasource.first.jdbc-url=jdbc:mysql://localhost:3306/db1?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true
    app.datasource.first.username=root
    app.datasource.first.password=123456
    app.datasource.first.type=com.alibaba.druid.pool.DruidDataSource
    app.datasource.first.configuration.maximum-pool-size = 30
    
    #ds2
    app.datasource.second.driver-class-name=com.mysql.cj.jdbc.Driver
    app.datasource.second.jdbc-url=jdbc:mysql://localhost:3306/db2?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true
    app.datasource.second.username=root
    app.datasource.second.password=123456
    app.datasource.second.type=com.alibaba.druid.pool.DruidDataSource

（2）将两个数据源的 mapper 接口和 xml 文件分别放入不同的文件夹下。  
如本示例  
1）在 com.example.demo.dao 包下分 first 和 second 两个包存放不同数据库的 mapper 接口。  
2）在 src/main/resources/mappers 文件夹下分 first 和 second 两个文件夹存放不同数据库的 xml 文件。

（3）config类

package com.example.demo.config;
    
    import javax.sql.DataSource;
    
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.mybatis.spring.SqlSessionTemplate;
    import tk.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.core.io.support.PathMatchingResourcePatternResolver;
    import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    
    @Configuration
    @MapperScan(basePackages = "com.example.demo.dao.first", sqlSessionTemplateRef  = "test1SqlSessionTemplate")
    public class DataSource1Config { 
    	
    	@Bean(name = "test1DataSource")
    	@Primary
    	@ConfigurationProperties("app.datasource.first")
    	public DataSource testDataSource() { 
            return DataSourceBuilder.create().build();
        }
    	
    	@Bean(name = "test1SqlSessionFactory")
        @Primary
        public SqlSessionFactory testSqlSessionFactory(@Qualifier("test1DataSource") DataSource dataSource) throws Exception { 
            SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
            bean.setDataSource(dataSource);
            //指定mapper.xml路径
            bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mappers/first/*.xml"));
            return bean.getObject();
        }
    
    	@Bean(name = "test1TransactionManager")
        @Primary
        public DataSourceTransactionManager testTransactionManager(@Qualifier("test1DataSource") DataSource dataSource) { 
            return new DataSourceTransactionManager(dataSource);
        }
    
        @Bean(name = "test1SqlSessionTemplate")
        @Primary
        public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("test1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception { 
            return new SqlSessionTemplate(sqlSessionFactory);
        }
    }

package com.example.demo.config;
    
    import javax.sql.DataSource;
    
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.mybatis.spring.SqlSessionTemplate;
    import tk.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.core.io.support.PathMatchingResourcePatternResolver;
    import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    
    @Configuration
    @MapperScan(basePackages = "com.example.demo.dao.second", sqlSessionTemplateRef  = "test2SqlSessionTemplate")
    public class DataSource2Config { 
    	@Bean(name = "test2DataSource")
        @ConfigurationProperties(prefix = "app.datasource.second")
        public DataSource testDataSource() { 
            return DataSourceBuilder.create().build();
        }
    
        @Bean(name = "test2SqlSessionFactory")
        public SqlSessionFactory testSqlSessionFactory(@Qualifier("test2DataSource") DataSource dataSource) throws Exception { 
            SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
            bean.setDataSource(dataSource);
            //指定mapper.xml路径
            bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mappers/second/*.xml"));
            return bean.getObject();
        }
    
        @Bean(name = "test2TransactionManager")
        public DataSourceTransactionManager testTransactionManager(@Qualifier("test2DataSource") DataSource dataSource) { 
            return new DataSourceTransactionManager(dataSource);
        }
    
        @Bean(name = "test2SqlSessionTemplate")
        public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("test2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception { 
            return new SqlSessionTemplate(sqlSessionFactory);
        }
    }

注意：使用本篇文章则不需像 [【11】Spring Boot系列之多数据源配置（方法一）][11_Spring Boot] 那样在启动类中添加 @MapperScan；也不需添加 @Import(DynamicDataSourceRegister.class) 注解了。

参考：[http://blog.51cto.com/11864647/2067708][http_blog.51cto.com_11864647_2067708]

[11_Spring Boot]: https://blog.csdn.net/lishk314/article/details/86288229
[http_blog.51cto.com_11864647_2067708]: http://blog.51cto.com/11864647/2067708