那些遇到过的问题

使用 Spring 正确测试 JPA DAO

sol*_*nmv 0 java spring unit-testing hibernate jpa

我创建了简单的 JPA 实体：Topic 和 Word。主题包含单词列表。

@ManyToMany(fetch = FetchType.EAGER, cascade = {CascadeType.MERGE, CascadeType.REMOVE})
@JoinTable
private List<Word> words;
Run Code Online (Sandbox Code Playgroud)

现在我想使用内存中的 H2 数据库测试我的 DAO。在测试类中，我编写了不同的测试来操作数据。但是我想为每个测试获得一个干净的数据库，所以我添加了 tearDown 方法来删​​除所有单词和主题。

我的测试类的片段：

@RunWith(SpringRunner.class)
@SpringBootTest
public class TopicServiceJpaDaoTest {
    @Autowired
    private TopicDao topicDao;

    @Autowired
    private WordDao wordDao;

    // different test methods

    @After
    public void tearDown() throws Exception {
        topicDao.deleteAll();
        wordDao.deleteAll();
    }
}
Run Code Online (Sandbox Code Playgroud)
  1. 但是当我尝试运行类中的所有测试时，我收到一个错误，该条目被锁定。
  2. 此外，当我运行所有集成测试时，我收到以下错误：Unable to acquire JDBC Connection.

条目的堆栈跟踪被锁定错误：

javax.persistence.PessimisticLockException: could not execute statement

    at org.hibernate.jpa.spi.AbstractEntityManagerImpl.wrapLockException(AbstractEntityManagerImpl.java:1760)
    at org.hibernate.jpa.spi.AbstractEntityManagerImpl.convert(AbstractEntityManagerImpl.java:1649)
    at org.hibernate.jpa.spi.AbstractEntityManagerImpl.convert(AbstractEntityManagerImpl.java:1602)
    at org.hibernate.jpa.spi.AbstractEntityManagerImpl.throwPersistenceException(AbstractEntityManagerImpl.java:1700)
    at org.hibernate.jpa.spi.AbstractQueryImpl.executeUpdate(AbstractQueryImpl.java:70)
    at io.github.solomkinmv.glossary.persistence.dao.impl.WordServiceJpaDao.deleteAll(WordServiceJpaDao.java:66)
    at io.github.solomkinmv.glossary.persistence.dao.impl.TopicServiceJpaDaoTest.tearDown(TopicServiceJpaDaoTest.java:287)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:33)
    at org.springframework.test.context.junit4.statements.RunAfterTestMethodCallbacks.evaluate(RunAfterTestMethodCallbacks.java:86)
    at org.springframework.test.context.junit4.statements.SpringRepeat.evaluate(SpringRepeat.java:84)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:252)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:94)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61)
    at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:191)
    at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
    at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)
    at com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:51)
    at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:237)
    at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147)
Caused by: org.hibernate.PessimisticLockException: could not execute statement
    at org.hibernate.dialect.H2Dialect$3.convert(H2Dialect.java:370)
    at org.hibernate.exception.internal.StandardSQLExceptionConverter.convert(StandardSQLExceptionConverter.java:42)
    at org.hibernate.engine.jdbc.spi.SqlExceptionHelper.convert(SqlExceptionHelper.java:109)
    at org.hibernate.engine.jdbc.spi.SqlExceptionHelper.convert(SqlExceptionHelper.java:95)
    at org.hibernate.engine.jdbc.internal.ResultSetReturnImpl.executeUpdate(ResultSetReturnImpl.java:207)
    at org.hibernate.hql.internal.ast.exec.BasicExecutor.doExecute(BasicExecutor.java:91)
    at org.hibernate.hql.internal.ast.exec.BasicExecutor.execute(BasicExecutor.java:60)
    at org.hibernate.hql.internal.ast.exec.DeleteExecutor.execute(DeleteExecutor.java:111)
    at org.hibernate.hql.internal.ast.QueryTranslatorImpl.executeUpdate(QueryTranslatorImpl.java:429)
    at org.hibernate.engine.query.spi.HQLQueryPlan.performExecuteUpdate(HQLQueryPlan.java:374)
    at org.hibernate.internal.SessionImpl.executeUpdate(SessionImpl.java:1348)
    at org.hibernate.internal.QueryImpl.executeUpdate(QueryImpl.java:102)
    at org.hibernate.jpa.internal.QueryImpl.internalExecuteUpdate(QueryImpl.java:405)
    at org.hibernate.jpa.spi.AbstractQueryImpl.executeUpdate(AbstractQueryImpl.java:61)
    ... 34 more
