springboot-mybatis多数据源的配置方法

缺乏、安全感 2021-09-30 15:02 315阅读 0赞

## **微信搜索：“二十同学” 公众号，欢迎关注一条不一样的成长之路** ##

springboot+mybatis配置多数据源，springboot版本在2.0以上

1.**在application.yml中配置两个数据库：**

spring:
      datasource:
        master:
          jdbc-url: jdbc:postgresql://192.168.1.2:5432/test?useUnicode=true&characterEncoding=utf8
          username: postgres
          password: postgres
          driverClassName: org.postgresql.Driver
          maxActive: 10
          maxIdle: 3
        worker:
          jdbc-url: jdbc:postgresql://192.168.1.3:5432/tests?useUnicode=true&characterEncoding=utf8
          username: postgres
          password: postgres
          driverClassName: org.postgresql.Driver
          maxActive: 10
          maxIdle: 3

2.建立数据库配置文件，创建数据源

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 javax.sql.DataSource;
    
    
    @Configuration
    public class DataSourceConfig {
    
        @Bean(name = "masterDB")
        @Primary
        @ConfigurationProperties(prefix = "spring.datasource.master") // application.properteis中对应属性的前缀
        public DataSource masterDataSource() {
            return DataSourceBuilder.create().build();
        }
    
    
        @Bean(name = "workerDB")
        @ConfigurationProperties(prefix = "spring.datasource.worker") // application.properteis中对应属性的前缀
        public DataSource workerDataSource() {
            return DataSourceBuilder.create().build();
        }
    
    
    }

3.配置mybatis的**`SqlSessionFactory`**分别使用不同的数据源：

`com.domain.mappers`下的Mapper接口，都会使用masterDB数据源

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.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.Primary;
    import org.springframework.core.io.Resource;
    import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    import javax.sql.DataSource;
    
    
    @Configuration
    @MapperScan(basePackages = {"com.domain.mappers"}, sqlSessionFactoryRef = "sqlSessionFactory1")
    public class MybatisMasterConfig {
    
        @Autowired
        @Qualifier("masterDB")
        private DataSource mDB;
    
    
        @Bean
        @Primary
        public SqlSessionFactory sqlSessionFactory1() throws Exception {
    
            SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
            factoryBean.setDataSource(mDB);
            Resource[] resources = new PathMatchingResourcePatternResolver().getResources("classpath*:mappers/**/*.xml");
            factoryBean.setMapperLocations(resources);
            SqlSessionFactory sessionFactory = factoryBean.getObject();
            return sessionFactory;
    
        }
    
        @Bean
        @Primary
        public SqlSessionTemplate sqlSessionTemplate1() throws Exception {
    
            SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactory1()); // 使用上面配置的Factory
            return template;
        }
    
    }

`com.domain.workmappers`下的Mapper接口，都会使用workerDB数据源

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.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.core.io.Resource;
    import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    
    import javax.sql.DataSource;
    
    
    @Configuration
    @MapperScan(basePackages = {"com.domain.workmappers"}, sqlSessionFactoryRef = "sqlSessionFactory2")
    public class MybatisWorkerConfig {
    
        @Autowired
        @Qualifier("workerDB")
        private DataSource wDB;
    
        @Bean
        public SqlSessionFactory sqlSessionFactory2() throws Exception {
    
            SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
            factoryBean.setDataSource(wDB);
            Resource[] resources = new PathMatchingResourcePatternResolver().getResources("classpath*:workmappers/**/*.xml");
            factoryBean.setMapperLocations(resources);
            SqlSessionFactory sessionFactory = factoryBean.getObject();
            return sessionFactory;
    
    
        }
    
        @Bean
        public SqlSessionTemplate sqlSessionTemplate2() throws Exception {
            SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactory2());
            return template;
        }
    
    }