java - Streaming 如何为 Mule 数据库连接器工作？

Question

我有一个流监听 HTTP 监听器，该流有以下消息处理器

1. 一个支持流的 Oracle 数据库消息处理器，它从一个表中选择 100 条记录，获取大小为 20。
2. 转换上述 org.mule.module.db.internal.result.resultset.ResultSetIterator 类型的有效载荷的表达式组件进入 java.util.List 类型的有效负载

根据我的理解，有效负载大小为 20，因为 Fetch Size 设置为 20。但是当我记录有效负载大小时，它是 100。

任何人都可以建议我对数据库连接器流式处理的理解是否正确？

Answer 1

这样做:

"org.mule.module.db.internal.result.resultset.ResultSetIterator into a payload of type java.util.List"

您正在一次性将其全部读入内存。您需要使用迭代器来处理每组 20 条记录。像这个简单的例子:

http://grepcode.com/file/repo1.maven.org/maven2/org.mule.modules/mule-module-db/3.5.0/integration/select/select-streaming-chunk-config.xml