java - neo4j 在一个迭代器上处理一个长事务

Question

我想遍历图表中的所有“用户”节点并对它们执行一些操作。

问题是我有太多“用户”节点，我无法将它们全部保存在堆上。

所以，做类似的事情:

try (Transaction tx = graphDb.beginTx())
{
   Iterator<Node> n_column = autoNodeIndex.get( "type", "user" );   


   while (n_column.hasNext()) {
     //create relationship for node...
   }
   tx.success();
}

会导致GC开销异常。

我如何将它拆分为几个事务，但在同一个迭代器上？

我考虑过嵌套事务，但手册上有不同的说法。嵌套事务会将本地内存滚动到顶级事务。

Answer 1

只需添加一个计数器，每 50.000 个节点提交并启动一个新事务。

   Transaction tx = graphDb.beginTx();
   Iterator<Node> n_column = autoNodeIndex.get( "type", "user" );   

   int counter=0;
   while (n_column.hasNext()) {
     //create relationship for node...
     if (++counter % 50000 == 0) {
        tx.success(); tx.close();
        tx = graphDb.beginTx();
     }
   }
   tx.success(); 
   tx.close();