Camel을 사용하여 데이터베이스에 파일 삽입

Question

Camel을 사용하여 원본 디렉토리에서 대상 디렉토리로 파일을 이동하는 경로를 작성했습니다. 이 파일을 데이터베이스로 옮기는 데 도움이 필요합니다. 이것은 다른 디렉토리로 파일을 이동하는 경로입니다 :

private static RouteBuilder createRouteBuilder() { 
    return new RouteBuilder() { 
     public void configure() { 
      from("file:data/outbox?idempotent=true&idempotentKey=${file:name}-${file:size}&noop=true&readLock=changed&delete=true") 
        .choice() 
        .when(header("CamelFileName").endsWith(".log")) 
        .process(new Processor() { 
         public void process(Exchange exchange) { 
          logger.log(Level.INFO, "File: " + exchange.getIn().getHeader("CamelFileName") + " has been updated"); 
         } 
        }) 
        .to("file:data/log"); 
     } 
    }; 
} 

내가 SqlComponent 같은 구성 요소를 사용하여 데이터베이스에 파일을 삽입하기 위해이 경로를 수정하는 방법? 스프링 부트 애플리케이션에서 H2 데이터베이스를 사용하여이 작업을 수행하려고합니다.

Answer 1

은 교체 :

.to("file:data/log"); 

와

.setBody(constant("select * from your query")) 
.to("jdbc:yourdatabase") 

는 또한이 종속성을 추가 :

<dependency> 
    <groupId>org.apache.camel</groupId> 
    <artifactId>camel-jdbc</artifactId> 
    <version>x.x.x</version> 
    <!-- use the same version as your Camel core version --> 
</dependency> 

Answer 2

기본적으로, 당신의 메시지 본문 파일입니다. 당신은 이것을 지속해야합니다. 이론적으로, 당신은 그것을 어디서나 지속하는 것을 포함하여 무엇이든하는 프로세서에 전달할 수 있습니다. 더 많은 표준 Camel 구성 요소를 사용하면 camel-jdbc 또는 camel-sql 또는 camel-jpa를 사용할 수 있습니다.

사용 낙타-SQL은 :

1. 당신은 URL의 일부로 삽입 문을 전달할 수 있습니다.
   : 위에서 아래에서

   from("file://c:/test/in1a?noop=true") 
       .convertBodyTo(String.class) 
       .setProperty("fileName", simple("${header.CamelFileAbsolutePath}")) 
       .setProperty("fileContents", body()) 
       .to("sql:insert into TEST1.FILE_UPLOAD (FILE_NAME, FILE_CONTENTS) 
         VALUES(:#${property.fileName} 
          , :#${property.fileContents})?dataSource=dsTest1"); 
   

   :

2. 그 전에, 당신은

코드는 다음과 같을 것 삽입 문에서 사용되는 매개 변수를 설정해야

1. insert 문은 원했던 문과 같습니다 (두 개의 열이있는 테이블을 가정했습니다). 또한 "위치 매개 변수"대신 " 매개 변수"를 사용할 수 있다고 가정했습니다. (Camel 2.14 이전 버전이 있다면 다른 접근 방법을 확인하십시오.)
2. 명명 된 매개 변수는 insert 문 앞에 속성으로 간단히 설정할 수 있습니다. 이것이 우리가 INSERT 전에 두 개의 "setProperty()"호출을하는 이유입니다.
3. 본문이 FILE로 시작하기 때문에 먼저이를 String으로 변환합니다. 파일에 이진 데이터가있는 경우 다른 데이터로 변환 할 수 있습니다. 그것은 Serializable 뭔가 있어야합니다.

또한 삽입에 데이터 소스의 이름 지정 옵션이 있음을 알 수 있습니다. 이 이름 (dsTest1)을 사용할 수 있어야합니다. 내 경우에는, 나는 나의 봄 구성에서 다음과 같은 한 :

<bean name="dsTest1" 
    class="org.springframework.jdbc.datasource.DriverManagerDataSource"> 
    <property name="driverClassName" value="com.mysql.jdbc.Driver" /> 
    <property name="url" value="jdbc:mysql://localhost:3306/test1" /> 
    <property name="username" value="user01" /> 
    <property name="password" value="password01" /> 
</bean> 

<bean name="route07Bean" class="com.mycompany.RouteBuilder07" /> 

<camelContext xmlns="http://camel.apache.org/schema/spring"> 

</camelContext> 

당신의 POM에 대한 종속성이 될 것입니다 :

<dependency> 
    <groupId>org.apache.camel</groupId> 
    <artifactId>camel-sql</artifactId> 
    <version>${camel-version}</version> 
</dependency> 

Here's a link to the Documentation for the SQL component