Caused by: org.h2.jdbc.JdbcSQLException: Timeout trying to lock table ; SQL statement:
delete from word [50200-193]
    at org.h2.message.DbException.getJdbcSQLException(DbException.java:345)
    at org.h2.message.DbException.get(DbException.java:168)
    at org.h2.command.Command.filterConcurrentUpdate(Command.java:307)
    at org.h2.command.Command.executeUpdate(Command.java:260)
    at org.h2.jdbc.JdbcPreparedStatement.executeUpdateInternal(JdbcPreparedStatement.java:160)
    at org.h2.jdbc.JdbcPreparedStatement.executeUpdate(JdbcPreparedStatement.java:146)
    at org.hibernate.engine.jdbc.internal.ResultSetReturnImpl.executeUpdate(ResultSetReturnImpl.java:204)
    ... 43 more
Caused by: org.h2.jdbc.JdbcSQLException: Concurrent update in table "WORD": another transaction has updated or deleted the same row [90131-193]
    at org.h2.message.DbException.getJdbcSQLException(DbException.java:345)
    at org.h2.message.DbException.get(DbException.java:168)
    at org.h2.mvstore.db.MVTable.convertException(MVTable.java:898)
    at org.h2.mvstore.db.MVPrimaryIndex.remove(MVPrimaryIndex.java:168)
    at org.h2.mvstore.db.MVTable.removeRow(MVTable.java:677)
    at org.h2.command.dml.Delete.update(Delete.java:95)
    at org.h2.command.CommandContainer.update(CommandContainer.java:98)
    at org.h2.command.Command.executeUpdate(Command.java:258)
    ... 46 more
Caused by: java.lang.IllegalStateException: Entry is locked [1.4.193/101]
    at org.h2.mvstore.DataUtils.newIllegalStateException(DataUtils.java:765)
    at org.h2.mvstore.db.TransactionStore$TransactionMap.set(TransactionStore.java:1031)
    at org.h2.mvstore.db.TransactionStore$TransactionMap.remove(TransactionStore.java:989)
    at org.h2.mvstore.db.MVPrimaryIndex.remove(MVPrimaryIndex.java:162)
    ... 50 more
Run Code Online (Sandbox Code Playgroud)

我尝试了对数据库 URL 的不同操作，例如添加MVCC=TRUE，但没有任何变化。

看起来我的单元测试方法是错误的。热以正确的方式做到这一点？

我不使用 Spring Data，只是简单的 JPA 实现。我的 DAO 实现：

@Repository
public class TopicServiceJpaDao extends AbstractJpaDaoService implements TopicDao {
    private static final Logger LOGGER = LoggerFactory.getLogger(TopicServiceJpaDao.class);

    @Override
    public List<Topic> listAll() {
        EntityManager entityManager = emf.createEntityManager();

        return entityManager.createQuery("FROM Topic", Topic.class)
                            .getResultList();
    }

    @Override
    public Optional<Topic> getById(Long id) {
        EntityManager entityManager = emf.createEntityManager();

        return Optional.ofNullable(entityManager.find(Topic.class, id));
    }

    @Override
    public Topic saveOrUpdate(Topic unsavedTopic) {
        EntityManager entityManager = emf.createEntityManager();

        entityManager.getTransaction().begin();
        Topic savedTopic = entityManager.merge(unsavedTopic);
        entityManager.getTransaction().commit();
        return savedTopic;
    }

