您如何测试 Spring @Transactional 而不只是命中休眠级别 1 缓存或进行手动会话刷新?

Posted

技术标签:

【中文标题】您如何测试 Spring @Transactional 而不只是命中休眠级别 1 缓存或进行手动会话刷新?【英文标题】:How do you test Spring @Transactional without just hitting hibernate level 1 cache or doing manual session flush? 【发布时间】:2014-12-23 05:09:12 【问题描述】:

使用 Spring + Hibernate 和事务注释。

我正在尝试测试以下内容:

    调用一个改变用户对象的方法,然后调用一个@Transactional服务方法来持久化它 从数据库中读回对象并确保其值在方法之后正确

我遇到的第一个问题是在第 2 步中读取 User 对象,只是返回了 Hibernate 1 级缓存中的那个,实际上并没有从数据库中读取。

因此,我使用 Session 手动从缓存中逐出对象以强制从数据库读取。但是,当我这样做时,对象值永远不会保留在单元测试中(我知道由于我指定的设置,它会在测试完成后回滚)。

我尝试在调用 @Transactional 服务方法后手动刷新会话,并且该 DID 提交了更改。然而,这不是我所期望的。我认为@Transactional 服务方法将确保事务已提交并在返回之前刷新会话。 我知道 Spring 通常会决定何时进行这种管理,但我认为 @Transactional 方法中的“工作单元”就是那个方法。

无论如何,现在我正试图弄清楚我将如何测试一般的@Transactional 方法。

这是一个失败的junit测试方法:

@RunWith(SpringJUnit4ClassRunner.class)
@Transactional
@TransactionConfiguration(transactionManager = "userTransactionManager", defaultRollback = true)
@WebAppConfiguration()
@ContextConfiguration(locations =  "classpath:test-applicationContext.xml",
        "classpath:test-spring-servlet.xml",
        "classpath:test-applicationContext-security.xml" )
public class HibernateTest 

    @Autowired
    @Qualifier("userSessionFactory")
    private SessionFactory sessionFactory;

    @Autowired
    private UserService userService;

    @Autowired
    private PaymentService paymentService;

    @Autowired
    private QueryService queryService;

    @Autowired
    private NodeService nodeService;

    @Autowired
    private UserUtils userUtils;

    @Autowired
    private UserContext userContext;

  @Test
    public void testTransactions() 
        // read the user
        User user1 = userService.readUser(new Long(77));
        // change the display name
        user1.setDisplayName("somethingNew");
        // update the user using service method that is marked @Transactional
        userService.updateUserSamePassword(user1);
        // when I manually flush the session everything works, suggesting the
        // @Transactional has not flushed it at the end of the method marked
        // @Transactional, which implies it is leaving the transaction open?
        // session.flush();
        // evict the user from hibernate level 1 cache to insure we are reading
        // raw from the database on next read
        sessionFactory.getCurrentSession().evict(user1);
        // try to read the user again
        User user2 = userService.readUser(new Long(77));
        System.out.println("user1 displayName is " + user1.getDisplayName());
        System.out.println("user2 displayName is " + user2.getDisplayName());
        assertEquals(user1.getDisplayName(), user2.getDisplayName());
    

如果我手动刷新会话,则测试成功。但是,我本来希望 @Transactional 方法负责提交和刷新会话。

updateUserSamePassword的服务方法在这里:

@Transactional("userTransactionManager")
@Override
public void updateUserSamePassword(User user) 
    userDAO.updateUser(user);

DAO方法在这里:

@Override
public void updateUser(User user) 
    Session session = sessionFactory.getCurrentSession();
    session.update(user);

SessionFactory 是自动装配的:

@Autowired
@Qualifier("userSessionFactory")
private SessionFactory sessionFactory;

我正在使用 XML 应用程序上下文配置。我有:

<context:annotation-config />
<tx:annotation-driven transaction-manager="userTransactionManager" />

<bean id="userDataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close"> 
    <property name="driverClass" value="$user.jdbc.driverClass"/>
    <property name="jdbcUrl" value="$user.jdbc.jdbcUrl" />
    <property name="user" value="$user.jdbc.user" />
    <property name="password" value="$user.jdbc.password" />
    <property name="initialPoolSize" value="3" />
    <property name="minPoolSize" value="1" />
    <property name="maxPoolSize" value="17" />
</bean>

<bean id="userSessionFactory"
    class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
    <property name="dataSource" ref="userDataSource" />
    <property name="configLocation" value="classpath:user.hibernate.cfg.xml" />
</bean>

<bean id="userTransactionManager"
    class="org.springframework.orm.hibernate4.HibernateTransactionManager">
    <property name="dataSource" ref="userDataSource" />
    <property name="sessionFactory" ref="userSessionFactory" />
</bean>

还对服务和 dao 类进行了组件扫描。正如我所说,这是在生产中工作的。

我认为如果我有一个标记为 @Transactional 的方法,在该方法结束时(例如这里的更新方法),Spring 会强制 Session 提交和刷新。

我只能看到几个选项:

    我错误地配置了一些东西,尽管这对我一般来说是有效的(只是不是单元测试)。有什么猜测吗?关于如何测试的任何想法?

    关于单元测试配置本身的某些事情与应用程序的行为方式不同。

    事务和会话不是这样工作的。我唯一的推断是 Spring 在调用该更新方法后使事务和/或会话保持打开状态。因此,当我在 Session 对象上手动驱逐用户时,这些更改尚未提交。

谁能确认这是否是预期的行为? @Transaction 不应该在会话中强制提交和刷新吗?如果不是,那么如何测试标记为 @Transactional 的方法以及这些方法是否真正适用于事务?

即,我应该如何在这里重写我的单元测试?

还有其他想法吗?

