Spring Boot配置和使用两个数据源的实现步骤

更新时间：2025年07月22日 11:02:50 作者：1010n111

本文详解Spring Boot配置双数据源方法,包含配置文件设置、Bean创建、事务管理器配置及@Qualifier注解使用,强调主数据源标记、代码隔离和ChainedTransactionManager事务管理,对Spring Boot使用两个数据源的相关知识感兴趣的朋友一起看看吧

Spring Boot配置和使用两个数据源

技术背景

在实际的开发场景中，一个Spring Boot应用可能需要连接多个数据库，比如主从数据库、不同业务模块使用不同数据库等。Spring Boot本身支持多数据源的配置，通过合理配置可以实现对多个数据源的管理和使用。

实现步骤

1. 配置数据源信息

在application.properties或application.yml中添加两个数据源的配置信息。以application.properties为例：

# 第一个数据库配置
spring.datasource.url = [url]
spring.datasource.username = [username]
spring.datasource.password = [password]
spring.datasource.driverClassName = oracle.jdbc.OracleDriver
# 第二个数据库配置
spring.secondDatasource.url = [url]
spring.secondDatasource.username = [username]
spring.secondDatasource.password = [password]
spring.secondDatasource.driverClassName = oracle.jdbc.OracleDriver

2. 创建数据源Bean

在配置类中创建两个数据源的Bean：

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 javax.sql.DataSource;
@Configuration
public class DataSourceConfig {
    @Bean
    @Primary
    @ConfigurationProperties(prefix="spring.datasource")
    public DataSource primaryDataSource() {
        return DataSourceBuilder.create().build();
    }
    @Bean
    @ConfigurationProperties(prefix="spring.secondDatasource")
    public DataSource secondaryDataSource() {
        return DataSourceBuilder.create().build();
    }
}

3. 配置事务管理器（可选）

如果需要对两个数据源进行事务管理，可以配置两个事务管理器：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import javax.sql.DataSource;
@Configuration
public class TransactionManagerConfig {
    @Bean(name="tm1")
    @Autowired
    @Primary
    DataSourceTransactionManager tm1(@Qualifier ("primaryDataSource") DataSource datasource) {
        DataSourceTransactionManager txm  = new DataSourceTransactionManager(datasource);
        return txm;
    }
    @Bean(name="tm2")
    @Autowired
    DataSourceTransactionManager tm2(@Qualifier ("secondaryDataSource") DataSource datasource) {
        DataSourceTransactionManager txm  = new DataSourceTransactionManager(datasource);
        return txm;
    }
}

4. 使用不同的数据源

在需要使用数据源的地方，通过@Qualifier注解指定使用哪个数据源：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import javax.sql.DataSource;
@Service
public class MyService {
    private final JdbcTemplate primaryJdbcTemplate;
    private final JdbcTemplate secondaryJdbcTemplate;
    @Autowired
    public MyService(@Qualifier("primaryDataSource") DataSource primaryDataSource,
                     @Qualifier("secondaryDataSource") DataSource secondaryDataSource) {
        this.primaryJdbcTemplate = new JdbcTemplate(primaryDataSource);
        this.secondaryJdbcTemplate = new JdbcTemplate(secondaryDataSource);
    }
    public void doSomething() {
        // 使用主数据源执行操作
        primaryJdbcTemplate.execute("SELECT 1 FROM DUAL");
        // 使用从数据源执行操作
        secondaryJdbcTemplate.execute("SELECT 1 FROM DUAL");
    }
}

核心代码

数据源配置

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 javax.sql.DataSource;
@Configuration
public class DataSourceConfig {
    @Bean
    @Primary
    @ConfigurationProperties(prefix="spring.datasource")
    public DataSource primaryDataSource() {
        return DataSourceBuilder.create().build();
    }
    @Bean
    @ConfigurationProperties(prefix="spring.secondDatasource")
    public DataSource secondaryDataSource() {
        return DataSourceBuilder.create().build();
    }
}

事务管理器配置

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import javax.sql.DataSource;
@Configuration
public class TransactionManagerConfig {
    @Bean(name="tm1")
    @Autowired
    @Primary
    DataSourceTransactionManager tm1(@Qualifier ("primaryDataSource") DataSource datasource) {
        DataSourceTransactionManager txm  = new DataSourceTransactionManager(datasource);
        return txm;
    }
    @Bean(name="tm2")
    @Autowired
    DataSourceTransactionManager tm2(@Qualifier ("secondaryDataSource") DataSource datasource) {
        DataSourceTransactionManager txm  = new DataSourceTransactionManager(datasource);
        return txm;
    }
}

