如何利用兵变处理全部赔偿？

Question

在Quarkus和小黑麦叛变案中工作，我不知道如何处理赔偿。

我有一份员工名单，我必须更新数据库中的所有员工。数据访问对象（EmployeeDao）具有以下方法：public Uni

此外，我必须返回一个Uni

public Uni<Boolean> updateEmployees(List<Employee> employees) {
    for(Employee employee: employees) {
        //TODO: Execute or compensate
    }
}

我的问题是，如何逐个迭代执行更新过程并处理补偿？

如果任何员工更新过程失败，我想尝试几次，然后，如果我无法更新员工，我必须在返回任何响应之前撤消所有员工。其思想是保持数据库处于一致状态。

如何利用兵变处理全部赔偿？




Answer 1

如果我理解正确，那么您需要执行一组异步操作并将它们组合起来。为此，您可以执行以下操作：

List<Uni<?>> list = new ArrayList();
for(Employee employee: employees) {
   Uni<Void> uni = update(employee);
   list.add(uni);
}

return Uni.combine().all().unis(list)
   .with(list -> { /* all employees have been updated */ return true; })
   .onFailure().call(failure -> {
       Uni<?> uni = compensate();
       return uni.onItem().transform(x -> false);
   });

第一个外观为每个更新收集Unis。然后我们把这些结合起来。如果一切都很好，我们就很好，回归真实。如果发生了不好的事情，我们将进行补偿并返回false。