在 java 个批处理中处理单独的事务 (JSR-352)

Question

我正在使用 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)，但是没有成功。

我的问题是：

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

Class 是从 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 事务管理。仍然不知道如何处理事务隔离:(

Answer 1

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

在 java 个批处理中处理单独的事务 (JSR-352)

handle separate transaction in java batch (JSR-352)

java-ee-7

jsr352

jberet