在Spring Boot（v2.6.6）中，如何从两个数据源中提取并分别访问它们？

Question

我有两个数据库，我需要同时实例，它们运行在oracle weblogic服务器上，而不是本地。在配置器类中，我指定了源并测试了连接，并且两个数据库都正确拉取数据。（一次使用一个，或与一个作为@Primary）

@Configuration
public class appDatabaseConfiguration {

 @Bean
 @Primary
 public DataSource dataSourceA() throws Exception{
     JndiDataSourceLookup dataSourceLookup = new JndiDataSourceLookup();
     JndiTemplate corpdwJndiTemplate = new JndiTemplate();
     return dataSourceLookup.getDataSource("<DBAProperties>");
 }
 
 @Bean
 public DataSource dataSourceB() throws Exception{
     JndiDataSourceLookup dataSourceLookup = new JndiDataSourceLookup();
     JndiTemplate jndiTemplate = new JndiTemplate();
     return dataSourceLookup.getDataSource("<DBBProperties>");
 }
}

然而，我无法使用@Qualifier告诉实例化要选择配置中的哪个bean-

@Service
public class DaoImpl implements Dao{
    @Autowired
    @Qualifier("dataSourceA")
    private JdbcTemplate dataSourceA;
    
    @Autowired
    @Qualifier("dataSourceB")
    private JdbcTemplate dataSourceB;
    
    public String getData() {

         resultsA = dataSourceA.queryForObject("SELECT COUNT(*) FROM TABLE", String.class);
                
         resultsB = dataSourceB.queryForObject("SELECT COUNT(*) FROM TABLE", String.class);     
        
         return resultsA + resultsB;
    }
}

不使用@Qualifier时：数据源查询将成功，但 DataSourceB 将失败（表或视图不存在错误）- 因为它正在为两个实例化拉取@Primary Bean

当使用@ qualifier:应用程序错误

org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type 
'org.springframework.jdbc.core.JdbcTemplate' available: expected at least 1 bean which 
qualifies as autowire candidate. Dependency annotations: 
{@org.springframework.beans.factory.annotation.Autowired(required=dataSourceA)} 

我曾尝试向bean添加特定名称，如@bean（“dataSourceA”）、@bean（name=“dataSourceB”），而不是依赖函数名和其他一些语法更改，但没有结果。这里有人有什么见解吗？

注意:即使一个数据源bean注释o

Answer 1

这是因为配置中定义的bean类型是数据源，而在@服务中，您注入了JdbcTemplate类型的bean。

要使它工作，您应该使用两个< code >数据源创建两个类型为< code>JdbcTemplate的beans，如下所示:

@Configuration
public class appDatabaseConfiguration {

 @Bean
 @Primary
 public DataSource dataSourceA() throws Exception{
     JndiDataSourceLookup dataSourceLookup = new JndiDataSourceLookup();
     JndiTemplate corpdwJndiTemplate = new JndiTemplate();
     return dataSourceLookup.getDataSource("<DBAProperties>");
 }
 
 @Bean
 public DataSource dataSourceB() throws Exception{
     JndiDataSourceLookup dataSourceLookup = new JndiDataSourceLookup();
     JndiTemplate jndiTemplate = new JndiTemplate();
     return dataSourceLookup.getDataSource("<DBBProperties>");
 }

 @Bean(name="jdbcTemplateA")
 public JdbcTemplate jdbcTemplateA() {
     return new JdbcTemplate(dataSourceA());
 }

 @Bean(name="jdbcTemplateB")
 public JdbcTemplate jdbcTemplateB() {
     return new JdbcTemplate(dataSourceB());
 }
}

然后，使用< code > @ Qualifier(" jdbcTemplateA ")或< code > @ Qualifier(" jdbcTemplateB ")注入您的beans

Answer 2

您必须创建两个JdbcTemplates，每个模板都配置了不同的数据源，并使用模板的限定符自动连接，例如

@Bean
@Primary
public JdbcTemplate jdbcTemp1(@Qualifier("dataSourceA") DataSource ds) {
    return new JdbcTemplate(ds);
}

@Bean
public JdbcTemplate jdbcTemp2(@Qualifier("dataSourceB") DataSource ds) {
    return new JdbcTemplate(ds);
}

...

@Autowired
@Qualifier("jdbcTemp2")
private JdbcTemplate jdbcTemplate;