我正在使用 spring boot 和 spring-data-jpa 开发一个应用程序,其中我有一个方法可以执行两件事:
它使用 JpaRepository 将元素列表保存到数据库中,因此方法 save 标记有 @Transactional。
它刷新缓存,因此它使用相同的 JpaRepository 对数据库执行查找所有操作。
如果列表的某个元素有错误(例如不允许的空值),我想回滚保存列表操作并且不执行查找所有查询,但它正在执行查找查询并抛出此时提交异常。
我尝试过不同类型的传播策略,但没有成功。 我也知道我可以将查找查询取出到外部方法,但对于封装问题我宁愿不这样做。
下面是方法:
@Transactional(rollbackFor=Exception.class)
public synchronized void saveMessageFilters(List<MessageFilter> list) {
logger.debug("Insert or update message filters <{}>", list);
for (MessageFilter filter : list) {
checkIfMessageFilterExists(filter);
MessageFilter messageFilter = messageFilterRepository.save(filter);
logger.info("Message filter <{}> processed",messageFilter);
}
List<MessageFilter> messageFilters = (List<MessageFilter>)messageFilterRepository.findAll();
}
最佳答案
JPA 可能会在执行 findAll 之前刷新挂起的更新操作,这就是它在 findAll 方法上触发错误的原因。
只需在执行 findAll 之前手动刷新即可解决问题
messageFilterRepository.flush();
List<MessageFilter> messageFilters = (List<MessageFilter>)messageFilterRepository.findAll();
关于java - Spring:多个事务,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48901744/