spring boot 链接两个数据源，操作两个数据库（可以多个）

不念不忘少年蓝@ 2022-04-11 12:19 900阅读 0赞

**readme：** 本文实现在同一个springboot服务上配置两个数据库源，如果想要添加更多数据库源，或者不同服务器的数据库源均可，文中会提示如何操作。

### 1.数据源配置文件： ###

数据源配置文件内容如下：

spring:
    	datasource:
    	    aaa:
    	      driver-class-name: com.mysql.jdbc.Driver
    	      jdbc-url: jdbc:mysql://localhost:3306/db_aa?useUnicode=true&characterEncoding=utf8&characterSetResults=utf8&useSSL=false
    	      username: root
    	      password: ***
    	    bbb:
    	      driver-class-name: com.mysql.jdbc.Driver
    	      jdbc-url: jdbc:mysql://localhost:3306/db_bb?useUnicode=true&characterEncoding=utf8&characterSetResults=utf8&useSSL=false
    	      username: root
    	      password: ***

如果按树结构去写配置文件，一定要注意缩进以及表达的含义。

### 2.修改springboot服务启动文件：PreprocessServiceApplication.java ###

import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    @EnableAutoConfiguration(exclude = {DataSourceAutoConfiguration.class})
    @SpringBootApplication()
    @EnableDiscoveryClient
    @EnableEurekaClient
    public class PreprocessServiceApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(PreprocessServiceApplication.class, args);
        }
    }

@EnableAutoConfiguration(exclude = \{DataSourceAutoConfiguration.class\})意为：去掉springboot服务启动时对于数据源配置的自动导入。后面我们会手动配置多个数据源。  
如果有需要，也可把事务管理与mybatis的自动导入去掉，注解为：  
@EnableAutoConfiguration(exclude = \{DataSourceAutoConfiguration.class,DataSourceTransactionManagerAutoConfiguration.class, MybatisAutoConfiguration.class\})

### 3.配置两个数据源（也可多个） ###

**注：以下三个文件都在config包下**  
DataSourceConfig.java

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 {
        @Primary
        @Bean(name = "aaa")
        @ConfigurationProperties(prefix = "spring.datasource.aaa")
        public DataSource dataSourcePreprocess() {
            return DataSourceBuilder.create().build();
        }
    
        @Primary
        @Bean(name = "bbb")
        @ConfigurationProperties(prefix = "spring.datasource.bbb")
        public DataSource dataSourceSentence() {
            return DataSourceBuilder.create().build();
        }
    
    	//如果有更多的数据源需要，在此添加相关的bean，注意bean属性name，@ConfigurationProperties为配置文件配置数据源的前缀
    	//有一个bean就要对于在config文件夹创建对应的xxxConfig.java文件生成工厂
    }

aaaConfig.java

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 javax.sql.DataSource;
    
    @Configuration
    @MapperScan(basePackages = {"com.dao.aaa"}, sqlSessionFactoryRef = "sqlSessionFactory1")
    public class MybatisPreprocessConfig {
        @Autowired
        @Qualifier("aaa")
        private DataSource ds1;
    
        @Bean(name = "sqlSessionFactory1")
        @Primary
        public SqlSessionFactory sqlSessionFactory1() throws Exception {
            SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
            sqlSessionFactoryBean.setDataSource(ds1);
            return sqlSessionFactoryBean.getObject();
        }
    
        @Bean
        @Primary
        public SqlSessionTemplate sqlSessionTemplate1() throws Exception {
            SqlSessionTemplate sqlSessionTemplate = new SqlSessionTemplate(sqlSessionFactory1());
            return sqlSessionTemplate;
        }
    }

bbbConfig.java

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 javax.sql.DataSource;
    
    @Configuration
    @MapperScan(basePackages = {"com.dao.bbb"}, sqlSessionFactoryRef = "sqlSessionFactory2")
    public class MybatisSentenceConfig {
        @Autowired
        @Qualifier("bbb")
        private DataSource ds2;
    
        @Bean(name = "sqlSessionFactory2")
        @Primary
        public SqlSessionFactory sqlSessionFactory2() throws Exception {
            SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
            sqlSessionFactoryBean.setDataSource(ds2);
            return sqlSessionFactoryBean.getObject();
        }
    
        @Bean
        @Primary
        public SqlSessionTemplate sqlSessionTemplate2() throws Exception {
            SqlSessionTemplate sqlSessionTemplate = new SqlSessionTemplate(sqlSessionFactory2());
            return sqlSessionTemplate;
        }
    }

### 4.dao包结构如下： ###

dao
    	aaa
    		xxxdao.java
    	bbb
    		yyydao.java
    	ccc
    		zzzdao.java

**一定注意！！一个数据源对应dao下面的一个子包！**

### 5.运行测试 ###

自己测。。

参考链接：  
[https://blog.csdn.net/mengda\_lei/article/details/81484355][https_blog.csdn.net_mengda_lei_article_details_81484355]  
[https://blog.csdn.net/weixin\_40085570/article/details/80968099][https_blog.csdn.net_weixin_40085570_article_details_80968099]

[https_blog.csdn.net_mengda_lei_article_details_81484355]: https://blog.csdn.net/mengda_lei/article/details/81484355
[https_blog.csdn.net_weixin_40085570_article_details_80968099]: https://blog.csdn.net/weixin_40085570/article/details/80968099