駱駝SQL - 將數據源放入Spring Boot中的SimpleRegistry

Question

我使用Spring Boot來啓動使用Camel-sql查詢MySQL數據庫並調用REST服務的駱駝路由。

application.properties中

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}"); 

    } 
} 

我在運行時看到下面的錯誤，發現Camel無法在註冊表中找到DataSource bean。我很不確定如何在Spring Boot中使用Java DSL將「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，你是指它使用#語法記載這裏的bean的名稱：http://camel.apache.org/how-do-i-configure-endpoints.html（指豆類）

所以東西都

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

其中dataSource是創建DataSource的bean的名稱，您可以給出其他名稱，例如

@Bean("myDataSource") 

然後駱駝SQL端點

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