apache camel如何从sql-component获取标题属性

2023-02-03 13:01:01 other 阅读：405
本文介绍了apache camel如何从sql-component获取标题属性的处理方法，对大家解决问题具有一定的参考价值

问题描述

我是 Apache Camel 的新手，我一直盯着编写一个从一个数据库中获取数据并将其插入另一个数据库的应用程序.我正在使用 sql 组件，并试图弄清楚如何使用 spring dsl 从消息头中获取 CamelSqlUpdateCount、CamelSqlRowCount 和 CamelSqlQuery.

我知道我可以使用这个来获取数据中的属性......

<log message="加工产品${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 server 来选择和 mysql 来插入.有谁知道可能出了什么问题?

我已经附加了一些来自跟踪的示例输出...

2013-09-04,21:11:55.615,MacBook-local >>>(processProduct-route) from(sourceSql://SELECT%20TOP%205%20product_id%20FROM%20product_) -->日志[SELECT,${header.CamelSqlQuery},${header.CamelSqlRowCount}] <<<模式:InOnly，标题:{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}] -->多播 <<<模式:InOnly，标题:{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) <<<模式:InOnly，标题:{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_) -->日志[INSERT,CONV_STG,${header.CamelSqlQuery},${header.CamelSqlUpdateCount}] <<<模式:InOnly，标题:{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_) -->日志[INSERT,CONV_ORIG,${header.CamelSqlQuery},${header.CamelSqlUpdateCount}] <<<模式:InOnly，标题:{breadcrumbId=MacBook}，BodyType:org.springframework.util.LinkedCaseInsensitiveMap，Body:{product_id=273}

下面是 sql 语句的样子...

sql.selectProduct=SELECT TOP 5 product_id FROM product_sql.insertProductOrig=插入 conv_orig_product_ (product_id) 值 (:#product_id)

这是我 POM 的摘录，用于显示我正在使用的 jdbc 驱动程序...

<依赖性><groupId>net.sourceforge.jtds</groupId><artifactId>jtds</artifactId><版本>1.3.0</版本></依赖><!-- MySQL 数据库驱动程序--><依赖性><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><版本>5.1.9</版本></依赖>

谢谢

解决方案

这看起来像是一个最终用户问题.

<块引用>

2013-09-04,21:11:55.625,MacBook-local >>>(processProduct-route) log[SELECT,${header.CamelSqlQuery},${header.CamelSqlRowCount}] -->多播 <<<模式:InOnly，标题:{breadcrumbId=MacBook-local}，BodyType:org.springframework.util.LinkedCaseInsensitiveMap，Body:{product_id=273}

来自跟踪日志的详细信息表明正在使用多播 EIP(见上文).当你这样做时，多播复制了传入的消息(原始消息)，每个接收者都会得到那个原始"消息的副本.这样就可以解释为什么这些标头不存在，因为原始副本没有 SQL 更新标头.

所以删除多播并使用直接管道.

您可以在此处阅读有关多播和管道的信息

I'm new to Apache Camel and I've stared to write an application that grabs data from one database and inserts it to another database. I'm using the sql component and am trying to figure out how to grab the CamelSqlUpdateCount, CamelSqlRowCount and CamelSqlQuery from the message header using spring dsl.

I know that I can get attributes in the data using this....

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

But when I try to grab data from my header after my insert like this...

<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"/>

it comes back empty. After getting advice on turning on a trace in my route to see what is coming back in the message headers I can see that those header attributes are not there. I am connecting to sql server to select and mysql to insert. does anyone know what might be wrong?

I've attached some sample output from the trace...

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}

Here are what the sql statements look like...

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

Here is an extract from my POM to show what jdbc drivers I am using...

<!-- 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>

thanks

解决方案

This looks like an end user issue. 

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}

The details from the trace logging indicates a multicast EIP is in use (see above). And when you do that then the multicast copied the incoming message (original message), and each receiver gets a copy of that "original" message. So that would explain why these headers is not there, as the original copy does not have the SQL update headers.

So remove the multicast and just use a straight pipeline.

You can read about multicast and pipeline here

这篇关于apache camel如何从sql-component获取标题属性的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，WP2

admin_action_{$_REQUEST[‘action’]}

do_action( "admin_action_{$_REQUEST[‘action’]}" )动作钩子：：在发送“Action”请求变量时激发。Action Hook: Fires when an ‘action’ request variable is sent.目录锚点：#说明#源码说明（Description）钩子名称的动态部分$_REQUEST['action']引用从GET或POST请求派生的操作。源码（Source）更新版本源码位置使用被使用2.6.0 wp-admin/admin.php:...

