java - jOOQ异步批量插入

Question

我想将大量行插入我的数据库。我已经看到 jOOQ 有批处理支持，所以我可以执行以下操作:

dslContext.batchInsert(myListOfRecords).execute()

但是，这是同义词。 jOOQ还有很多其他的异步API，有没有一个可以批量插入呢？

如果不是，简单地将对 execute 的调用包装在 CompletableFuture 中是否安全？

Answer 1

从 jOOQ 3.12 开始，org.jooq.Batch 类型上确实缺少这些 executeAsync() 方法。请参阅:https://github.com/jOOQ/jOOQ/issues/9806

但是，他们并没有做任何魔法。如果您查看 AbstractQuery.executeAsync(Executor) 的实现，您会发现它正在执行以下操作(从 jOOQ 3.12 开始):

@Override
public final CompletionStage<Integer> executeAsync(Executor executor) {
    return ExecutorProviderCompletionStage.of(
        CompletableFuture.supplyAsync(blocking(this::execute), executor), () -> executor
    );
}

jOOQ 做的两件事您可能不需要自己做:

1. 它将 CompletableFuture 包装在一个代理中，该代理保留对您的 Executor 的引用，以便在该执行器上运行后续任务。默认返回到常见的ForkJoinPool。在我看来，CompletableFuture 的设计存在重大错误。
2. 它将同步执行 (this::execute) 包装在 blocking() 包装器中，该包装器可以方便地将逻辑包装在 ForkJoinPool.managedBlock()。在 ForkJoinPool
中运行阻塞工作时建议这样做