Mutiny/JOOQ异步事务处理：双插入失败无回滚问题排查

针对你遇到的「单事务中第二个插入触发非空约束失败，但第一个对象仍被保存」的问题，可按以下步骤排查修复：

1. 确认事务注解的正确使用 #

• 确保执行双插入的业务方法上添加了jakarta.transaction.Transactional注解，且该方法是通过Quarkus代理调用（禁止同一类内部直接调用事务方法，会绕过代理导致事务不生效）。
• 示例正确写法：

@ApplicationScoped
public class BizService {
    private final ObjectRepo repo;

    public BizService(ObjectRepo repo) {
        this.repo = repo;
    }

    @Transactional // 必须添加此注解
    public void saveTwoObjects(Object1 obj1, Object2 obj2) {
        repo.insert(obj1);
        repo.insert(obj2); // 触发异常后，整个事务回滚
    }
}

2. 检查Repo层的事务绑定 #

• 确保Repo中使用的DSLContext是Quarkus注入的实例，而非手动创建的DSL.using(connection)——手动创建的上下文不会参与Quarkus的事务管理。
• 禁止在Repo的insert方法中使用dsl.transaction()或dsl.transactionResult()，这类方法会创建独立嵌套事务，不受外层@Transactional控制。
• 正确的Repo实现：

@ApplicationScoped
public class ObjectRepo {
    private final DSLContext dsl;

    // 依赖注入Quarkus管理的DSLContext
    public ObjectRepo(DSLContext dsl) {
        this.dsl = dsl;
    }

    public void insert(Object1 obj1) {
        dsl.insertInto(TABLE1)
           .set(TABLE1.ID, obj1.getId())
           .set(TABLE1.NAME, obj1.getName())
           .execute(); // 直接执行，不手动管理事务
    }
}

3. 排查异常处理逻辑 #

• 禁止在事务方法内部捕获异常后吞掉（仅打印日志不抛出），这会导致Quarkus事务管理器无法感知异常，从而不会触发回滚。
• 若需自定义异常处理，必须将异常重新抛出，或在@Transactional注解中指定rollbackOn属性明确触发回滚的异常类型：

@Transactional(rollbackOn = {SQLException.class, RuntimeException.class})
public void saveTwoObjects(Object1 obj1, Object2 obj2) throws SQLException {
    try {
        repo.insert(obj1);
        repo.insert(obj2);
    } catch (SQLException e) {
        log.error("插入失败", e);
        throw e; // 必须重新抛出
    }
}

4. 验证Quarkus配置正确性 #

检查application.properties中的核心配置，确保事务支持正常开启：

# 数据源配置（以PostgreSQL为例）
quarkus.datasource.db-kind=postgresql
quarkus.datasource.username=your_user
quarkus.datasource.password=your_pass
quarkus.datasource.jdbc.url=jdbc:postgresql://localhost:5432/your_db

# jOOQ配置
quarkus.jooq.sql-dialect=POSTGRES
# 默认事务管理器已集成，无需额外开启，若手动修改过需恢复默认
# quarkus.jooq.transaction-manager-enabled=true

5. 确认数据库事务支持 #

确保你的数据库引擎支持事务（如MySQL需使用InnoDB引擎，而非MyISAM），否则即使框架层面配置正确，数据库本身也无法回滚。

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