如何在活动的 Spring 事务中将数据刷新到数据库中？答案

【问题标题】：How to flush data into db inside active spring transaction?如何在活动的 Spring 事务中将数据刷新到数据库中？
【发布时间】：2013-06-20 06:02:10
【问题描述】：

我想使用 Spring 测试框架测试休眠会话的 save() 方法。 @Test 方法是：

@Test
@Transactional
public void testSave() {
    User expected = createUser();
    getGenericDao().currentSession().save(expected);
    User actual = getUser(generatedId);
    assertUsersEqual(expected,actual);
}

我想将用户刷新到数据库中。我希望我的用户在这个方法之后进入数据库

getGenericDao().currentSession().save(expected);

然后我想使用 spring 数据框架进入数据库并通过下一行获取这个保存的用户：

User actual = getUser(generatedId);

我尝试使用休眠刷新方法，例如：

currentSession().setFlushMode(MANUAL);
//do saving here
currentSession().flush();

它不会将我的用户刷新到数据库中！但是，如果我不使用 @Transactional spring 注释并将我的用户保存在程序化 spring 事务中，我将实现我想要的。不幸的是，用户保存到数据库中没有回滚，因为没有 spring @Transactional。因此我的测试方法改变了后续测试方法的数据库和行为。

所以我需要将我的用户刷新到测试方法内的数据库中（而不是在最后），并在测试方法结束时回滚对数据库的所有更改。

UPDATE建议准备方法如下：

@Transactional
public void doSave(User user){
    getGenericDao().currentSession().save(user);
}

并且在 testSave 中调用 doSave 什么也不做。执行此方法后，我在 db 中仍然没有用户。我设置断点并从命令行检查我的数据库。

更新非常感谢您的回复。问题是方法 flush() 没有将我的用户放入数据库。我尝试了 Isolation.READ_UNCOMMITTED 并且它没有将我的用户放入数据库。我可以实现我想要的，但前提是我关闭 @Test 方法上的 spring 事务并保存编程事务。但是，@Test 方法不会回滚，将保存的用户留给后续的@Test 方法。这里@Test 方法保存用户不像@Test 方法删除用户那样危险，因为它没有回滚。所以必须有对@Test 方法的spring 事务支持，我无论如何都不能将我的用户（或删除）放入数据库中。实际上，只有在 @Test 方法结束并且 @Test 方法的事务被提交后，用户才被放入（或删除）到数据库中。 所以我想在@Test 方法中间将我的用户保存到数据库中，并在@Test 方法结束时回滚它

谢谢！

【问题讨论】：

你也可以给我们你的 GenericDao 课程吗？编辑：实际上，我想我看到了问题。当前事务需要在数据实际保存到数据库之前提交。所以你需要两个@Transactional 方法：一个用来保存，另一个用来加载。
请看我是否正确
关闭。我的意思是有两个由非事务函数调用的事务函数。这应该工作......
如果我将 testSave 方法设置为非事务性的，那么在 testSave 方法结束后我将不会回滚。因此保存的用户将保留。
没有找到当前线程的会话。这是调用 GenericDao 的方法 save 时的休眠异常。 doSave 上的@Transactional 不起作用！

标签： java hibernate spring-transactions spring-test hibernate-session

【解决方案1】：

最后我坚持了以下解决方案：

首先，我的 @Test 方法没有在 spring @Transactional 支持中运行。请参阅this article 以了解它可能有多危险。接下来，我没有在 @Test 方法中使用 @Repository bean，而是自动装配使用 @Transactional 注释的 @Service bean。奇迹就是@Test这样的方法

@Test
@Transactional(propagation = Propagation.NOT_SUPPORTED)
public void testSave() {
    Answer created = createAnswer();
    Long generatedId = answerService.save(created);
//at this moment answer is already in db
    Answer actual=getAnswerById(generatedId);
... }

将我的 Answer 对象放入数据库（就在 answerService.save(created); 之后），方法 getAnswerById 进入数据库并提取它以检查保存是否正确。
为了消除在@Test 方法中对数据库所做的更改，我通过JdbcTestUtils.executeSqlScript 重新创建数据库

【讨论】：

你可以应用@DirtiesContext注解而不是使用JdbcTestUtils。

【解决方案2】：

查看here 并警告@Transactional 测试 (Spring Pitfalls: Transactional tests considered harmful)。我使用@org.springframework.test.context.jdbc.Sql 在我的服务测试中重新填充数据库，并在控制器中使用@Transactional。
ConstraintViolationException 仅在提交事务时才抛出带有无效数据的控制器更新测试。所以我找到了 3 个选项：
- 2.1 使用@Commit 或@Transactional(propagation = Propagation.NEVER) 注释测试。注意数据库更改。
- 2.2 使用TestTransaction

代码：

     TestTransaction.flagForCommit();
     TestTransaction.end();

2.3 使用TransactionTemplate

代码：

    @Autowired
    private PlatformTransactionManager platformTransactionManager;

    @Test(expected = Exception.class)
    public void testUpdate() throws Exception {
        TransactionTemplate transactionTemplate = new TransactionTemplate(platformTransactionManager);
        transactionTemplate.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
        String json = ...
        transactionTemplate.execute(ts -> {
            try {
                mockMvc.perform(put(REST_URL + USER_ID)
                    .contentType(MediaType.APPLICATION_JSON)
                    .content(json))
                    .andExpect(status().isOk());
                ...
            } catch (Exception e) {
                e.printStackTrace();
            }
            return null;
        });

【讨论】：

【解决方案3】：

您还应该注意导入的包：就我而言，我导入了

导入 javax.transaction.Transactional;

而不是

导入 org.springframework.transaction.annotation.Transactional;

【讨论】：

【解决方案4】：

如果flush 不起作用，那么它在很大程度上取决于您的数据库隔离级别。

Isolation 是数据库的ACID 属性之一，它定义了一个操作所做的更改如何/何时对其他并发操作可见。

我相信您的隔离级别设置为Read Committed 或Repeatable Read。

【讨论】：