2

私は Apache Camel を初めて使用し、あるデータベースからデータを取得して別のデータベースに挿入するアプリケーションを書き始めました。私はSQLコンポーネントを使用しており、Spring DSLを使用してメッセージヘッダーからCamelSqlUpdateCount、CamelSqlRowCount、およびCamelSqlQueryを取得する方法を見つけようとしています。

これを使用してデータの属性を取得できることを知っています....

<log message="Processing product ${body[product_id]}"/>

しかし、このように挿入した後、ヘッダーからデータを取得しようとすると...

<from uri="sourceSql:{{sql.selectProduct}}"/>
<log message="SELECT,${header.CamelSqlQuery},${header.CamelSqlRowCount}" loggingLevel="INFO" logName="db_log"/>
<to uri="targetSql:{{sql.insertProductOrig}}"/>     
<log message="INSERT,CONV_ORIG,${header.CamelSqlQuery},${header.CamelSqlUpdateCount}" loggingLevel="INFO" logName="db_log"/>

それは空に戻ります。ルートでトレースをオンにして、メッセージ ヘッダーに何が返されているかを確認するためのアドバイスを受けた後、それらのヘッダー属性がそこにないことがわかります。選択するためにSQLサーバーに接続し、挿入するためにmysqlに接続しています。誰が何が間違っているのか知っていますか?

トレースからのサンプル出力をいくつか添付しました...

2013-09-04,21:11:55.615,MacBook-local >>> (processProduct-route) from(sourceSql://SELECT%20TOP%205%20product_id%20FROM%20product_) --> log[SELECT,${header.CamelSqlQuery},${header.CamelSqlRowCount}] <<< Pattern:InOnly, Headers:{breadcrumbId=MacBook-local}, BodyType:org.springframework.util.LinkedCaseInsensitiveMap, Body:{product_id=273}
    2013-09-04,21:11:55.625,MacBook-local >>> (processProduct-route) log[SELECT,${header.CamelSqlQuery},${header.CamelSqlRowCount}] --> multicast <<< Pattern:InOnly, Headers:{breadcrumbId=MacBook-local}, BodyType:org.springframework.util.LinkedCaseInsensitiveMap, Body:{product_id=273}
    2013-09-04,21:11:55.644,MacBook-local >>> (processProduct-route) from(sourceSql://SELECT%20TOP%205%20product_id%20FROM%20product_) --> targetSql://insert%20into%20conv_stg_product_%20(product_id)%20values%20(:%23product_id) <<< Pattern:InOnly, Headers:{breadcrumbId=MacBook-local}, BodyType:org.springframework.util.LinkedCaseInsensitiveMap, Body:{product_id=273}
    2013-09-04,21:11:55.646,MacBook-local >>> (processProduct-route) from(sourceSql://SELECT%20TOP%205%20product_id%20FROM%20product_) --> log[INSERT,CONV_STG,${header.CamelSqlQuery},${header.CamelSqlUpdateCount}] <<< Pattern:InOnly, Headers:{breadcrumbId=MacBook}, BodyType:org.springframework.util.LinkedCaseInsensitiveMap, Body:{product_id=273}
    2013-09-04,21:11:55.642,MacBook >>> (processProduct-route) from(sourceSql://SELECT%20TOP%205%20product_id%20FROM%20product_) --> log[INSERT,CONV_ORIG,${header.CamelSqlQuery},${header.CamelSqlUpdateCount}] <<< Pattern:InOnly, Headers:{breadcrumbId=MacBook}, BodyType:org.springframework.util.LinkedCaseInsensitiveMap, Body:{product_id=273}

SQLステートメントは次のようになります...

sql.selectProduct=SELECT TOP 5 product_id FROM product_
sql.insertProductOrig=insert into conv_orig_product_ (product_id) values (:#product_id)

これは、私が使用しているjdbcドライバーを示す私のPOMからの抜粋です...

<!-- SQL Server database driver -->
<dependency>
    <groupId>net.sourceforge.jtds</groupId>
    <artifactId>jtds</artifactId>
    <version>1.3.0</version>
</dependency>  

<!-- MySQL database driver -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.9</version>
</dependency>

ありがとう

4

1 に答える 1

2

これはエンド ユーザーの問題のようです。

2013-09-04,21:11:55.625,MacBook-local >>> (processProduct-route) log[SELECT,${header.CamelSqlQuery},${header.CamelSqlRowCount}] --> multicast <<< Pattern:InOnly, Headers:{breadcrumbId=MacBook-local}, BodyType:org.springframework.util.LinkedCaseInsensitiveMap, Body:{product_id=273}

トレース ログの詳細は、マルチキャスト EIP が使用されていることを示しています (上記を参照)。そして、それを行うと、マルチキャストは着信メッセージ (元のメッセージ) をコピーし、各受信者はその「元の」メッセージのコピーを取得します。元のコピーにはSQL更新ヘッダーがないため、これらのヘッダーが存在しない理由を説明できます。

したがって、マルチキャストを削除して、ストレート パイプラインを使用してください。

ここでマルチキャストとパイプラインについて読むことができます

于 2013-09-06T07:01:42.813 に答える