springboot在yml中配置多个数据源

旧城等待， 2023-07-13 13:52 1阅读 0赞

因项目多个库在不同服务器,一个数据源并不能满足正常需求,下面介绍springboot在yml文件中配置mysql多个数据源

### 1.首先在yml文件中配置数据源的 ###

## ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1J1X3lpbl9oYWk_size_16_color_FFFFFF_t_70][]

### 2.配置druid ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1J1X3lpbl9oYWk_size_16_color_FFFFFF_t_70 1][]

### 3.配置主节点的数据源 ###

package com.tmao.config;
    
    import com.alibaba.druid.pool.DruidDataSource;
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.mybatis.spring.annotation.MapperScan;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.beans.factory.annotation.Value;
    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;
    
    import javax.sql.DataSource;
    
    
    @Configuration
    @MapperScan(basePackages = MasterDbConfig.PACKAGE,sqlSessionFactoryRef = "masterSqlSessionFactory")
    public class MasterDbConfig  {
        private Logger logger = LoggerFactory.getLogger(MasterDbConfig.class);
    
        // 精确到 master 目录，以便跟其他数据源隔离
        static final String PACKAGE = "com.tmao.dao.master";
        private static final String MAPPER_LOCATION = "classpath*:com/tmao/dao/master/*.xml";
        private static final String DOMAIN_PACKAGE = "com.tmao.entity.tmall";
    
    
        @Value("${spring.datasource.url1}")
        private String dbUrl;
    
        @Value("${spring.datasource.username1}")
        private String username;
    
        @Value("${spring.datasource.password1}")
        private String password;
    
        @Value("${spring.datasource.driverClassName}")
        private String driverClassName;
    
    
        @Bean(name="masterDataSource")   //声明其为Bean实例
        @Primary  //在同样的DataSource中，首先使用被标注的DataSource
        public DataSource masterDataSource() {
            DruidDataSource datasource = new DruidDataSource();
    
            datasource.setUrl(this.dbUrl);
            datasource.setUsername(username);
            datasource.setPassword(password);
            datasource.setDriverClassName(driverClassName);
    
            return datasource;
        }
    
        @Bean(name = "masterTransactionManager")
        @Primary
        public DataSourceTransactionManager masterTransactionManager() {
            return new DataSourceTransactionManager(masterDataSource());
        }
    
        @Bean(name = "masterSqlSessionFactory")
        @Primary
        public SqlSessionFactory masterSqlSessionFactory(@Qualifier("masterDataSource") DataSource masterDataSource)
                throws Exception {
            final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
            sessionFactory.setDataSource(masterDataSource);
            sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                    .getResources(MasterDbConfig.MAPPER_LOCATION));
            sessionFactory.setTypeAliasesPackage(DOMAIN_PACKAGE);
            //mybatis 数据库字段与实体类属性驼峰映射配置
            sessionFactory.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);
            return sessionFactory.getObject();
        }
    
    
    
    }

### 4.配置子节点 ###

package com.tmao.config;
    
    import com.alibaba.druid.pool.DruidDataSource;
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.mybatis.spring.annotation.MapperScan;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.beans.factory.annotation.Value;
    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;
    
    import javax.sql.DataSource;
    
    
    @Configuration
    @MapperScan(basePackages  = ClusterDbConfig.PACKAGE , sqlSessionFactoryRef = "clusterSqlSessionFactory")
    public class ClusterDbConfig {
        private Logger logger = LoggerFactory.getLogger(ClusterDbConfig.class);
        // 精确到 cluster 目录，以便跟其他数据源隔离
        static final String PACKAGE = "com.tmao.dao.cluster1";
        private static final String MAPPER_LOCATION = "classpath*:com/tmao/dao/cluster1/*.xml";
        private static final String DOMAIN_PACKAGE = "com.tmao.entity.os";
    
        @Value("${spring.datasource.url2}")
        private String dbUrl;
    
        @Value("${spring.datasource.username2}")
        private String username;
    
        @Value("${spring.datasource.password2}")
        private String password;
    
        @Value("${spring.datasource.driverClassName}")
        private String driverClassName;
    
    
    
        @Bean(name="clusterDataSource")   //声明其为Bean实例
        public DataSource clusterDataSource() {
            DruidDataSource datasource = new DruidDataSource();
    
            datasource.setUrl(this.dbUrl);
            datasource.setUsername(username);
            datasource.setPassword(password);
            datasource.setDriverClassName(driverClassName);
            return datasource;
        }
    
        @Bean(name = "clusterTransactionManager")
        public DataSourceTransactionManager clusterTransactionManager() {
            return new DataSourceTransactionManager(clusterDataSource());
        }
    
        @Bean(name = "clusterSqlSessionFactory")
        public SqlSessionFactory clusterSqlSessionFactory(@Qualifier("clusterDataSource") DataSource culsterDataSource)
                throws Exception {
            final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
            sessionFactory.setDataSource(culsterDataSource);
            sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                    .getResources(ClusterDbConfig.MAPPER_LOCATION));
            sessionFactory.setTypeAliasesPackage(DOMAIN_PACKAGE);
            //mybatis 数据库字段与实体类属性驼峰映射配置
            sessionFactory.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);
            return sessionFactory.getObject();
        }
    
    }

### 5.注意事项: ###

主节点和子节点的dao,xml,bean,都应该有单独的包进行分开,防止数据冲突

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1J1X3lpbl9oYWk_size_16_color_FFFFFF_t_70]: /images/20230529/8d27947d679043ec9a85433ce3e77597.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1J1X3lpbl9oYWk_size_16_color_FFFFFF_t_70 1]: /images/20230529/39635499076c48268c588ce620b1850e.png