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のようなコンポーネントを使用してデータベースにファイルを挿入するには、このルートを変更することができますか？私はSpringブートアプリケーションでH2データベースを使ってこれをやろうとしています。

Answer 1

置き換えます

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

と

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

をも、この依存関係を追加：

<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

は基本的に、あなたのメッセージ本体はFILEです。これを維持しなければなりません。理論的には、どこにでも永続させるなど、何でもするプロセッサに渡すことができます。より多くの標準的なCamelコンポーネントを使用すると、camel-jdbc、またはcamel-sql、またはcamel-jpaを使用できます。

ラクダ-SQLを使用して：

1. をあなたがURLの一部としてinsert文を渡すことができます。
   ：に上から下から

   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. その前に、あなたは

コードは次のようになり insert文で使用されるパラメータを設定する必要があります

1. insert文は、あなたが望むものと同じです（私は の2つのカラムを持つテーブルを想定しています）。また、「位置パラメータ」の代わりに「 という名前のパラメータ」を使用できると仮定しました。 （Camel 2.14より前のものがあれば、他のアプローチについては文書をチェックしてください）
2. 名前付きパラメータは、単にinsert文の前にプロパティとして設定することができます。そのため、INSERTの前に2つの "setProperty（）"呼び出しがあります。
3. ボディはFILEとして開始されるので、まずそれをStringに変換します。ファイルにバイナリデータがある場合、それを別のものに変換することができます。シリアライズ可能なものである必要があります。

この挿入には、データソースの名前を付けるオプションもあります。この名前（dsTest1）を使用可能にする必要があります。私の場合、私は私のSpring構成で次のいます

<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