java - 在事务之外使用 ExecutionEngine#execute(String)？

Question

我只花了 10 分钟弄清楚为什么我针对测试数据库的单元测试需要大约 25 秒才能完成一个简单的查询。显然，原因是我忘记在 Transaction 中包装对 ExecutionEngine#execute(String) 的调用。我不知道那应该是可能的。嗯。

我的代码看起来像这样:

...

@Before
public void before() {
  db = new TestGraphDatabaseFactory().newImpermanentDatabase();
  /* create all the test nodes and rels */
}

@After
public void after() {
  db.shutdown();
}

@Test
public void testAllTheThings() {
  /* build the cypher query */
  Iterable<Map<String, Object>> result = engine.execute(cypher);
  /* assert all the things */
}

...

这里令人困惑的部分是 execute() 立即返回并执行以下语句。但是，测试在成功终止之前停顿了大约 25 秒。

将语句更改为以下内容按预期工作，没有任何滞后:

...
try (Transaction transaction = db.beginTx()) {
  Iterable<Map<String, Object>> result = engine.execute(cypher);
}
...

这里到底发生了什么？为什么可以这样做？

Answer 1

我怀疑您没有用完 ExecutionEngine#execute() 返回的 ExecutionResult 中的 Iterator。如果这样做，测试将快速完成，而无需将 execute() 包装在事务中。

这是我认为正在发生的事情，尽管我还没有在调试器中重现它。

ExecutionEngine#execute() 创建自己的事务，因此没有必要创建自己的事务。但是，所有交易都必须关闭。在这种情况下，事务状态由 ExecutionResult 处理，其方法如文档中所述 here .如果您部分使用结果 Iterator，则事务将保持打开状态。

当您调用 GraphDatabaseService#shutdown() 时，它会尝试通过在强制关闭之前等待它们完成来容纳打开的事务。您在测试中看到的停顿可能是超时发生的原因。当然，在这种情况下，事务不可能在等待期间关闭，因为它由关闭数据库的同一个线程持有。

因为事务与线程相关联，原则上，GraphDatabaseService 可以检测到这种情况并在不等待的情况下关闭事务。然而，在生产代码中，同一个线程执行事务和控制数据库的情况可能很少见，因此额外的复杂性是不合理的。

处理此问题的最简单方法是始终确保用尽 ExecutionEngine 返回的结果迭代器。