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

Question

如何配置和使用两个数据源？

例如，以下是我对第一个数据源的了解：

应用属性

#first db
spring.datasource.url = [url]
spring.datasource.username = [username]
spring.datasource.password = [password]
spring.datasource.driverClassName = oracle.jdbc.OracleDriver

#second db ...

应用类

@SpringBootApplication
public class SampleApplication
{
    public static void main(String[] args) {
        SpringApplication.run(SampleApplication.class, args);
    }
}

如何修改应用程序。是否要添加其他数据源？如何自动关联它以供其他存储库使用？

Answer 1

参考官方文件

创建多个数据源的工作原理与创建第一个数据源相同。如果您使用的是JDBC或JPA的默认自动配置，您可能希望将其中一个标记为@主配置（然后该数据源将被任何@Autow的注入拾取）。

@Bean
@Primary
@ConfigurationProperties(prefix="datasource.primary")
public DataSource primaryDataSource() {
    return DataSourceBuilder.create().build();
}

@Bean
@ConfigurationProperties(prefix="datasource.secondary")
public DataSource secondaryDataSource() {
    return DataSourceBuilder.create().build();
}

Answer 2

使用Spring Boot 1.5.8更新2022-05-29。应与Spring防尘套2配合使用的释放装置。x个

大多数答案不提供如何使用它们（作为数据源本身和事务），只提供如何配置它们。

此外，您应该知道如何同时提交/回滚两个数据源的事务。

您可以在中看到可运行的示例和一些解释https://github.com/surasint/surasint-examples/tree/master/spring-boot-jdbi/10_spring-boot-two-databases（请参阅README.txt中的内容）

我在这里复制了一些代码。

首先，您必须设置应用程序。像这样的属性

#Database
database1.datasource.url=jdbc:mysql://localhost/testdb
database1.datasource.username=root
database1.datasource.password=root
database1.datasource.driver-class-name=com.mysql.jdbc.Driver

database2.datasource.url=jdbc:mysql://localhost/testdb2
database2.datasource.username=root
database2.datasource.password=root
database2.datasource.driver-class-name=com.mysql.jdbc.Driver

然后将它们定义为提供者（@Bean），如下所示：

@Bean(name = "datasource1")
@ConfigurationProperties("database1.datasource")
@Primary
public DataSource dataSource(){
    return DataSourceBuilder.create().build();
}

@Bean(name = "datasource2")
@ConfigurationProperties("database2.datasource")
public DataSource dataSource2(){
    return DataSourceBuilder.create().build();
}

请注意，我有@Bean（name=“datasource1”）和@Bean（name=“datasource2”），然后您可以在我们需要数据源作为限定符（“datasource1”）和限定符（“datasource2”）时使用它，例如

@Qualifier("datasource1")
@Autowired
private DataSource dataSource;

如果您确实关心事务，则必须为这两者定义DataSourceTransactionManager，如下所示：

@Bean(name="tm1")
@Autowired
@Primary
DataSourceTransactionManager tm1(@Qualifier ("datasource1") DataSource datasource) {
    DataSourceTransactionManager txm  = new DataSourceTransactionManager(datasource);
    return txm;
}

@Bean(name="tm2")
@Autowired
DataSourceTransactionManager tm2(@Qualifier ("datasource2") DataSource datasource) {
    DataSourceTransactionManager txm  = new DataSourceTransactionManager(datasource);
    return txm;
}

然后你可以像这样使用它

@Transactional //this will use the first datasource because it is @primary

或

@Transactional("tm2")

最重要的部分，您很难在任何地方找到一个示例：如果您想要一个方法来提交/回滚两个数据库的事务，您需要针对tm1和tm2的ChainedTransactionManager，如下所示：

@Bean(name = "chainedTransactionManager")
public ChainedTransactionManager getChainedTransactionManager(@Qualifier ("tm1") DataSourceTransactionManager tm1, @Qualifier ("tm2") DataSourceTransactionManager tm2){
    return new ChainedTransactionManager(tm1, tm2);
}

要使用它，请在方法@Transactional（value=“chainedTransactionManager”）中添加此注释，例如

@Transactional(value="chainedTransactionManager")
public void insertAll() {
    UserBean test = new UserBean();
    test.setUsername("username" + new Date().getTime());
    userDao.insert(test);

    userDao2.insert(test);
}

这应该足够了。请参见上面链接中的示例和详细信息。

Answer 3

干得好。

添加您的application.properties文件：

#first db
spring.datasource.url = [url]
spring.datasource.username = [username]
spring.datasource.password = [password]
spring.datasource.driverClassName = oracle.jdbc.OracleDriver

#second db ...
spring.secondDatasource.url = [url]
spring.secondDatasource.username = [username]
spring.secondDatasource.password = [password]
spring.secondDatasource.driverClassName = oracle.jdbc.OracleDriver

在任何带有@Configuration注释的类中添加以下方法：

@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();
}