0

我正在使用 JSR 352 java 批处理规范的 jberet 实现。

实际上，我需要一个单独的事务来进行单一更新，如下所示：

class MyItemWriter implements ItemWriter

@Inject
UserTransaction transaction

void resetLastProductsUpdateDate(String uidCli) throws BusinessException {
    try {
        if (transaction.getStatus() != Status.STATUS_ACTIVE) {
            transaction.begin();
        }
        final Customer customer = dao.findById(id);
        customer.setLastUpdate(null);
        customer.persist(cliente);
        transaction.commit();
    } catch (RollbackException | HeuristicMixedException | HeuristicRollbackException | SystemException | NotSupportedException e) {
        logger.error("error while updating user products last update");
        throw new BusinessException();
    }
}

我首先尝试将resetLastProductsUpdateDate方法标记为@Transactional(REQUIRES_NEW)，但是没有成功。

我的问题是：

  1. 有没有更优雅的方式来实现这个单一的交易而无需手动处理交易？
  2. 虽然 UserTransation 有效，但 EntityManager.transaction 无效。我不明白为什么。

  3. 下面的类是从 Batchlet 注入的，可以正常工作；为什么我不能在resetLastProductsUpdateDate方法上使用 @Transactional 注释呢？

    public class DynamicQueryDAO {

@Inject
EntityManager entityManager;

@Inject
private Logger logger;

@Transactional(Transactional.TxType.REQUIRED)
public void executeQuery(String query) {

    logger.info("executing query: {}", query);

    final int output = entityManager.createNativeQuery(query).executeUpdate();

    logger.info("rows updated: {}", output);
}

    }

编辑

实际上，我想这两个 usertransaction 都不是一个好的解决方案，因为它会影响整个 itemwriter 事务管理。仍然不知道如何处理事务隔离:(

4

1 回答 1

1

一般来说，批处理应用程序应避免直接处理事务。你可以让你的批处理组件在某些条件下抛出一些业务异常，并配置你的 job.xml 来触发这个业务异常的重试。在重试期间，每个单独的数据将在其自己的块中进行处理和提交。

于 2020-02-18T20:40:39.133 回答