使用WITH语句合并Neo4J JSON导入查询时关系数量异常排查请求

你遇到的这个问题本质是Cypher查询的执行流程导致了关系的重复创建，咱们一步步拆解：

1. 先看你合并后的查询逻辑：

   CALL apoc.load.json("file:///files.json") yield value 
   unwind value.nodes as node 
   merge (file:File {id:node.path}) ON CREATE SET file.name = node.name 
   WITH value 
   unwind value.edges as edge 
   MATCH (source:File {id: edge.sourceId}), (target:File {id: edge.targetId}) 
   CREATE (source)-[:`R`]->(target)
   

   这里的关键是WITH value这一步——在你unwind value.nodes as node之后，每一个node都会生成一行结果，而你用WITH value把同一个value对象传递到下一个阶段。也就是说，有多少个node，就会重复执行多少次后续的unwind edges和创建关系的逻辑。

2. 计算一下：你有254个File节点，3578条预期关系，254 × 3578 = 908812，正好是你看到的异常关系数。这就说明每一条关系被重复创建了254次。

要解决这个问题，你需要确保处理edges的逻辑只执行一次，而不是跟着每个node重复执行。有两种常见的修复方式：

方式一：拆分处理逻辑，用WITH聚合避免重复 #

CALL apoc.load.json("file:///files.json") yield value 
// 先处理所有节点，然后用collect(*)聚合，确保只传递一行value到下阶段
UNWIND value.nodes as node 
MERGE (file:File {id:node.path}) ON CREATE SET file.name = node.name 
WITH value, collect(*) as temp // temp只是占位，用来聚合行
UNWIND value.edges as edge 
MATCH (source:File {id: edge.sourceId}), (target:File {id: edge.targetId}) 
CREATE (source)-[:`R`]->(target)

这里的collect(*) as temp会把之前的多行结果（每个node一行）聚合为一行，这样后续处理edges的逻辑就只会执行一次。

方式二：分开加载nodes和edges，逻辑更清晰 #

如果你觉得聚合的方式有点绕，也可以把节点和边的处理分成两个独立的子查询，放在同一个查询窗口执行，既简化操作又保持逻辑直观：

CALL apoc.load.json("file:///files.json") yield value 
UNWIND value.nodes as node 
MERGE (file:File {id:node.path}) ON CREATE SET file.name = node.name;

CALL apoc.load.json("file:///files.json") yield value 
UNWIND value.edges as edge 
MATCH (source:File {id: edge.sourceId}), (target:File {id: edge.targetId}) 
CREATE (source)-[:`R`]->(target);

这种方式和你最初的两个独立查询效果完全一致，同时满足你简化操作的需求。

另外，如果你需要避免后续重复执行查询时再次创建重复关系，可以把CREATE改成MERGE，不过这需要根据你的业务场景来判断是否适用。

内容的提问来源于stack exchange，提问作者Silta