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

 更新时间:2025年07月22日 11:02:50   作者:1010n111  
本文详解Spring Boot配置双数据源方法,包含配置文件设置、Bean创建、事务管理器配置及@Qualifier注解使用,强调主数据源标记、代码隔离和ChainedTransactionManager事务管理,对Spring Boot使用两个数据源的相关知识感兴趣的朋友一起看看吧

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

技术背景

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

实现步骤

1. 配置数据源信息

application.propertiesapplication.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使用不同的数据源

可以通过配置不同的EntityManagerFactoryTransactionManager,并在@EnableJpaRepositories注解中指定对应的entityManagerFactoryReftransactionManagerRef

3. 分布式事务问题

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

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

相关文章

  • 详解SpringBoot 快速整合Mybatis(去XML化+注解进阶)

    详解SpringBoot 快速整合Mybatis(去XML化+注解进阶)

    本篇文章主要介绍了详解SpringBoot 快速整合Mybatis(去XML化+注解进阶),小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-11-11
  • Java封装(Encapsulation)实践

    Java封装(Encapsulation)实践

    封装是OOP核心原则,将数据和方法整合为类,通过访问修饰符(如private)隐藏内部状态,仅提供受控的getter/setter访问,确保数据安全、完整性,提升代码可维护性,但可能增加代码量与复杂度
    2025-09-09
  • Spring系列之事物管理

    Spring系列之事物管理

    这篇文章主要介绍了Spring系列之事物管理,文中通过示例代码介绍的非常详细,对大家学习或者使用spring方面知识具有一定的参考学习价值,需要的朋友们一起学习学习吧
    2021-09-09
  • JavaOOP封装实例解读

    JavaOOP封装实例解读

    封装通过private限制属性访问,提供get/set方法控制数据读写,确保值合法,示例中Student类属性私有,Test类需调用set方法赋值并验证,get方法获取值,实现数据隐藏与安全操作
    2025-09-09
  • Shiro安全框架的主要组件及认证过程简介

    Shiro安全框架的主要组件及认证过程简介

    这篇文章主要介绍了Shiro安全框架的主要组件及认证过程简介,Shiro 是一个强大灵活的开源安全框架,可以完全处理身份验证、授权、加密和会话管理,本文就来介绍一下此框架的核心组成,需要的朋友可以参考下
    2023-08-08
  • SpringBoot+ruoyi框架文件上传和下载的实现

    SpringBoot+ruoyi框架文件上传和下载的实现

    文件的上传和下载功能,是项目开发过程中比较常见的业务需求,本文主要介绍了SpringBoot+ruoyi框架文件上传和文件下载的实现,具有一定的参考价值,感兴趣的可以了解一下
    2023-09-09
  • 关于Springboot如何获取IOC容器

    关于Springboot如何获取IOC容器

    大家好,我是孤焰。最近我在制作日志审计功能时发现不知道怎样获取到Springboot项目中的IOC容器,经过摸索,最终解决了这个问题,现在把解决方式和大家分享一下
    2021-08-08
  • Java创建线程的五种写法总结

    Java创建线程的五种写法总结

    本文主要为大家详细介绍一下Java实现线程创建的五种写法,文中的示例代码讲解详细,对我们学习有一定的帮助,感兴趣的可以跟随小编学习一下
    2022-08-08
  • Springboot 内部服务调用方式

    Springboot 内部服务调用方式

    这篇文章主要介绍了Springboot 内部服务调用方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-03-03
  • JDK9对String字符串的新一轮优化

    JDK9对String字符串的新一轮优化

    这篇文章主要介绍了JDK9对String字符串的新一轮优化,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2021-03-03

最新评论