Spring Boot配置和使用兩個數(shù)據(jù)源的實現(xiàn)步驟

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

本文詳解Spring Boot配置雙數(shù)據(jù)源方法,包含配置文件設置、Bean創(chuàng)建、事務管理器配置及@Qualifier注解使用,強調(diào)主數(shù)據(jù)源標記、代碼隔離和ChainedTransactionManager事務管理,對Spring Boot使用兩個數(shù)據(jù)源的相關(guān)知識感興趣的朋友一起看看吧

Spring Boot配置和使用兩個數(shù)據(jù)源

技術(shù)背景

在實際的開發(fā)場景中，一個Spring Boot應用可能需要連接多個數(shù)據(jù)庫，比如主從數(shù)據(jù)庫、不同業(yè)務模塊使用不同數(shù)據(jù)庫等。Spring Boot本身支持多數(shù)據(jù)源的配置，通過合理配置可以實現(xiàn)對多個數(shù)據(jù)源的管理和使用。

實現(xiàn)步驟

1. 配置數(shù)據(jù)源信息

在application.properties或application.yml中添加兩個數(shù)據(jù)源的配置信息。以application.properties為例：

# 第一個數(shù)據(jù)庫配置
spring.datasource.url = [url]
spring.datasource.username = [username]
spring.datasource.password = [password]
spring.datasource.driverClassName = oracle.jdbc.OracleDriver
# 第二個數(shù)據(jù)庫配置
spring.secondDatasource.url = [url]
spring.secondDatasource.username = [username]
spring.secondDatasource.password = [password]
spring.secondDatasource.driverClassName = oracle.jdbc.OracleDriver

2. 創(chuàng)建數(shù)據(jù)源Bean

在配置類中創(chuàng)建兩個數(shù)據(jù)源的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. 配置事務管理器（可選）

如果需要對兩個數(shù)據(jù)源進行事務管理，可以配置兩個事務管理器：

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. 使用不同的數(shù)據(jù)源

在需要使用數(shù)據(jù)源的地方，通過@Qualifier注解指定使用哪個數(shù)據(jù)源：

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() {
        // 使用主數(shù)據(jù)源執(zhí)行操作
        primaryJdbcTemplate.execute("SELECT 1 FROM DUAL");
        // 使用從數(shù)據(jù)源執(zhí)行操作
        secondaryJdbcTemplate.execute("SELECT 1 FROM DUAL");
    }
}

核心代碼

數(shù)據(jù)源配置

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;
    }
}

服務層使用數(shù)據(jù)源

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() {
        // 使用主數(shù)據(jù)源執(zhí)行操作
        primaryJdbcTemplate.execute("SELECT 1 FROM DUAL");
        // 使用從數(shù)據(jù)源執(zhí)行操作
        secondaryJdbcTemplate.execute("SELECT 1 FROM DUAL");
    }
}

最佳實踐

標記主數(shù)據(jù)源：使用@Primary注解標記一個主數(shù)據(jù)源，這樣在自動注入時Spring會優(yōu)先使用該數(shù)據(jù)源。
事務管理：對于需要同時操作兩個數(shù)據(jù)源的場景，使用ChainedTransactionManager進行事務管理。
代碼隔離：將不同數(shù)據(jù)源的配置和使用代碼進行隔離，提高代碼的可維護性。