更新一堆行是基于事务还是基于行？

Question

我有一个表，其中有一列需要不断地重新计算，我希望这个表是可扩展的。用户也必须能够在上面写字。

如果没有服务器和并发用户，很难测试这种类型的东西，至少我不知道如何。 那么这两个选项之一是否可行？

@ApplicationScoped
public class Abean {
   @EJB
   private MyService myService;
   @Asynchronous
   public void computeTheData(){
      long i = 1;
      long numberOfRows = myService.getCountRows(); // gives the number of row in the table
      while(i<numberOfRows){
        myService.updateMyRow(i);
      }
      computeTheData(); // recursion so it never stops, I'm wondering if this wouldn't spawn more threads and if it would be an issue.
   }
}

public class MyService implements MyServiceInterface{
    ...
    public void updateMyRows(int row){
       Query query = em.createQuery("SELECT m FROM MyEntity WHERE m.id=:id");
       Query.setParameter("id", row);
       List<MyEntity> myEntities = (MyEntity) query.getResultList();
       myEntity.computeData();
    }
}

VS

@ApplicationScoped
public class Abean {
   @EJB
   private MyService myService;
   @Asynchronous
   public void computeTheData(){
      myService.updateAllRows();
   }
}

public class MyService implements MyServiceInterface{
        ...
    public void updateAllRows(int page){
       Query query = em.createQuery("SELECT m FROM MyEntity");
       List<MyEntity> myEntities = (MyEntity) query.getResultList();
       myEntity.computeData();
    }
}

这些可行吗？我用的是mysql，表的引擎是innoDB。

Answer 1

您应该在更新之前使用悲观锁定来锁定修改的行，这样用户的手动修改不会与后台更新发生冲突。如果您不使用锁定，如果用户的修改与修改了同一行的后台作业发生冲突，有时会回滚。

此外，对于悲观锁定，如果您的用户的事务等待获取锁的时间超过超时发生时间，则她可能会遇到回滚。为了防止这种情况，您应该使所有使用悲观锁的事务尽可能短。因此，后台作业应该为每一行或一小组行创建一个新事务，如果它可能运行的时间超过合理的时间。只有在事务完成后才会释放锁（用户将等待锁被释放）。

MyService 的外观示例，在单独的事务中运行每个更新（实际上，您可以在单个事务中批量运行多个更新，将 id 列表或范围作为参数传递给 updateMyRows）：

public class MyService implements MyServiceInterface{
        ...
    @TransactionAttribute(TransactionAttributeType.REQUIRES_NEW) // this will create a new transaction when running this method from another bean, e.g. from Abean
    public void updateMyRows(int row){
       TypedQuery<MyEntity> query = em.createQuery(SELECT m FROM MyEntity WHERE m.id=:id", MyEntity.class);
       query.setParameter("id", row);
       query.setLockMode(LockModeType.PESSIMISTIC_WRITE); // this will lock all entities retrieved by the query
       List<MyEntity> myEntities = query.getResultList();
       if (!myEntities.isEmpty()) {
         myEntities.get(0).computeData();
       }
    }
}

当你在where条件中只使用id时，你可以考虑em.find(row, MyEntity.class, LockModeType.PESSIMISTIC_WRITE).computeData()而不是使用查询（在em.find()之后添加空指针检查）

其他说明：

从问题中不清楚您如何触发后台作业。正如您在示例中所写的那样，无限地运行作业，一方面不会创建额外的线程（当您在同一个 bean 上调用方法时，不会递归地考虑注释）。另一方面，如果出现异常，您的后台作业至少应该处理异常，使其不会停止。您可能还想在后续执行之间添加一些等待时间。

最好将后台作业作为计划作业运行。一种可能的选择是@Schedule 注释而不是@Asynchronous。您可以指定作业在后台执行的频率。然后最好检查你的工作的开始，之前的执行是否完成。 Java EE 7 的另一个选项是使用ManagedScheduledExecutorService 以指定的时间间隔定期触发后台作业。