本文详解如何使用 JOOQ 的 fetchLazy() 与 Cursor 实现内存友好的分页流式处理，避免一次性加载全部 20 万+ 记录，通过内部迭代（回调式消费）实现每批 1000 条的可控、低开销批量处理。
本文详解如何使用 jooq 的 `fetchlazy()` 与 `cursor` 实现内存友好的分页流式处理，避免一次性加载全部 20 万+ 记录，通过内部迭代（回调式消费）实现每批 1000 条的可控、低开销批量处理。
在处理大规模数据库表（如超 20 万行记录）时，直接调用 fetch() 全量加载极易引发内存溢出（OOM）、GC 压力剧增及响应延迟等问题。JOOQ 提供了高效的流式查询能力——fetchLazy() 返回一个 Cursor<t></t>，它底层基于 JDBC ResultSet 的游标机制，支持按需拉取、延迟加载，是解决大数据量处理的理想方案。
关键在于采用内部迭代（Internal Iteration）而非外部循环：不应将 Cursor 暴露给业务层自行遍历，而应由持久层封装游标生命周期，并通过函数式接口（如 Consumer<list>></list>）将每批数据“推送”给业务逻辑。这不仅确保资源自动释放（借助 try-with-resources），还消除了手动状态管理（如偏移量、游标位置）的错误风险。
以下是推荐的实现方式：
class RecordService {
private final RecordPersistence recordPersistence = new RecordPersistence();
public void processRecords() {
recordPersistence.fetchRecordsInBatches(1000, records -> {
// ✅ 每次接收 exactly 1000 条（最后一组可能更少）
System.out.println("Processing batch of " + records.size() + " records");
records.forEach(this::processSingleRecord);
// 可在此处提交事务、更新进度、触发下游任务等
});
}
private void processSingleRecord(Record record) {
// 实际业务处理逻辑，例如转换、校验、写入其他系统等
}
}
class RecordPersistence {
private final DSLContext dsl; // 注入的 JOOQ DSLContext
public RecordPersistence(DSLContext dsl) {
this.dsl = dsl;
}
/**
* 分批拉取并消费记录，每批 size 条
* @param batchSize 每批记录数（建议 500–5000，依单条数据大小和 JVM 内存调整）
* @param consumer 批处理消费者，接收当前批次 List<record>
*/
public void fetchRecordsInBatches(int batchSize, Consumer super List<record>> consumer) {
// 构建查询（务必包含明确 ORDER BY，保证分批一致性！）
SelectSeekStepN<record> query = dsl
.selectFrom(table("records"))
.orderBy(field("id")); // ⚠️ 必须指定稳定排序字段（如主键）
try (Cursor<record> cursor = query.fetchLazy()) {
while (cursor.hasNext()) {
List<record> batch = cursor.fetchNext(batchSize);
if (!batch.isEmpty()) {
consumer.accept(batch);
}
}
} // ✅ 自动关闭 Cursor 和 underlying ResultSet
}
}</record></record></record></record></record>
重要注意事项：
-
必须指定
ORDER BY：fetchLazy()不保证顺序稳定性，若无显式排序，分批结果可能重复或遗漏。推荐使用主键或唯一递增字段排序； -
避免
OFFSET/LIMIT分页：对 20 万+ 数据，深度分页（如OFFSET 199000 LIMIT 1000）性能急剧下降，Cursor是更优解； - 合理设置批次大小：过小（如 10）增加 IO 轮次；过大（如 10000）可能挤占堆内存。建议从 1000 开始压测调整；
-
事务与异常处理：若每批需独立事务，请在
consumer内部开启/提交；全局长事务不推荐，易锁表； -
无需异步化：本方案本质是同步流式处理，I/O 阻塞已由 JDBC 驱动优化，引入
CompletableFuture或 Reactive 并不提升吞吐，反而增加复杂度。
总结：利用 JOOQ 的 Cursor + 回调式消费模式，以简洁、健壮、低内存占用的方式完成海量数据批处理——这是面向吞吐与稳定性的工程最佳实践，无需范式切换，只需一次设计重构。
