从数据库读取数据并使用骆驼写入文件

我想从数据库读取数据并使用Camel将记录写入文件。以下是我的代码：从数据库读取数据并使用骆驼写入文件

import javax.sql.DataSource; 
import org.apache.camel.CamelContext; 
import org.apache.camel.builder.RouteBuilder; 
import org.apache.camel.impl.DefaultCamelContext; 
import org.apache.camel.impl.SimpleRegistry; 
import org.apache.commons.dbcp.BasicDataSource; 

public class JDBCExampleSimpleRegistry { 

    public static void main(String[] args) throws Exception { 
     final String url = "jdbc:oracle:thin:@MYSERVER:1521:myDB"; 
     DataSource dataSource = setupDataSource(url); 

     SimpleRegistry reg = new SimpleRegistry() ; 
     reg.put("myDataSource",dataSource); 

     CamelContext context = new DefaultCamelContext(reg); 
     context.addRoutes(new JDBCExampleSimpleRegistry().new MyRouteBuilder()); 

     context.start(); 
     Thread.sleep(5000); 
     context.stop(); 
    } 

    class MyRouteBuilder extends RouteBuilder { 
     public void configure() { 
      String dst = "C:/Local Disk E/TestData/Destination/?fileName=output.txt"; 
      from("direct:myTable") 
       .setBody(constant("select * from myTable")) 
       .to("jdbc:myDataSource") 
       .to("file://" + dst); 
     } 
    } 

    private static DataSource setupDataSource(String connectURI) { 
     BasicDataSource ds = new BasicDataSource(); 
     ds.setDriverClassName("oracle.jdbc.driver.OracleDriver"); 
     ds.setUsername("sa"); 
     ds.setPassword("devon1"); 
     ds.setUrl(connectURI); 
     return ds; 
    } 
}

上面的程序工作正常，CamelContext被优雅地关闭。但是，目标文件未创建。我究竟做错了什么？

我是Apache Camel的新手，非常感谢任何帮助。我在Apache Camel 2.12.1上使用JDK7，并没有使用Spring。

来源

2013-10-15 ParagJ

该路由将不会被执行，因为它从一个'direct：'端点开始。只有在另一条路由向其发送消息时，才能触发'direct：'端点。我完全不了解应用程序的完整要求。看起来你正试图实现一个控制台应用程序，它只能将一些数据从数据库写入文件一次。但我认为骆驼更适合服务。 –

由于你是骆驼新手，我建议阅读这篇文章：http://java.dzone.com/articles/open-source-integration-apache –

你可以看看SQL例子：http://camel.apache.org/sql-example.html，然后写入文件，仅仅是发送到一个文件，而不是调用豆作为SQL实例做的。

如果你想使用JDBC组件然后它没有内置的消费者，所以你需要使用定时器或石英调度运行路线每隔X时间触发的路线。

来源

2013-10-16 15:21:28

从数据库读取数据并使用骆驼写入文件

回答

相关问题