java - 在不同的事务问题中保持相同的依赖关系

Question

我有一部分程序以并行方式与另一个系统实现同步。每个同步过程都会打开新的事务。同步对象将映射到某些数据并保留。待映射对象的数据可以在之前持久化，也可以在同步时间内持久化。

我的持久层提供级联操作，所以我不关心持久化所有依赖项。

问题

在映射对象之前没有被持久化，并且在同步时它将同时保存在不同的线程中出现 hibernate 异常:

org.springframework.dao.DataIntegrityViolationException: A different object with the same identifier value was already associated with the session : [my.project.entity.CrmCaseLink#27];
nested exception is javax.persistence.EntityExistsException: A different object with the same identifier value was already associated with the session : [my.project.entity.CrmCaseLink#27]

我尝试解决问题没有帮助

1.

我尝试使用缓存，从中我可以为不同的线程获取相同的CrmCaseLink，但它并没有解决我的问题。

2.

还有一次我尝试过

@CacheConfig(cacheNames = Constants.CRM_CASE_LINK_CACHE, cacheManager = Constants.GUAVA_CACHE_MANAGER)
@Service
public class CrmCaseLinkService {

    private static final Logger LOGGER = LogManager.getLogger(CrmCaseLinkService.class);
    @Autowired
    private CrmCaseLinkRepository crmCaseLinkRepository;

    @Cacheable(key = "#id")
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public synchronized CrmCaseLink findOne(Long id) {
        LOGGER.debug("trace loading crm case link by specified id: {}", id);
        return Optional.ofNullable(crmCaseLinkRepository.findOne(id))
                .orElseGet(() -> crmCaseLinkRepository.save(new CrmCaseLink(id)));
    }
}

问题

为什么这里缓存错误？我希望 hiberate 能够在不同的事务中管理相同的非持久实体。我确信在单独的 spring bean 中使用新事务的缓存解决方案是无可争议的解决方案，但它也对我没有帮助。

其他详细信息

java8、spring、spring data jpa、postgres、hibernate5、jetty 容器

Answer 1

问题原因说明

我认为出现这个问题是因为在提供的解决方案中使用了分离的实体对象。如您所见，我为同步单例方法创建了新事务

@Transactional(propagation = Propagation.REQUIRES_NEW)
public synchronized CrmCaseLink findOne(Long id) {
    LOGGER.debug("trace loading crm case link by specified id: {}", id);
    return Optional.ofNullable(crmCaseLinkRepository.findOne(id))
            .orElseGet(() -> crmCaseLinkRepository.save(new CrmCaseLink(id)));
}

如果数据库存储中不存在新对象，则持久保存新对象。但是，从另一个事务中使用 public Synchronized CrmCaseLink findOne 来获取 CrmCaseLink 并将其映射到其他对象上。要成功映射和保留其他实体，我必须使用附加的 CrmCaseLink。

解决方案代码示例

我已经通过以下方式更改了代码:

1. 数据库查找和持久化是不同的方法
2. Persist方法必须在新的tranzaction中同步和处理
3. 删除缓存，因为映射需要附加实体，并且不同的事务使用此服务来加载 CrmCaseLink。

代码示例:

@Service
public class CrmCaseLinkManager implements CrmLinkManager {
    @Autowired
    private CrmCaseLinkRepository crmCaseLinkRepository;

    @Override
    public CrmCaseLink findOne(Long id) {
        return crmCaseLinkRepository.findOne(id);
    }

    @Override
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public synchronized void save(Long id) {
        if (crmCaseLinkRepository.exists(id)) {
            return;
        }
        crmCaseLinkRepository.save(new CrmCaseLink(id));
    }
}

使用它的代码部分演示了如何从实现的服务中获取必要的附加实体:

T getOrCreateCrmLink(Long id, CrmLinkManager<T> crmLinkManager) {
    T crmLink = crmLinkManager.findOne(id);
    if (crmLink == null) {
        crmLinkManager.save(id);
        crmLink = crmLinkManager.findOne(id);
    }
    return crmLink;
}