在不同的交易问题中保持相同的依赖性

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 container

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. 必须在新事务中同步和处理持久方法
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;
}