日期：2020-09-02 17:44:16 浏览：1169

admin_footer-{$GLOBALS[‘hook_suffix’]}

do_action( "admin_footer-{$GLOBALS[‘hook_suffix’]}", string $hook_suffix )操作挂钩：在默认页脚脚本之后打印脚本或数据。Action Hook: Print scripts or data after the default footer scripts.目录锚点：#说明#参数#源码说明（Description）钩子名的动态部分，$GLOBALS['hook_suffix']引用当前页的全局钩子后缀。参数（Parameters）参数类...

日期：2020-09-02 17:44:20 浏览：1070

customize_save_{$this->id_data[‘base’]}

do_action( "customize_save_{$this-&gt;id_data[‘base’]}", WP_Customize_Setting $this )动作钩子：：在调用WP_Customize_Setting：：save（）方法时激发。Action Hook: Fires when the WP_Customize_Setting::save() method is called.目录锚点：#说明#参数#源码说明（Description）钩子名称的动态部分，$this->id_data...

日期：2020-08-15 15:47:24 浏览：806

customize_value_{$this->id_data[‘base’]}

apply_filters( "customize_value_{$this-&gt;id_data[‘base’]}", mixed $default )过滤器：：过滤未作为主题模式或选项处理的自定义设置值。Filter Hook: Filter a Customize setting value not handled as a theme_mod or option.目录锚点：#说明#参数#源码说明（Description）钩子名称的动态部分，$this->id_date['base']，指的是设置...

日期：2020-08-15 15:47:24 浏览：899

get_comment_author_url

过滤钩子：过滤评论作者的URL。Filter Hook: Filters the comment author’s URL.目录锚点：#源码源码（Source）更新版本源码位置使用被使用 wp-includes/comment-template.php:32610...

日期：2020-08-10 23:06:14 浏览：930

network_admin_edit_{$_GET[‘action’]}

do_action( "network_admin_edit_{$_GET[‘action’]}" )操作挂钩：启动请求的处理程序操作。Action Hook: Fires the requested handler action.目录锚点：#说明#源码说明（Description）钩子名称的动态部分$u GET['action']引用请求的操作的名称。源码（Source）更新版本源码位置使用被使用3.1.0 wp-admin/network/edit.php:3600...

日期：2020-08-02 09:56:09 浏览：877

network_sites_updated_message_{$_GET[‘updated’]}

apply_filters( "network_sites_updated_message_{$_GET[‘updated’]}", string $msg )筛选器挂钩：在网络管理中筛选特定的非默认站点更新消息。Filter Hook: Filters a specific, non-default site-updated message in the Network admin.目录锚点：#说明#参数#源码说明（Description）钩子名称的动态部分$_GET['updated']引用了非默认的...

日期：2020-08-02 09:56:03 浏览：864

pre_wp_is_site_initialized

过滤器：：过滤在访问数据库之前是否初始化站点的检查。Filter Hook: Filters the check for whether a site is initialized before the database is accessed.目录锚点：#源码源码（Source）更新版本源码位置使用被使用 wp-includes/ms-site.php:93910...

日期：2020-07-29 10:15:38 浏览：834

WordPress 的SEO 教学：如何在网站中加入关键字（Meta Keywords）与Meta 描述（Meta Description）？

你想在WordPress 中添加关键字和meta 描述吗？关键字和meta 描述使你能够提高网站的SEO。在本文中，我们将向你展示如何在WordPress 中正确添加关键字和meta 描述。为什么要在WordPress 中添加关键字和Meta 描述？关键字和说明让搜寻引擎更了解您的帖子和页面的内容。关键词是人们寻找您发布的内容时，可能会搜索的重要词语或片语。而Meta Description则是对你的页面和文章的简要描述。如果你想要了解更多关于中继标签的资讯，可以参考Google的说明。Meta 关键字和描...

日期：2020-10-03 21:18:25 浏览：1726

谷歌的SEO是什么

SEO (Search Engine Optimization)中文是搜寻引擎最佳化，意思近于「关键字自然排序」、「网站排名优化」。简言之，SEO是以搜索引擎（如Google、Bing）为曝光媒体的行销手法。例如搜寻「wordpress教学」，会看到本站的「WordPress教学：12个课程…」排行Google第一：关键字：wordpress教学、wordpress课程…若搜寻「网站架设」，则会看到另一个网页排名第1：关键字：网站架设、架站…以上两个网页，每月从搜寻引擎导入自然流量，达2万4千：每月「有机搜...

日期：2020-10-30 17:23:57 浏览：1308