Neo4j：插入 7k 节点很慢（Spring Data Neo4j / SpringRestGraphDatabase）

我正在构建一个应用程序，我的用户可以在其中管理字典。其中一项功能是上传文件以初始化或更新词典的内容。

我首先关注的结构部分是Dictionary -[:CONTAINS]->Word。 从一个空数据库（Neo4j 1.9.4，但也尝试过 2.0.0M5）开始，在分布式环境中通过 Spring Data Neo4j 2.3.1 访问（因此使用 SpringRestGraphDatabase，但使用 localhost 进行测试），我尝试加载 7k 个单词在 1 字典中。然而，我无法在带有核心 i7、8Gb RAM 和 SSD 驱动器（ulimit 提高到 40000）的 Linux 上在不到 8/9 分钟内完成它。

我读过很多关于使用 REST 加载/插入性能的文章，并且尝试应用我找到的建议，但运气不佳。由于我的应用程序限制，BatchInserter 工具对我来说似乎不是一个好的选择。

我可以希望在几秒钟而不是几分钟内加载 10k 个节点吗？

这是我在阅读完所有内容后想出的代码：

Map<String, Object> dicProps = new HashMap<String, Object>();
dicProps.put("locale", locale);
dicProps.put("category", category);
Dictionary dictionary = template.createNodeAs(Dictionary.class, dicProps);
Map<String, Object> wordProps = new HashMap<String, Object>();
Set<Word> words = readFile(filename); 
for (Word gw : words) {
  wordProps.put("txt", gw.getTxt());
  Word w = template.createNodeAs(Word.class, wordProps);
  template.createRelationshipBetween(dictionary, w, Contains.class, "CONTAINS", true);
}

我通过创建一些 CSV 文件然后从 Neo4j 读取它来解决这个问题。需要采取这样的步骤：

1. 编写一些获取输入数据的类，并基于它创建 CSV 文件（它可以是每个节点类型一个文件，甚至您可以创建用于构建关系的文件）。

2. 就我而言，我还创建了 servlet，它允许 Neo4j 通过 HTTP 读取该文件。

3. 创建适当的 Cypher 语句，允许读取和解析该 CSV 文件。我使用了一些示例（如果您使用 Spring Data 还记得标签）：

   • 简单的一个：

     load csv with headers from {fileUrl} as line 
        merge (:UserProfile:_UserProfile {email: line.email})
     

   • 更复杂：

     load csv with headers from {fileUrl} as line 
          match (c:Calendar {calendarId: line.calendarId})
          merge (a:Activity:_Activity {eventId: line.eventId})
     on create set  a.eventSummary = line.eventSummary,
          a.eventDescription = line.eventDescription,
          a.eventStartDateTime = toInt(line.eventStartDateTime),
          a.eventEndDateTime = toInt(line.eventEndDateTime),
          a.eventCreated = toInt(line.eventCreated), 
          a.recurringId = line.recurringId
     merge (a)-[r:EXPORTED_FROM]->c
     return count(r)