mysql - 如何使用 CAMEL 批量处理 SQL 查询的结果？

Question

我想批量发送 sql 查询的结果示例:如果我们有 5000 行作为 sql 查询结果，我们将对其进行 1000 x 1000 处理。

这是路线:

<from uri="sql:select * from params?dataSource=moodleDB"/>
<split>
  <simple>body</simple>
  <setBody>
    <simple>My_URI_Params</simple>
  </setBody>
  <to uri="http://URI"/>
  <log message="Response: ${property.CamelSplitIndex} "/>
</split>

我该怎么做？

Answer 1

我想不出通过 DSL 实现这一点的简单方法，但您可以轻松实现自己的拆分 bean 来管理这种情况。

from("sql party")
    .split().method("springBeanName", "method")
        .to("some other process")
        .log("camel rocks!")
    .end()
    .to("Any process you want when camel is done");

您的 bean 方法将如下所示(显然是 1000 行而不是每行的逻辑):

public String[] split(String body) {
    String[] split = body.split("\n");
    return split;
}