동일한 유형의 2 bean 사용 : Spring의 javax.sql.DataSource

Question

2 개의 bean을 작성하려는 Spring Boot 기반 응용 프로그램을 개발 중입니다. 하나는 'Oracle'데이터베이스를 가리키고, 다른 하나는 ' 다른 하나는 하이브를 가리킬 것입니다.

Exception in thread "main" 
org.springframework.beans.factory.BeanCreationException: Error 
creating bean with name 
'org.springframework.boot.actuate.autoconfigure.EndpointAutoConfiguration': 
Injection of autowired dependencies failed; nested exception is 
org.springframework.beans.factory.BeanCreationException: Could not 
autowire field: private javax.sql.DataSource 
org.springframework.boot.actuate.autoconfigure.EndpointAutoConfiguration.dataSource; 
nested exception is 
org.springframework.beans.factory.NoUniqueBeanDefinitionException: No 
qualifying bean of type [javax.sql.DataSource] is defined: expected 
single matching bean but found 2: metadataDataSource,hiveDataSource 

은 주로 그들 모두는 javax.sql.DataSource에서 상속 때문에 :

public @Bean 
BoneCPDataSource metadataDataSource() { 
    BoneCPDataSource boneCPDataSource = new BoneCPDataSource(); 
    boneCPDataSource.setDriverClass(getDriver()); 
    boneCPDataSource.setJdbcUrl(getJdbcUrl()); 
    boneCPDataSource.setUser(getUser()); 
    boneCPDataSource.setPassword(getPassword()); 
    boneCPDataSource.setMaxConnectionsPerPartition(5); 
    boneCPDataSource.setPartitionCount(5); 
    return boneCPDataSource; 
} 

public @Bean 
BasicDataSource hiveDataSource() { 
    BasicDataSource basicDataSource = new BasicDataSource(); 

    // Note: In a separate command window, use port forwarding like this: 
    // 
    // ssh -L 127.0.0.1:9996:<server>:<port> -l <userid> <server> 
    // 
    // and then login as the generic user. 

    basicDataSource.setDriverClassName("org.apache.hadoop.hive.jdbc.HiveDriver"); 
    basicDataSource.setUrl("jdbc:hive://127.0.0.1:9996:10000/mytable"); 
    return basicDataSource; 
} 

문제는 내가이 무엇입니까 시작에 있습니다 : 다음과 같이 내가 그들을 선언했습니다. 이 문제를 해결하는 가장 좋은 방법은 무엇입니까?

---

편집 :

는 지금은 다음과 같이 그들을 선언했습니다

public @Bean (name="metadataDataSource") 
BoneCPDataSource metadataDataSource() { 
    BoneCPDataSource boneCPDataSource = new BoneCPDataSource(); 
    boneCPDataSource.setDriverClass(getDriver()); 
    boneCPDataSource.setJdbcUrl(getJdbcUrl()); 
    boneCPDataSource.setUser(getUser()); 
    boneCPDataSource.setPassword(getPassword()); 
    boneCPDataSource.setMaxConnectionsPerPartition(5); 
    boneCPDataSource.setPartitionCount(5); 
    return boneCPDataSource; 
} 

public @Bean (name="hiveDataSource") 
BasicDataSource hiveDataSource() { 
    BasicDataSource basicDataSource = new BasicDataSource(); 

    // Note: In a separate command window, use port forwarding like this: 
    // 
    // ssh -L 127.0.0.1:9996:<server>:<port> -l <userid> <server> 
    // 
    // and then login as the generic user. 

    basicDataSource.setDriverClassName("org.apache.hadoop.hive.jdbc.HiveDriver"); 
    basicDataSource.setUrl("jdbc:hive://127.0.0.1:9996:10000/mytable"); 
    return basicDataSource; 
} 

을 그리고이 예외를 가지고 :

Exception in thread "main" 
org.springframework.beans.factory.BeanCreationException: Error 
creating bean with name 
'org.springframework.boot.actuate.autoconfigure.EndpointAutoConfiguration': 
Injection of autowired dependencies failed; nested exception is 
org.springframework.beans.factory.BeanCreationException: Could not 
autowire field: private javax.sql.DataSource 
org.springframework.boot.actuate.autoconfigure.EndpointAutoConfiguration.dataSource; 
nested exception is 
org.springframework.beans.factory.NoUniqueBeanDefinitionException: No 
qualifying bean of type [javax.sql.DataSource] is defined: expected 
single matching bean but found 2: metadataDataSource,hiveDataSource 

다른 클래스는 이러한 콩 참조됩니다 다음과 같습니다 :

개 공용 클래스는 MetadataProcessorImpl는 MetadataProcessor를 구현 {@Bean를 사용하는 경우

@Autowired 
@Qualifier("metadataDataSource") 
BoneCPDataSource metadataDataSource; 

@Controller 공용 클래스 HiveController {

@Autowired 
@Qualifier("hiveDataSource") 
BasicDataSource hiveDataSource; 

Answer 1

은 콩에 다른 이름을 보내기

@Bean(name="bonecpDS") 
public BoneCPDataSource metadataDataSource() { 
    //... 
} 

@Bean(name="hiveDS") 
public BasicDataSource hiveDataSource() { 
    //... 
} 

을 그런 다음 주입 할 때 bean 인 경우 @Qualifier을 사용하고 bean의 이름을 지정하십시오.

@Component 
public class FooComponent { 
    @Autowired 
    @Qualifier("bonecpDS") 
    DataSource boneCPDataSource; 
} 

Answer 2

설정 섹션에 설명 된대로 @primary 으로 빔의 하나 67.2 구성 두 데이터 소스

http://docs.spring.io/spring-boot/docs/current-SNAPSHOT/reference/htmlsingle/#howto-two-datasources