如何使用jOOQ非阻塞API以编程方式回滚事务？

首先明确：并非完全无法以编程方式回滚事务，只是你用错了API——当配置R2BDC ConnectionFactory时，jOOQ强制使用反应式编程模型，不能直接调用阻塞风格的executeAsync().await()这类方法，而RollbackToSavepointStep本身也不属于反应式流的Publisher类型，这才导致了报错。

错误原因解析 #

你遇到的DetachedException核心问题是：在仅配置R2BDC ConnectionFactory的场景下，jOOQ不允许执行阻塞方法（比如Query.execute()或ResultQuery.fetch()）。虽然jOOQ的RowCountQuery和ResultQuery实现了Publisher接口，可以通过Flux等反应式流订阅结果，但rollback()生成的RollbackToSavepointStep并没有实现该接口，无法直接套用反应式流用法；同时executeAsync().await()本质还是依赖阻塞调用逻辑，完全不符合R2BDC的反应式编程要求。

正确的编程式回滚姿势 #

要实现手动回滚，必须在jOOQ的反应式事务上下文内操作，核心是利用jOOQ提供的反应式事务API，而非直接调用dsl().rollback()：

1. 全局事务回滚
   使用DSLContext.transactional()的反应式重载版本，在事务回调中通过TransactionContext主动触发回滚：

dslContext.transactional(ctx -> {
    // 执行数据库操作逻辑...
    
    // 满足自定义条件时手动触发回滚
    if (needRollback) {
        ctx.rollback();
        return Mono.empty();
    }
    
    // 正常提交逻辑
    return Mono.just(/* 返回操作结果 */);
});

2. 回滚到指定保存点
   如果需要回滚到指定保存点，同样在事务上下文内完成操作：

dslContext.transactional(ctx -> {
    // 创建保存点
    Savepoint sp = ctx.setSavepoint("my_savepoint");
    
    // 执行部分数据库操作...
    
    // 触发回滚到保存点
    if (needRollbackToSavepoint) {
        ctx.rollbackToSavepoint(sp);
    }
    
    // 后续操作或提交逻辑
    return Mono.just(/* 返回结果 */);
});

补充说明 #

jOOQ文档虽未直接提及编程式回滚的具体方法，但反应式事务API本身就支持手动控制回滚——只要在事务回调的上下文中调用TransactionContext的回滚方法，jOOQ会自动适配R2BDC的反应式连接，彻底避免阻塞调用的问题。

内容的提问来源于stack exchange，提问作者Jakub Bochenski