当Spring Boot中使用多个数据源时，如何设置多个连接池？

Question

我有一个Spring Boot应用程序，它连接到两个独立的数据库。虽然为了自定义Tomcat JDBC连接池设置，我必须手动配置它（因为通过定义多个数据源，引导自动配置将被忽略，并且Spring Boot不再从application.properties读取特定于Tomcat的属性），但所有操作都很正常（我遵循了文档和教程中的步骤）。

由于Spring内部的多层抽象，我很难对此进行调试。我有Eclipse类反编译插件，我通常使用它查看Spring逻辑，但在本例中，数据源的初始化代码发生在bean注册时，而不是Spring Boot实际使用它们来设置数据源时。

底线，你能帮我理解一下吗：

1. 为什么只有一个连接池
2. 如何使用两个连接池，每个数据源一个
3. 要查看Spring代码中的哪个位置以获得有关此操作方式的更多详细信息

对于第二个问题，有一个有点相关的问题，但没有答案。还有一个问题是假阳性，还有一个是跟Spring有关的，不是跟Spring靴有关的，所以请不要把这个当成上当。

Answer 1

下面是我必须采用的方法，以便为每个数据源获得单独的池。下面是@user3007501上面提出的要点的一个实现。

>

不要使用DatasourceBuilder，而是创建一个org.apache.tomcat.jdbc.pool.Datasource。这将创建池并配置连接。

如果需要hikari或dbcp2使用原始Spring源datasourceConfiguration.java中的hikari或dbcp2配置部分替换下面的createPooleddatasource()方法的内容。以下CreatePooledDataSource()的显示内容是从链接文件中的Tomcat.DataSource()方法中盗取的。

# Primary Datasource
spring:
  datasource:
    username: your-username-for-ds-1
    password: your-password-for-ds-1
    driver-class-name: net.sourceforge.jtds.jdbc.Driver
    tomcat:
      validation-query: select 1
      test-on-borrow: true


myotherdatasource:
  datasource:
    username: your-username-for-ds-2
    password: your-password-for-ds-2
    driver-class-name: net.sourceforge.jtds.jdbc.Driver
    # HERE: make sure you have a tomcat config for your second datasource like below 
    tomcat:
      validation-query: select 1
      test-on-borrow: true

import org.apache.tomcat.jdbc.pool.DataSource;
import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DatabaseDriver;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.beans.factory.annotation.Qualifier;


@Configuration
public class MyCustomDatasourceConfig {
    @Bean(name = "My-First-Data")
    @Primary
    @ConfigurationProperties(prefix = "spring.datasource.tomcat") 
    // *** NOTE the inclusion of the .tomcat above
    public DataSource primaryDataSource(DataSourceProperties properties) {
        return createPooledDataSource(properties);
    }


    @Bean()
    @Primary
    @ConfigurationProperties(prefix = "spring.datasource")
    public DataSourceProperties dataSourcePropsPrimary() {
        return new DataSourceProperties();
    }


    @Bean(name = "My-Second-Data-Source")
    @ConfigurationProperties(prefix = "myotherdatasource.datasource.tomcat") 
    // *** NOTE the inclusion of the .tomcat above
    public DataSource datasourceOtherConfig(@Qualifier("secondary_ds_prop") DataSourceProperties properties) {
        return createPooledDataSource(properties);
    }

    @Bean(name  = "secondary_ds_prop")
    @ConfigurationProperties(prefix = "myotherdatasource.datasource")
    public DataSourceProperties dataSourcePropsSecondary() {
        return new DataSourceProperties();
    }


    private DataSource createPooledDataSource(DataSourceProperties properties) {
        // Using fully qualified path to the tomcat datasource just to be explicit for the sake of this example
        DataSource dataSource = (org.apache.tomcat.jdbc.pool.DataSource)
                   properties.initializeDataSourceBuilder()
                   .type(org.apache.tomcat.jdbc.pool.DataSource.class).build();
        DatabaseDriver databaseDriver = DatabaseDriver.fromJdbcUrl(properties.determineUrl());
        String validationQuery = databaseDriver.getValidationQuery();
        if (validationQuery != null) {
            dataSource.setTestOnBorrow(true);
            dataSource.setValidationQuery(validationQuery);
        }
        return dataSource;
    }
}