从CSV加载数据模式的问题

Question

对象文件：

ID
ABC-DE
DEF

零件文件：

ID  ParentID    Level   Size
ABC ABC-DE  1   3
DE  ABC-DE  1   2
AB  ABC 2   2
BC  ABC 2   2
DE  DEF 1   2
F   DEF 2   1
A   AB  3   1
B   AB  3   1
B   BC  3   1
C   BC  3   1
D   DE  3   1
E   DE  3   1

用于加载数据的密码命令行：

LOAD CSV WITH HEADERS FROM 'file:///path_to_file/object.csv' as csvLine FIELDTERMINATOR '\t' CREATE (:Object { Name: csvLine.ID})  RETURN count(*);
LOAD CSV WITH HEADERS FROM 'file:///path_to_file/part.csv' as csvLine FIELDTERMINATOR '\t' MATCH (o:Object {Name: csvLine.ParentID}) MERGE (p:Part {Name: csvLine.ID}) ON CREATE SET p.Size = csvLine.Size CREATE (o) -[:hasPart {Level: csvLine.Level}]-> (p) RETURN count(*);
LOAD CSV WITH HEADERS FROM 'file:///path_to_file/part.csv' as csvLine FIELDTERMINATOR '\t' MATCH (o:Part {Name: csvLine.ParentID}) MERGE (p:Part {Name: csvLine.ID}) ON CREATE SET p.Size = csvLine.Size CREATE (o) -[:hasPart {Level: csvLine.Level}]-> (p) return count(*);

neo4j2.1.7和neo4j2.2.0-M04都存在此问题。

Answer 1

所以我认为这里的问题是cypher将许多更新批处理到一个事务中，然后提交它们。它放入事务中的数量可以通过使用定期提交来配置。我可能错了，但我认为通常它会将整个数据加载视为一个大事务。

对您来说，这是一个问题，因为当您在第6行时，您可能需要引用回在第3行创建的节点。除了那行不通；如果事务尚未提交，因为cypher正在批处理一系列结果），那么尚未提交的结果可能无法用于后续查询运行。

所以你有几个选择；一种方法是对该零件文件进行两次导入。在第一次传球时，您可能会这样做：

LOAD CSV WITH HEADERS FROM 'file:///path_to_file/part.csv' as csvLine FIELDTERMINATOR '\t' 
MERGE (p:Part {Name: csvLine.ID}) ON CREATE SET p.Size = csvLine.Size CREATE (o) -[:hasPart {Level: csvLine.Level}]-> (p) return count(*);

（第一个将确保所有部分都存在于数据库中）

然后在第二次传递时，您可以这样做：

LOAD CSV WITH HEADERS FROM 'file:///path_to_file/part.csv' as csvLine FIELDTERMINATOR '\t' MATCH (o:Part {Name: csvLine.ParentID}) MATCH (p:Part {Name: csvLine.ID}) CREATE (o) -[:hasPart {Level: csvLine.Level}]-> (p) return count(*);

（这只会将它们与关系联系起来）