Advertisement
Guest User

Untitled

a guest
Aug 15th, 2016
82
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 4.42 KB | None | 0 0
  1. import javax.sql.DataSource;
  2. import org.apache.camel.main.Main;
  3. import org.apache.camel.builder.RouteBuilder;
  4. import org.apache.commons.dbcp.BasicDataSource;
  5.  
  6. public class JDBCExample {
  7.  
  8. private Main main;
  9.  
  10. public static void main(String[] args) throws Exception {
  11. JDBCExample example = new JDBCExample();
  12. example.boot();
  13. }
  14.  
  15. public void boot() throws Exception {
  16. // create a Main instance
  17. main = new Main();
  18. // enable hangup support so you can press ctrl + c to terminate the JVM
  19. main.enableHangupSupport();
  20.  
  21. String url = "jdbc:oracle:thin:@MYSERVER:1521:myDB";
  22. DataSource dataSource = setupDataSource(url);
  23.  
  24. // bind dataSource into the registery
  25. main.bind("myDataSource", dataSource);
  26.  
  27. // add routes
  28. main.addRouteBuilder(new MyRouteBuilder());
  29.  
  30. // run until you terminate the JVM
  31. System.out.println("Starting Camel. Use ctrl + c to terminate the JVM.n");
  32. main.run();
  33. }
  34.  
  35. class MyRouteBuilder extends RouteBuilder {
  36. public void configure() {
  37. String dst = "C:/Local Disk E/TestData/Destination";
  38. from("direct:myTable")
  39. .setBody(constant("select * from myTable"))
  40. .to("jdbc:myDataSource")
  41. .to("file:" + dst);
  42. }
  43. }
  44.  
  45. private DataSource setupDataSource(String connectURI) {
  46. BasicDataSource ds = new BasicDataSource();
  47. ds.setDriverClassName("oracle.jdbc.driver.OracleDriver");
  48. ds.setUsername("sa");
  49. ds.setPassword("devon1");
  50. ds.setUrl(connectURI);
  51. return ds;
  52. }
  53. }
  54.  
  55. import javax.sql.DataSource;
  56. import org.apache.camel.CamelContext;
  57. import org.apache.camel.impl.DefaultCamelContext;
  58. import org.apache.camel.impl.SimpleRegistry;
  59. import org.apache.camel.main.Main;
  60. import org.apache.camel.builder.RouteBuilder;
  61. import org.apache.commons.dbcp.BasicDataSource;
  62.  
  63. public class JDBCExample {
  64.  
  65. private Main main;
  66.  
  67. public static void main(String[] args) throws Exception {
  68. String url = "jdbc:oracle:thin:@MYSERVER:1521:myDB";
  69. DataSource dataSource = setupDataSource(url);
  70.  
  71. SimpleRegistry reg = new SimpleRegistry() ;
  72. reg.put("myDataSource",dataSource);
  73.  
  74. CamelContext context = new DefaultCamelContext(reg);
  75. context.addRoutes(new JDBCExample().new MyRouteBuilder());
  76. context.start();
  77. Thread.sleep(5000);
  78. context.stop();
  79. }
  80.  
  81. class MyRouteBuilder extends RouteBuilder {
  82. public void configure() {
  83. String dst = "C:/Local Disk E/TestData/Destination";
  84. from("direct:myTable")
  85. .setBody(constant("select * from myTable"))
  86. .to("jdbc:myDataSource")
  87. .to("file:" + dst);
  88. }
  89. }
  90.  
  91. private static DataSource setupDataSource(String connectURI) {
  92. BasicDataSource ds = new BasicDataSource();
  93. ds.setDriverClassName("oracle.jdbc.driver.OracleDriver");
  94. ds.setUsername("sa");
  95. ds.setPassword("devon1");
  96. ds.setUrl(connectURI);
  97. return ds;
  98. }
  99. }
  100.  
  101. Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: jdbc://myDataSource due to: No component found with scheme: jdbc
  102. at org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:534)
  103. at org.apache.camel.util.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:63)
  104. at org.apache.camel.model.RouteDefinition.resolveEndpoint(RouteDefinition.java:192)
  105. at org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:106)
  106. at org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:112)
  107. at org.apache.camel.model.SendDefinition.resolveEndpoint(SendDefinition.java:61)
  108. at org.apache.camel.model.SendDefinition.createProcessor(SendDefinition.java:55)
  109. at org.apache.camel.model.ProcessorDefinition.makeProcessor(ProcessorDefinition.java:500)
  110. at org.apache.camel.model.ProcessorDefinition.addRoutes(ProcessorDefinition.java:213)
  111. at org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:909)
  112. ... 12 more
  113. [Thread-0] INFO org.apache.camel.main.MainSupport$HangupInterceptor - Received hang up - stopping the main instance.
  114.  
  115. SimpleRegistry registry = new SimpleRegistry();
  116.  
  117. // code to create data source here
  118. DateSource ds = ...
  119.  
  120. registry.put("myDataSource", ds);
  121.  
  122. CamelContext camel = new DefaultCamelContext(registry);
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement