如何在Neo4j中仅当目标节点存在时创建关系？

针对CSV导入时仅在目标节点存在时创建关系的需求，核心是避免因单个节点不存在导致整行操作失败，同时实现条件化的关系创建。以下是具体实现方案：

针对实际业务场景的修改查询 #

方法1：利用FOREACH模拟条件执行（兼容所有Neo4j版本） #

LOAD CSV FROM 'file:///MyData.csv' AS line
MATCH (n:BOM { Material: line[0]})
WITH n, line
// 若Supplier/Type必须存在，找不到则跳过整行，保持MATCH；若允许不存在，改为OPTIONAL MATCH并添加对应FOREACH逻辑
MATCH (s:Supplier { name:line[2]})
MATCH (t:Type { name: line[7]})
OPTIONAL MATCH (g1:Grade { number: line[6]})
OPTIONAL MATCH (g2:Grade { number: line[5]})

// 创建必选关系
MERGE (n)-[:HAS_SUPPLIER]->(s)
MERGE (n)-[:MATERIAL_TYPE]->(t)

// 仅当g1存在时创建HAS_GRADE关系（priority=1）
FOREACH (_ IN CASE WHEN g1 IS NOT NULL THEN [1] ELSE [] END |
  MERGE (n)-[:HAS_GRADE{priority:1}]->(g1)
)

// 仅当g2存在时创建HAS_GRADE关系（priority=2）
FOREACH (_ IN CASE WHEN g2 IS NOT NULL THEN [1] ELSE [] END |
  MERGE (n)-[:HAS_GRADE{priority:2}]->(g2)
)

方法2：使用CALL {}子句（Neo4j 4.0+推荐） #

LOAD CSV FROM 'file:///MyData.csv' AS line
MATCH (n:BOM { Material: line[0]})
WITH n, line
MATCH (s:Supplier { name:line[2]})
MATCH (t:Type { name: line[7]})
OPTIONAL MATCH (g1:Grade { number: line[6]})
OPTIONAL MATCH (g2:Grade { number: line[5]})

MERGE (n)-[:HAS_SUPPLIER]->(s)
MERGE (n)-[:MATERIAL_TYPE]->(t)

// 条件创建g1对应的关系
CALL {
  WITH n, g1
  WHERE g1 IS NOT NULL
  MERGE (n)-[:HAS_GRADE{priority:1}]->(g1)
} IN TRANSACTIONS OF 1 ROW

// 条件创建g2对应的关系
CALL {
  WITH n, g2
  WHERE g2 IS NOT NULL
  MERGE (n)-[:HAS_GRADE{priority:2}]->(g2)
} IN TRANSACTIONS OF 1 ROW

针对初始查询的修改方案 #

LOAD CSV FROM 'file:///your_source_file.csv' AS line
MERGE (n:Source {id: line[0]})
OPTIONAL MATCH (d1:Destination1 { id: line[2], name: line[3] })
OPTIONAL MATCH (d2:Destination2 { id: line[4], name: line[5] })

// 仅当d1存在时创建关系
FOREACH (_ IN CASE WHEN d1 IS NOT NULL THEN [1] ELSE [] END |
  MERGE (n)-[:MY_RELATIONSHIP]->(d1)
)

// 仅当d2存在时创建关系
FOREACH (_ IN CASE WHEN d2 IS NOT NULL THEN [1] ELSE [] END |
  MERGE (n)-[:MY_RELATIONSHIP]->(d2)
)

关键逻辑说明 #

• OPTIONAL MATCH替代MATCH：避免因单个目标节点不存在而过滤整行，保证其他存在节点的关系能正常创建。
• 条件执行技巧：
  • FOREACH通过CASE生成空/非空集合，集合非空时执行内部MERGE，模拟IF-THEN逻辑，兼容所有Neo4j版本。
  • CALL {}子句支持直接添加WHERE条件，仅当节点存在时执行关系创建，搭配IN TRANSACTIONS可避免大事务风险，适合大规模数据导入。
• 节点存在性区分：对必须存在的节点（如业务上要求必须关联的Supplier）保持MATCH，找不到则跳过整行；对可选存在的节点用OPTIONAL MATCH，找不到则跳过对应关系创建。

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