使用悲观锁在进程期间启动JPA事务提交

Question

我需要使用悲观锁执行批处理操作，以便在此操作期间没有其他人可以读取或写入此行。但是我想在每批之后增加页码，以便如果事务失败或实例死亡，我将从最后一页继续。但是使用下面的代码，它不会更新页面，直到所有批处理完成，所以当重新启动作业时，它会从页面=0开始处理。

@Transactional
public void process(long id) {
    Entity entity = repo.findById(id);
    processBatch(entity);
}

void processBatch(Entity entity) {
    int totalPages = otherMicroService.getTotalPages(id);
    int lastPage = entity.getPage();
    for(int page=lastPage; i<totalPages; i++) {
        doOperation();
        entity.setPage(page);
        repo.save(entity);
    }
}


@Lock(LockModeType.PESSIMISTIC_WRITE)
Optional<Entity> findById(int id);

有没有办法在每批启用悲观_写后更新页面？

提前谢谢。

Answer 1

我将添加@Transacti的（传播=Propagation.REQUIRES_NEW）到进程批处理，因此数据将在每次迭代时提交（btw，保存和保存将在这种情况下工作相同）。

请注意，添加此注释后，需要将< code>processBatch方法移动到单独的bean中(或者应该进行bean的自注入),以使Spring AOP正常工作。