    @Override
    public void delete(Long id) {
        EntityManager entityManager = emf.createEntityManager();

        entityManager.getTransaction().begin();
        Topic entity = entityManager.find(Topic.class, id);
        if (entity == null) {
            LOGGER.error("No such entity in the DB");
            throw new EntityNotFoundException("Topic id: " + id);
        }
        entityManager.remove(entityManager.find(Topic.class, id));
        entityManager.getTransaction().commit();
    }

    @Override
    public void deleteAll() {
        EntityManager entityManager = emf.createEntityManager();

        entityManager.getTransaction().begin();
        entityManager.createQuery("DELETE FROM Topic").executeUpdate();
        entityManager.getTransaction().commit();
    }
}
Run Code Online (Sandbox Code Playgroud)

ale*_*xbt 5

如果使用 Spring Data JPA Repository，这个答案就足够了

使用 Spring Data JPA 存储库，可以将 Dao 替换为：

public interface TopicRepository extends JpaRepository<Topic, Long> {
    // no need for code here   
}
Run Code Online (Sandbox Code Playgroud)

从我在道中看到的，它几乎是一个完美的匹配：

  • listAll -> findAll
  • getById -> findOne
  • saveOrUpdate -> 保存
  • 删除
  • 删除所有。

这不是你的问题，但你可以看看 Spring Data JPA Repository

您可以@DataJpaTest改用，这将负责加载内存中的 h2 数据库和回滚。

来源：https : //docs.spring.io/spring-boot/docs/current/reference/html/boot-features-testing.html

默认情况下，它将配置一个内存嵌入式数据库，扫描 @Entity类并配置 Spring Data JPA 存储库。常规 @Componentbean 不会加载到 ApplicationContext 中。

默认情况下，数据 JPA 测试是事务性的，并且在每个测试结束时回滚 [...]

数据 JPA 测试还可以注入一个TestEntityManagerbean，该bean 提供了专为测试设计的标准 JPA EntityManager 的替代方案。如果你想在外面使用 TestEntityManager @DataJpaTests你也可以使用@AutoConfigureTestEntityManager 注解。[...]

@RunWith(SpringRunner.class)
@DataJpaTest
public class ExampleRepositoryTests {

    @Autowired
    private TestEntityManager entityManager;

    @Autowired
    private UserRepository repository;

    @Test
    public void testExample() throws Exception {
        this.entityManager.persist(new User("sboot", "1234"));
        User user = this.repository.findByUsername("sboot");
        assertThat(user.getUsername()).isEqualTo("sboot");
        assertThat(user.getVin()).isEqualTo("1234");
    }
}
Run Code Online (Sandbox Code Playgroud)

归档时间：

查看次数：

1294 次

最近记录：

9 年，1 月 前
相关归档
JPA:迭代大型结果集的正确模式是什么？ 112
如何在Java中居中窗口？ 104
如何修复"java.security.cert.CertificateException:没有主题替代名称出现"错误？ 98
是什么让Java比C更容易解析？ 89
如何获取Web应用程序中所有HttpSession对象的列表？ 49
无法使用spring-data-elasticsearch进行自定义自动配置 11
无法将DaoAuthenticationConfigurer应用于已构建的对象 9
JPA 域对象中的注释违反了数据库是一个细节 6
如何为AbstractRoutingDataSource安全频繁的DataSource切换？ 4
@JoinColumn和@MappedBy如何工作 4
难疑归档
如何在C#中枚举枚举？ 3620
如何将命令行参数传递给Node.js程序？ 2280
什么是MVP和MVC,有什么区别？ 2081
什么是NullReferenceException,我该如何解决？ 1876
CSS三角形如何工作？ 1791
.gitignore和.gitkeep有什么区别？ 1776
如何将堆栈跟踪转换为字符串？ 1435
漂亮的git分支图 1290
如何一次删除所有Git stashes？ 1280
从字典中删除元素 1243