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

郏杏儿

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

技术背景

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

实现步骤

1. 配置数据源信息

在

1. application.properties

复制代码

或

1. application.yml

复制代码

中添加两个数据源的配置信息。以

1. application.properties

复制代码

为例：

1. # 第一个数据库配置
2. spring.datasource.url = [url]
3. spring.datasource.username = [username]
4. spring.datasource.password = [password]
5. spring.datasource.driverClassName = oracle.jdbc.OracleDriver
6. # 第二个数据库配置
7. spring.secondDatasource.url = [url]
8. spring.secondDatasource.username = [username]
9. spring.secondDatasource.password = [password]
10. spring.secondDatasource.driverClassName = oracle.jdbc.OracleDriver

复制代码

2. 创建数据源Bean

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

1. import org.springframework.boot.context.properties.ConfigurationProperties;
2. import org.springframework.boot.jdbc.DataSourceBuilder;
3. import org.springframework.context.annotation.Bean;
4. import org.springframework.context.annotation.Configuration;
5. import javax.sql.DataSource;
6. @Configuration
7. public class DataSourceConfig {
8. @Bean
9. @Primary
10. @ConfigurationProperties(prefix="spring.datasource")
11. public DataSource primaryDataSource() {
12. return DataSourceBuilder.create().build();
13. }
14. @Bean
15. @ConfigurationProperties(prefix="spring.secondDatasource")
16. public DataSource secondaryDataSource() {
17. return DataSourceBuilder.create().build();
18. }
19. }

复制代码

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

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

1. import org.springframework.context.annotation.Bean;
2. import org.springframework.context.annotation.Configuration;
3. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
4. import javax.sql.DataSource;
5. @Configuration
6. public class TransactionManagerConfig {
7. @Bean(name="tm1")
8. @Autowired
9. @Primary
10. DataSourceTransactionManager tm1(@Qualifier ("primaryDataSource") DataSource datasource) {
11. DataSourceTransactionManager txm = new DataSourceTransactionManager(datasource);
12. return txm;
13. }
14. @Bean(name="tm2")
15. @Autowired
16. DataSourceTransactionManager tm2(@Qualifier ("secondaryDataSource") DataSource datasource) {
17. DataSourceTransactionManager txm = new DataSourceTransactionManager(datasource);
18. return txm;
19. }
20. }

复制代码

4. 使用不同的数据源

在需要使用数据源的地方，通过

1. @Qualifier

复制代码

注解指定使用哪个数据源：

1. import org.springframework.beans.factory.annotation.Autowired;
2. import org.springframework.beans.factory.annotation.Qualifier;
3. import org.springframework.jdbc.core.JdbcTemplate;
4. import org.springframework.stereotype.Service;
5. import javax.sql.DataSource;
6. @Service
7. public class MyService {
8. private final JdbcTemplate primaryJdbcTemplate;
9. private final JdbcTemplate secondaryJdbcTemplate;
10. @Autowired
11. public MyService(@Qualifier("primaryDataSource") DataSource primaryDataSource,
12. @Qualifier("secondaryDataSource") DataSource secondaryDataSource) {
13. this.primaryJdbcTemplate = new JdbcTemplate(primaryDataSource);
14. this.secondaryJdbcTemplate = new JdbcTemplate(secondaryDataSource);
15. }
16. public void doSomething() {
17. // 使用主数据源执行操作
18. primaryJdbcTemplate.execute("SELECT 1 FROM DUAL");
19. // 使用从数据源执行操作
20. secondaryJdbcTemplate.execute("SELECT 1 FROM DUAL");
21. }
22. }

复制代码

核心代码

数据源配置

1. import org.springframework.boot.context.properties.ConfigurationProperties;
2. import org.springframework.boot.jdbc.DataSourceBuilder;
3. import org.springframework.context.annotation.Bean;
4. import org.springframework.context.annotation.Configuration;
5. import javax.sql.DataSource;
6. @Configuration
7. public class DataSourceConfig {
8. @Bean
9. @Primary
10. @ConfigurationProperties(prefix="spring.datasource")
11. public DataSource primaryDataSource() {
12. return DataSourceBuilder.create().build();
13. }
14. @Bean
15. @ConfigurationProperties(prefix="spring.secondDatasource")
16. public DataSource secondaryDataSource() {
17. return DataSourceBuilder.create().build();
18. }
19. }

复制代码

事务管理器配置

1. import org.springframework.context.annotation.Bean;
2. import org.springframework.context.annotation.Configuration;
3. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
4. import javax.sql.DataSource;
5. @Configuration
6. public class TransactionManagerConfig {
7. @Bean(name="tm1")
8. @Autowired
9. @Primary
10. DataSourceTransactionManager tm1(@Qualifier ("primaryDataSource") DataSource datasource) {
11. DataSourceTransactionManager txm = new DataSourceTransactionManager(datasource);
12. return txm;
13. }
14. @Bean(name="tm2")
15. @Autowired
16. DataSourceTransactionManager tm2(@Qualifier ("secondaryDataSource") DataSource datasource) {
17. DataSourceTransactionManager txm = new DataSourceTransactionManager(datasource);
18. return txm;
19. }
20. }

复制代码

服务层使用数据源

1. import org.springframework.beans.factory.annotation.Autowired;
2. import org.springframework.beans.factory.annotation.Qualifier;
3. import org.springframework.jdbc.core.JdbcTemplate;
4. import org.springframework.stereotype.Service;
5. import javax.sql.DataSource;
6. @Service
7. public class MyService {
8. private final JdbcTemplate primaryJdbcTemplate;
9. private final JdbcTemplate secondaryJdbcTemplate;
10. @Autowired
11. public MyService(@Qualifier("primaryDataSource") DataSource primaryDataSource,
12. @Qualifier("secondaryDataSource") DataSource secondaryDataSource) {
13. this.primaryJdbcTemplate = new JdbcTemplate(primaryDataSource);
14. this.secondaryJdbcTemplate = new JdbcTemplate(secondaryDataSource);
15. }
16. public void doSomething() {
17. // 使用主数据源执行操作
18. primaryJdbcTemplate.execute("SELECT 1 FROM DUAL");
19. // 使用从数据源执行操作
20. secondaryJdbcTemplate.execute("SELECT 1 FROM DUAL");
21. }
22. }

复制代码

最佳实践

• 标记主数据源：使用
  1. @Primary

  复制代码
  注解标记一个主数据源，这样在自动注入时Spring会优先使用该数据源。
• 事务管理：对于需要同时操作两个数据源的场景，使用
  1. ChainedTransactionManager

  复制代码
  进行事务管理。
• 代码隔离：将不同数据源的配置和使用代码进行隔离，提高代码的可维护性。

常见问题

1.jdbcUrl is required with driverClassName错误

在Spring Boot 2.0之后，需要使用

1. jdbc-url

复制代码

代替

1. url

复制代码

。

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

可以通过配置不同的

1. EntityManagerFactory

复制代码

和

1. TransactionManager

复制代码

，并在

1. @EnableJpaRepositories

复制代码

注解中指定对应的

1. entityManagerFactoryRef

复制代码

和

1. transactionManagerRef

复制代码

。

3. 分布式事务问题

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

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

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！