在不同线程上运行时，Hibernate会不必要地创建新实体

Question

我正在使用Spring Data JPA，以违反直觉的行为运行以下测试结果

@Test
public void testAsync() throws ExecutionException, InterruptedException {
    Job job = jobRepository.save(new Job());
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(10);
    long origJobID = job.getId();
    executor.initialize();
    Future<?> wait = executor.submit(() -> {
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        Job outcome = jobRepository.save(job.setStopTime(Instant.now()));
        // this assertion fails, Hibernate requested a new ID and persisted a new entity ... even though I am reusing the same instance with an ID already populated
        assertEquals(origJobID, outcome.getId().longValue());
    });
    wait.get();
}

进一步研究Hibernate的代码库，它出现在一个新线程上，persistentContext被清除干净。因此，就DefaultMergeEventListener而言，我的实体变成了分离状态...创建了一系列决策，这些决策莫名其妙地导致生成一个新ID

我引用的特定代码位于:https://github.com/hibernate/hibernate-orm/blob/master/hibernate-core/src/main/java/org/hibernate/event/internal/defaultmergeeventlistener.java#l109

如果从一个新线程运行，Hibernate的持久性上下文是空的...这很好....但我不明白为什么我的实体现在被认为是超然的...

更多摘自Hibernate源代码的内容：Default https://github.com/hibernate/hibernate-orm/blob/master/hibernate-core/src/main/java/org/hibernate/event/internal/defaultmergeeventlistener.java#L293

if ( result == null ) {
            //TODO: we should throw an exception if we really *know* for sure
            //      that this is a detached instance, rather than just assuming
            //throw new StaleObjectStateException(entityName, id);

            // we got here because we assumed that an instance
            // with an assigned id was detached, when it was
            // really persistent
            entityIsTransient( event, copyCache );
        }

如果这与事务尚未提交有关，并且新线程没有使用相同的事务，请编辑...是否有方法在代码中强制执行事务？

注意调用jparepository.saveandflush()不能解决此问题

编辑2我将使用embedded h2进行此测试，无论哪种情况，我都希望saveandflush()已经将事务提交到数据库（嵌入的或在世界的另一端），以便多个线程可以使用JPararePository查看其他线程保存的状态，对吗？

编辑3查看其他类似的问题，它似乎将测试方法本身标记为@transaction(propagation=NOT_SUPPORTED)强制底层事务管理器提交jparepository.save()...这仍然令人困惑...测试方法一开始是如何事务性的？即为什么交易没有从一开始就提交？

Answer 1

关于它的工作原理的一个非常粗略的想法：

• 您有多个线程
• 事务通常是线程绑定的（每个线程都有自己的事务）
• EntityManager通常是事务绑定的（每个事务都有自己的EntityManager，它根据该事务查看事情）

你正在做的是

null

通过确保线程1在步骤3时已经提交，您应该能够实现这一工作。被执行。无论如何，我不建议在线程之间传递托管实体引用，因为它非常棘手，非常快。

关于Spring数据事务分界，您可以阅读https://docs.Spring.io/spring-data/jpa/docs/current/reference/html/#transactions了解更多信息，但它基本上涉及将每个事务变成一个方法，然后对该方法进行注释。