服务层使用数据源

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import javax.sql.DataSource;
@Service
public class MyService {
    private final JdbcTemplate primaryJdbcTemplate;
    private final JdbcTemplate secondaryJdbcTemplate;
    @Autowired
    public MyService(@Qualifier("primaryDataSource") DataSource primaryDataSource,
                     @Qualifier("secondaryDataSource") DataSource secondaryDataSource) {
        this.primaryJdbcTemplate = new JdbcTemplate(primaryDataSource);
        this.secondaryJdbcTemplate = new JdbcTemplate(secondaryDataSource);
    }
    public void doSomething() {
        // 使用主数据源执行操作
        primaryJdbcTemplate.execute("SELECT 1 FROM DUAL");
        // 使用从数据源执行操作
        secondaryJdbcTemplate.execute("SELECT 1 FROM DUAL");
    }
}

最佳实践

标记主数据源：使用@Primary注解标记一个主数据源，这样在自动注入时Spring会优先使用该数据源。
事务管理：对于需要同时操作两个数据源的场景，使用ChainedTransactionManager进行事务管理。
代码隔离：将不同数据源的配置和使用代码进行隔离，提高代码的可维护性。

常见问题

1.jdbcUrl is required with driverClassName错误

在Spring Boot 2.0之后，需要使用jdbc-url代替url。

2. 如何让不同的JpaRepository使用不同的数据源

可以通过配置不同的EntityManagerFactory和TransactionManager，并在@EnableJpaRepositories注解中指定对应的entityManagerFactoryRef和transactionManagerRef。

3. 分布式事务问题

如果需要在两个数据源之间进行分布式事务处理，可以考虑使用XA协议或分布式事务框架，如Atomikos。

到此这篇关于Spring Boot配置和使用两个数据源的实现步骤的文章就介绍到这了,更多相关Spring Boot内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

Spring Boot集成MyBatis的方法
今天小编就为大家分享一篇关于Spring Boot集成MyBatis的方法，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧
2018-12-12
SpringBoot+Vue前后端分离实现审核功能的示例
在实际开发中,审核功能是一个非常常用的功能,本文就来介绍一下使用SpringBoot+Vue前后端分离实现审核功能的示例,具有一定的参考价值,感兴趣的可以了解一下
2024-02-02
java如何实现递归删除树形数据的任一个节点
文章讲述了在Java中实现递归删除树形数据的任一个节点时需要注意的三个点,包括删除的节点包含子节点、删除子节点和其他子节点删除的节点不包含子节点、以及该父节点变成叶子节点,此外,文章还提到这两件事包含在同一件事务中
2024-12-12
纯注解版spring与mybatis的整合过程
这篇文章主要介绍了纯注解版spring与mybatis的整合过程，本文通过示例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
2022-06-06
Java并发编程中构建自定义同步工具
这篇文章主要介绍了Java并发编程中构建自定义同步工具,本文讲解了可阻塞状态依赖操作的结构、有界缓存实现基类示例、阻塞实现方式一：抛异常给调用者、阻塞实现方式二：通过轮询和休眠、阻塞实现方式三：条件队列等内容,需要的朋友可以参考下
2015-04-04
解读SpringBoot中addCorsMappings配置跨域与拦截器互斥问题的原因
这篇文章主要介绍了解读SpringBoot中addCorsMappings配置跨域与拦截器互斥问题的原因,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2023-12-12
springboot聚合工程的部署与深入讲解
最近在写一个商城,使用Maven聚合工程来管理,但是其中搭建环境遇见了各种的坑,下面这篇文章主要给大家介绍了关于springboot聚合工程部署的相关资料,需要的朋友可以参考下
2021-11-11
java 与web服务器链接的实例
这篇文章主要介绍了java 与web服务器链接的实例的相关资料,使用net.Socket类sock.getInetAddress()方法获得与Web服务器连接，需要的朋友可以参考下
2017-07-07
Spring MVC+MyBatis+MySQL实现分页功能实例
分页功能是我们日常开发中经常会遇到的，下面这篇文章主要给大家介绍了Spring MVC+MyBatis+MySQL实现分页功能的相关资料，文中介绍的非常详细，对大家具有一定的参考学习价值，需要的朋友们下面来一起看看吧。
2017-06-06
java实现登录注册界面
这篇文章主要为大家详细介绍了java实现登录注册界面，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-06-06