Scalikejdbc 查询结果作为流

【问题标题】：Scalikejdbc query results as a streamScalikejdbc 查询结果作为流
【发布时间】：2015-03-03 19:51:33
【问题描述】：

对于非常大的数据集，是否可以将 scalikejdbc 查询的结果返回为 Stream？即光标在哪里保持打开直到流用完以节省内存使用？如果有，怎么做？

【问题讨论】：

【解决方案1】：

您可以通过 session.toStatementExecutor 返回您自己的迭代器，但是您必须手动关闭事物或将语句和会话包装在一个对象中，然后您可以在完成后调用 close。

【讨论】：

【解决方案2】：

【讨论】：

通过使用foreach 获得具有背压的流的全部功能似乎并非易事。这是我找到的一个实现 github.com/longcao/reactive-streams-end-to-end-example 能否请您添加一个带有 foreach 和流实现的示例