Camel SQL - Spring 부트에서 SimpleRegistry에 DataSource 넣기

Question

스프링 부트를 사용하여 Camel-SQL을 사용하여 MySQL DB를 쿼리하고 REST 서비스를 호출하는 낙타 경로를 시작합니다.

는

db.driver=com.mysql.jdbc.Driver 
db.url=mysql://IP:PORT/abc 
db.username=abc 
db.password=pwd 

에게 Application.java

public static void main(String[] args) { 
    SpringApplication.run(WlEventNotificationBatchApplication.class, args); 

} 

DataSourceConfig.java

public class DataSourceConfig { 

    @Value("${db.driver}") 
    public String dbDriver; 

    @Value("${db.url}") 
    public String dbUrl; 

    @Value("${db.username}") 
    public String dbUserName; 

    @Value("${db.password}") 
    public String dbPassword; 
    @Bean("dataSource") 
    public DataSource getConfig() { 
     DriverManagerDataSource dataSource = new DriverManagerDataSource(); 

     dataSource.setDriverClassName(dbDriver); 
     dataSource.setUrl(dbUrl); 
     dataSource.setUsername(dbUserName); 
     dataSource.setPassword(dbPassword); 

     return dataSource; 
    } 
} 

WLRouteBuilder.java

@Component 
public class WLRouteBuilder extends RouteBuilder { 
    @Autowired 
    private NotificationConfig notificationConfig; 

    @Autowired 
    private DataSource dataSource; 

    @Override 
    public void configure() throws Exception { 

     from("direct:eventNotification") 
       .to("sql:"+notificationConfig.getSqlQuery()+"?dataSource="+dataSource) 
       .process(new RowMapper()) 
       .log("${body}"); 

    } 
} 

가있는 application.properties

나는 낙타가 레지스트리에서 DataSource 빈을 찾을 수 없다는 것을 알게되었다. Java DSL을 사용하는 Spring Boot의 레지스트리에 "DataSource"를 주입하는 방법을 잘 모르겠습니다.

?dataSource=org.springframework.jdbc.datasource.DriverManagerDataSource%40765367 due to: No bean could be found in the registry for: org.springframework.jdbc.datasource.DriverManagerDataSource@765367 of type: javax.sql.DataSource 

Answer 1

그 낙타가 여기에 설명 된대로 당신이 # 구문을 사용하여 참조하는 URI에 사용하는 빈의 이름 : http://camel.apache.org/how-do-i-configure-endpoints.html (참조 콩)

그래서 모두 뭔가

.to("sql:"+notificationConfig.getSqlQuery()+"?dataSource=#dataSource" 

은 DataSource을 만드는 빈의 이름이며 다른 이름을 지정할 수 있습니다. 예 :

@Bean("myDataSource") 

그리고 낙타 SQL 엔드 포인트가

.to("sql:"+notificationConfig.getSqlQuery()+"?dataSource=#myDataSource"