come creare l'origine dati usando cammello?

Question

Ho appena iniziato ad imparare Apache Camel. Ho capito le basi di Routes and Components. Ora voglio fare un tentativo connettendomi al database Oracle, leggendo i record da una particolare tabella e scrivendo quei record su un file usando il componente File. Per leggere dal database presumo che ho bisogno di utilizzare il componente JDBC e dare il dataSourceName.

Tuttavia, non ho trovato alcuna informazione su come creare un dataSource utilizzando cammello. Tutte le informazioni che ho trovato relative a questo argomento utilizzano gli esempi DSL di primavera. Io non uso Spring e ho solo bisogno di testare questo utilizzando l'applicazione Java standalone semplice.

Sto usando JDK7u25 con Apache Camel 2.12.1.

Qualcuno può pubblicare un campione per leggere dalla tabella dell'oracolo e scrivere in un file?

[EDIT]

Dopo aver controllato diverse soluzioni sul web, sono venuto a sapere di seguire due approcci:

1. Camel per l'esecuzione come standalone. Qui è il mio codice:

   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. Utilizzando l'approccio di cui parla Claus lbsen. Ecco il codice di nuovo:

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

Ma in entrambi i casi che sto ottenendo qui di seguito eccezione:

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. 

Answer 1

Così stupido! Non avevo incluso camel-jdbc-2.12.1.jar nel CLASSPATH. Ora sopra gli esempi funzionano.

Answer 2

Primavera è stato menzionato lì solo perché è molto utile paradigma di lavorare con DB (principalmente a causa di templates introduced by Spring Framework.) Naturalmente è possibile collegare la connessione standard JDBC e implementare DAO da soli - niente di male in questo.

Answer 3

c'è l'esempio di SQL che mostra come impostare un DataSource

• http://camel.apache.org/sql-example.html

Sì che gli esempi utilizzando XML Primavera. Ma come si imposta il DataSource può essere fatto anche in codice Java. Quindi è necessario registrare il DataSource nel Camel Registry.

Ad esempio è possibile utilizzare uno JndiRegistry o lo SimpleRegistry. Quest'ultimo è più facile.

Ecco alcuni pseudo-codice che mostrano il principio, di creare un registro, aggiungere i bean in questo registro e quindi fornire il registro al costruttore di DefaultCamelContext.

SimpleRegistry registry = new SimpleRegistry(); 

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

registry.put("myDataSource", ds); 

CamelContext camel = new DefaultCamelContext(registry);