Neo4j 跨会话查询数据

Question

我在访问以前在 Neo4j 的嵌入式 Java 版本中创建的数据库时遇到问题。我想做的是打开一个 GraphDatabaseService，添加几百万个关系（不使用 BatchInserter，仅使用事务），然后关闭最后一个事务和连接。这看起来像：

public class startNeo4j{ …
  public static void main (String[] args) {
    GraphDatabaseService graphDb = new EmbeddedGraphDatabase( "data/test/base" );
    Transaction tx = graphDb.beginTx();
    IndexManager index = graphDb.index();
    Index<Node> userIds = index.forNodes("userIds");
    RelationshipIndex follows = index.forRelationships("follows");

[这里我输入了一个非常大的csv（几百万个关系），还给出了关系和userId索引]

    tx.finish();
    graphDb.shutdown(); }}

然后我需要做的是打开一个新的GraphDatabaseService并访问我刚刚插入的所有数据。我检查了 Neo4j 列表，他们确认这是可能的，但没有提供任何细节。

我不想重新创建索引，但是当我尝试简单地重新打开它时，我收到一个错误，其中索引（上面的 userIds）“无法解析”。理想情况下，如果有人能大致了解第二组代码的外观，那就太好了。我的非功能性查询如下所示：

public class examineNeo4j{
  public static void main (String[] args){
    GraphDatabaseService graphDb = new EmbeddedGraphDatabase( "data/test/base" );
    Transaction tx = graphDb.beginTx();
    IndexHits<Node> hits_final = userIds.get("userId","12");
    Node testthis = hits_final.getSingle();

[或我想要运行的其他一些查询]

    tx.finish();
    graphDb.shutdown();}}

任何帮助将不胜感激！

Answer 1

你还必须执行 tx.success();默认情况下，tx 处于“回滚”状态。

Transaction tx = graphDb.beginTx();
try {
  // do your work here
  tx.success();
} finally {
  tx.finish();
}
graphdb.shutdown();

另请记住，您的交易大小不应超过 10k 次操作左右。所以请使用这样的块大小批量交易。