9

我刚刚开始学习 Apache Camel。我了解了路由和组件的基础知识。现在我想尝试连接到 Oracle 数据库,从一个特定的表中读取记录,然后使用File组件将这些记录写入文件。要从数据库中读取,我假设我需要使用JDBC组件并提供dataSourceName.

但是,我找不到有关如何使用骆驼创建数据源的任何信息。我找到的与该主题相关的所有信息都使用 Spring DSL 示例。我不使用 Spring,我只需要使用简单的独立 Java 应用程序来测试它。

我将 JDK7u25 与 Apache Camel 2.12.1 一起使用。

有人可以发布一个示例以从 oracle 表中读取并写入文件吗?

[编辑]

在网上查看了几个解决方案后,我了解了以下两种方法:

  1. Camel 作为独立运行。这是我的代码:

    import javax.sql.DataSource;    
    import org.apache.camel.main.Main;
    import org.apache.camel.builder.RouteBuilder;
    import org.apache.commons.dbcp.BasicDataSource;
    
    public class JDBCExample {
    
        private Main main;
    
        public static void main(String[] args) throws Exception {
            JDBCExample example = new JDBCExample();
            example.boot();
        }
    
        public void boot() throws Exception {
            // create a Main instance
            main = new Main();
            // enable hangup support so you can press ctrl + c to terminate the JVM
            main.enableHangupSupport();
    
            String url = "jdbc:oracle:thin:@MYSERVER:1521:myDB";
            DataSource dataSource = setupDataSource(url);
    
            // bind dataSource into the registery
            main.bind("myDataSource", dataSource);
    
            // add routes
            main.addRouteBuilder(new MyRouteBuilder());
    
            // run until you terminate the JVM
            System.out.println("Starting Camel. Use ctrl + c to terminate the JVM.\n");
            main.run();
        }
    
        class MyRouteBuilder extends RouteBuilder {
            public void configure() {
                String dst = "C:/Local Disk E/TestData/Destination";
                from("direct:myTable")
                   .setBody(constant("select * from myTable"))
                   .to("jdbc:myDataSource")
                    .to("file:" + dst);
            }
        }
    
        private 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;
        }
    }
    
  2. 使用 Claus lbsen 提到的方法。这是代码:

    import javax.sql.DataSource;
    import org.apache.camel.CamelContext;
    import org.apache.camel.impl.DefaultCamelContext;
    import org.apache.camel.impl.SimpleRegistry;
    import org.apache.camel.main.Main;
    import org.apache.camel.builder.RouteBuilder;
    import org.apache.commons.dbcp.BasicDataSource;
    
    public class JDBCExample {
    
        private Main main;
    
        public static void main(String[] args) throws Exception {
            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 JDBCExample().new MyRouteBuilder());
            context.start();
            Thread.sleep(5000);
            context.stop();
        }
    
        class MyRouteBuilder extends RouteBuilder {
            public void configure() {
                String dst = "C:/Local Disk E/TestData/Destination";
                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;
        }
    }
    

但在这两种情况下,我都遇到了异常:

Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: jdbc://myDataSource due to: No component found with scheme: jdbc
    at org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:534)
    at org.apache.camel.util.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:63)
    at org.apache.camel.model.RouteDefinition.resolveEndpoint(RouteDefinition.java:192)
    at org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:106)
    at org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:112)
    at org.apache.camel.model.SendDefinition.resolveEndpoint(SendDefinition.java:61)
    at org.apache.camel.model.SendDefinition.createProcessor(SendDefinition.java:55)
    at org.apache.camel.model.ProcessorDefinition.makeProcessor(ProcessorDefinition.java:500)
    at org.apache.camel.model.ProcessorDefinition.addRoutes(ProcessorDefinition.java:213)
    at org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:909)
    ... 12 more
[Thread-0] INFO org.apache.camel.main.MainSupport$HangupInterceptor - Received hang up - stopping the main instance.
4

3 回答 3

8

有一个 SQL 示例,它显示了如何设置一个DataSource

是的,使用 Spring XML 的示例。但是如何设置 DataSource 也可以在 Java 代码中完成。然后你需要在 Camel Registry 中注册 DataSource。

例如,您可以使用 aJndiRegistrySimpleRegistry. 后者更容易。

这是一些伪代码,展示了创建注册表的原理,将您的 bean 添加到此注册表中,然后将注册表提供给DefaultCamelContext.

SimpleRegistry registry = new SimpleRegistry();

// code to create data source here
DateSource ds = ...

registry.put("myDataSource", ds);

CamelContext camel = new DefaultCamelContext(registry);
于 2013-10-14T10:03:06.337 回答
2

我太傻了!我没有在 CLASSPATH 中包含 camel-jdbc-2.12.1.jar。现在上面的例子有效。

于 2013-10-14T11:59:33.300 回答
0

在那里提到 Spring 只是因为它是使用 DB 的非常有用的范例(主要是因为Spring Framework 引入的模板。)当然,您可以连接标准的JDBC连接并自己实现 DAO——这没有错。

于 2013-10-14T09:53:40.837 回答