【问题讨论】:

【参考方案1】:

谁能确认这是否是预期的行为?不应该 @Transaction 已强制提交并刷新会话?如果不是,那如何 是否会测试一种标记为@Transactional 的方法,并且这些方法 实际处理事务?

一个

It is the expected behavior。 Spring 感知事务单元测试支持在测试完成后回滚事务。这是设计使然。

每个测试都会创建一个隐式事务边界(每个方法都带有@Test),一旦测试完成,就会完成回滚。

这样做的结果是,在所有测试完成之后,实际上并没有改变任何数据。那就是目标是更像“单元”,而不是像“集成”一样。您应该阅读spring documentation 了解为什么这是有利的。

如果您真的想测试被持久化的数据并在事务边界之外查看该数据,我建议您进行更端到端的测试,例如 functional/integration 测试,例如 selenium,或者在以下情况下使用您的外部 WS/REST API你有一个。

即,我应该如何在这里重写我的单元测试?

一个

您的单元测试不起作用,因为您 session.evict 并且没有刷新。即使您已经在事务和休眠批处理操作中调用了session.update,驱逐将导致更改不同步。这对于原始 SQL 来说更清楚,因为休眠延迟持久化以批处理所有操作,因此它会等到会话被刷新或关闭以与数据库通信以获得性能。如果您session.flush 尽管 SQL 将立即执行(即更新将真正发生),那么您可以驱逐如果您想强制重新读取但您在事务中重新读取。实际上,我很确定 flush 会导致驱逐,因此无需致电 evict 强制重读,​​但我可能错了。

【讨论】:

其实和上面说的完全一样。事务单元是测试方法,因此提交(因此刷新)只会发生在测试方法结束之后,而不是服务方法结束之后。对于测试而不是驱逐,您必须flush 当前会话。此外,一般来说,为了测试数据库中的值,您应该使用一个简单的 jdbc 语句,而不是您用来放入它的机制。 这不适用于我所描述的内容。测试期间数据不在数据库中。我在这里发布的单元测试(和描述)应该清楚地说明这一点。此外,您可以指定该行为,就像我在这里所做的那样。但是,只是为了好玩,既然你提到了它,我会关掉它,这样它就不会回滚,看看会发生什么。应该没有影响 正确,永远不会,因为事务是在测试方法之前启动的。您的测试方法是事务边界而不是服务方法。提交只会在事务结束时发生,在测试的情况下它不会在调用您的服务方法时结束,因为事务是在此之前启动的。 设置rollback=false 不会有什么不同。事务边界仍然是您的测试方法。唯一的解决方案是让您的测试不是事务性的,以便与您的 Web 应用程序具有相同的行为。 感谢 M. Deinum,尽管我认为您的评论与完成后回滚的测试行为是正交的。那么事务的范围是调用事务方法的整个测试方法吗?通常情况下,事务的范围是调用@Transactional 方法的方法,还是事务单元测试特有的?【参考方案2】:

这就是我遇到的问题。在测试方法中考虑这段代码:

    String testDisplayNameChange = "ThisIsATest";
    User user = userService.readUser(new Long(77));
    user.setDisplayName(testDisplayNameChange);
    user = userService.readUser(new Long(77));
    assertNotEquals(user.getDisplayName(), testDisplayNameChange);

请注意,方法 userService.readUser 在服务类中标记为@Transactional。

如果该测试方法标记为@Transactional,则测试失败。如果不是,则成功。现在我不确定 Hibernate 缓存是否/何时真正参与其中。如果测试方法是事务性的,那么每次读取都发生在一个事务中,我相信它们只会命中 Hibernate 1 级缓存(实际上并不从数据库中读取)。但是,如果测试方法不是事务性的,那么每次读取都发生在它自己的事务中,并且每次都会访问数据库。因此,休眠级别 1 缓存与会话/事务管理相关联。

外卖:

    即使一个测试方法正在调用另一个类中的多个事务方法,如果该测试方法本身是事务性的,那么所有这些调用都发生在一个事务中。测试方法是“工作单元”。但是,如果测试方法不是事务性的,那么在该测试中对事务性方法的每次调用都会在它自己的事务中执行。

    我的测试类被标记为@Transactional,因此每个方法都将是事务性的,除非使用覆盖注释(如@AfterTransaction)进行标记。我可以很容易地不标记类@Transactional并标记每个方法@Transactional

    在使用 Spring @Transactional 时,Hibernate 1 级缓存似乎与事务相关联。 IE。在同一事务中对对象的后续读取将命中休眠级别 1 缓存,而不是数据库。请注意,您可以调整二级缓存和其他机制。

我打算有一个@Transactional 测试方法,然后在测试类中的另一个方法上使用@AfterTransaction 并提交原始SQL 来评估数据库中的值。这将完全绕过 ORM 和休眠 1 级缓存,确保您比较数据库中的实际值。

简单的答案是从我的测试类中删除@Transactional。耶。

【讨论】:

非常有用的解释,但我仍在顽固地试图弄清楚如何重构我的类似测试以不使用 @Transactional 但仍然回滚:(

以上是关于您如何测试 Spring @Transactional 而不只是命中休眠级别 1 缓存或进行手动会话刷新?的主要内容,如果未能解决你的问题,请参考以下文章

Hibernate 4 + Spring 3.2 + Transaction:一个服务,几个道,一个方法

聊一聊Spring中的 Transaction基本实现

如何使用 @Transaction() 装饰器为方法编写单元测试?

如何让 Spring Integration HTTP outbound-channel-adapter 参与 Global Transaction

您如何测试 Spring @Transactional 而不只是命中休眠级别 1 缓存或进行手动会话刷新?

老王读Spring Transaction-3TransactionDefinition原理和源码解析