Spring Boot 应用程序不会连接到第二个数据源

Question

我有一个使用 2 个数据源的 Spring Boot 应用程序。它可以很好地连接到第一个。当我尝试使用第二个数据源时，我收到 SQL 错误：表或​​视图不存在，因为它使用第一个数据源作为其连接。

这是我的应用程序属性文件：

#Property for both DBs
spring.datasource.driver.class.name=oracle.jdbc.driver.OracleDriver

## Database Properties DB #1
spring.datasource.tms.url=jdbc:oracle:thin:@ldap:<connection properties have been removed but are present>
spring.datasource.tms.username=own_app
spring.datasource.tms.password=own_app_l1
spring.datasource.tms.jmx.enabled=true

spring.main.allow-bean-definition-overriding=true

## Database Properties DB #2
spring.datasource.lhl.url=jdbc:oracle:thin:@ldap:<connection string has been removed but is correct>
spring.datasource.lhl.username=LHL_PURCH_APP
spring.datasource.lhl.password=ChangemeChangemeChangeme$$2019
spring.datasource.lhl.jmx-enabled=true

这是我的两个数据源的配置文件：

@Configuration
@PropertySource("classpath:application-local.properties")
public class FxgLhlPurchasedItineraryAdapterDataSourceConfiguration {

    @Value("${spring.datasource.driver.class.name}")
    private String driverClassName;

    //TMS properties
    @Value("${spring.datasource.tms.url}")
    private String tmsUrl;

    @Value("${spring.datasource.tms.username}")
    private String tmsUsername;

    @Value("${spring.datasource.tms.password}")
    private String tmsPassword;

    //LHL Properties
    @Value("${spring.datasource.lhl.url}")
    private String lhlUrl;

    @Value("${spring.datasource.lhl.username}")
    private String lhlUsername;

    @Value("${spring.datasource.lhl.password}")
    private String lhlPassword;

    @Primary
    @Bean(name = "tmsDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.tms")
    public DataSource tmsDataSource() {
        DataSourceBuilder factory = DataSourceBuilder.create(this.getClass().getClassLoader())
                .driverClassName(driverClassName).url(tmsUrl)
                .username(tmsUsername)
                .password(tmsPassword);

        return factory.build();
    }

    @Bean(name = "lhlDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.lhl")
    public DataSource lhlDataSource() {
        DataSourceBuilder factory = DataSourceBuilder.create(this.getClass().getClassLoader())
                .driverClassName(driverClassName).url(lhlUrl)
                .username(lhlUsername)
                .password(lhlPassword);

        return factory.build();
    }

    @Bean(name = "tmsJdbcTemplate")
    public JdbcTemplate tmsJdbcTemplate(final DataSource tmsDataSource) {
        return new JdbcTemplate(tmsDataSource);
    }

    @Bean(name = "lhlJdbcTemplate")
    public JdbcTemplate lhlJdbcTemplate(final DataSource lhlDataSource) {
        return new JdbcTemplate(lhlDataSource);
    }

}

如果服务无法运行，我必须添加 @Primary 注释。
当我尝试对不是主数据库的表执行简单的 SELECT 时，我收到该表不存在的错误。 这是调用select语句的代码：

 private JdbcTemplate lhlJdbcTemplate;
    DataSource ds = lhlJdbcTemplate.getDataSource();
    Connection con = ds.getConnection();
    LOGGER.info("Connection info:  {}", con.getSchema());

    lhlParmSqIdModelList = lhlJdbcTemplate.query(
                         selectSequenceNbrSQLStatement,
                        new LhlParmSqIdModelRowMapper());

logger 语句返回主数据库的架构。 如何获得连接以使用第二个数据库

Answer 1

因为你有多个 DataSource bean，通常 Spring 会失败，因为它不知道如何自动决定它应该使用多个等效 bean 中的哪一个，它把这个责任交给了你作为程序员。

通过添加@Primary 注释，您是在告诉Spring“如果有多个这种类型的候选bean，请使用这个。”

您的 bean 方法并没有向 Spring 请求特定的 DataSource，它们只需要 任何 数据源，因此 Spring 为每个方法都提供了标有 @Primary 的数据源。

相反，您需要使用 @Qualifier 来准确指出他们想要的名称为 DataSource：

@Bean(name = "tmsJdbcTemplate")
public JdbcTemplate tmsJdbcTemplate(@Qualifier("tmsDataSource") final DataSource tmsDataSource) {
    return new JdbcTemplate(tmsDataSource);
}

@Bean(name = "lhlJdbcTemplate")
public JdbcTemplate lhlJdbcTemplate(@Qualifier("lhlDataSource") final DataSource lhlDataSource) {
    return new JdbcTemplate(lhlDataSource);
}

我不保证这个语法是完全正确的，但是类似的。

您还需要限定 JdbcTemplate 注入点。 （感谢 cmets 中的Sherif Behna）