171.6. Samples

在以下示例中，我们从客户表中获取相应的行。

首先，在 Camel 注册表中将数据源注册为 testdb ：

然后，我们将配置路由到 JDBC 组件的路由，因此将执行 SQL。请注意，我们如何引用上一步中绑定的 testdb 数据源：

或者您可以在 Spring 中创建 DataSource，如下所示：

我们创建一个端点，将 SQL 查询添加到 IN 消息的正文中，然后发送交换。查询的结果在 OUT 正文中返回：

如果您需要一次使用 Splitter EIP，例如：

在 Camel 2.13.x 中或更早的版本

在 Camel 2.14.x 中，或更新

from("direct:hello")
// here we split the data from the testdb into new messages one by one
// so the mock endpoint will receive a message per row in the table
// the StreamList option allows to stream the result of the query without creating a List of rows
// and notice we also enable streaming mode on the splitter
.to("jdbc:testdb?outputType=StreamList")
  .split(body()).streaming()
  .to("mock:result");

from("direct:hello")
// here we split the data from the testdb into new messages one by one
// so the mock endpoint will receive a message per row in the table
// the StreamList option allows to stream the result of the query without creating a List of rows
// and notice we also enable streaming mode on the splitter
.to("jdbc:testdb?outputType=StreamList")
  .split(body()).streaming()
  .to("mock:result");

Copy to Clipboard

Toggle word wrap

返回顶部

171.6. Samples

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links