使用Neo4j构建航空场景图数据库：CSV导入节点关系问题求助

第一次导入代码问题 #

• 机场节点定义逻辑错误：将出发机场ID、到达机场ID两个不同实体的属性同时存入同一个Airport节点，不符合实体设计逻辑，单个机场不可能同时既是某趟航班的出发地又是到达地，导致生成的机场节点属性完全混乱。
• 关系指向逻辑错误：后续两个MERGE关系语句用同一个机场节点同时关联航班的出发和到达，最终形成航班从某机场出发又飞回同一个机场的错误关系。

第二次导入代码问题 #

• 实体标签拆分冗余：将出发机场、到达机场拆分为Origin和Destination两个独立标签，同一个机场如果既是部分航班的出发地、又是部分航班的目的地，会被生成两个完全独立的节点，后续跨出发/到达的航线查询完全无法关联。
• 航班节点匹配规则有隐患：仅用flightId作为航班的唯一匹配键，同一航班号不同日期的航班会被误合并为同一个节点，导致数据混乱。

步骤1：提前创建唯一约束（加快导入速度+避免重复数据） #

// 机场ID设置唯一约束，避免重复创建同一个机场节点
CREATE CONSTRAINT airport_id_unique FOR (a:Airport) REQUIRE a.id IS UNIQUE;
// 航班设置联合唯一约束，用航班号+日期作为唯一标识，避免同航班号不同日期的航班被合并
CREATE CONSTRAINT flight_unique FOR (f:Flight) REQUIRE (f.flightId, f.Flightdate) IS UNIQUE;

步骤2：执行正确的导入代码 #

LOAD CSV WITH HEADERS FROM 'file:///dummy.csv' AS row
// 匹配/创建出发机场节点，统一使用Airport标签
MERGE (departure_airport:Airport {id: row.Origin})
// 匹配/创建到达机场节点，统一使用Airport标签
MERGE (arrival_airport:Airport {id: row.Dest})
// 匹配/创建航班节点，用航班号+日期唯一匹配
MERGE (flight:Flight {
  flightId: row.Flight_num,
  Flightdate: row.Date,
  distance: row.Distance,
  Flightdelay: row.Total_delay,
  Airline: row.Carrier_code
})
// 创建出发机场到航班的关联关系
MERGE (departure_airport)-[:DEPARTS_FROM]->(flight)
// 创建航班到到达机场的关联关系
MERGE (flight)-[:ARRIVES_AT]->(arrival_airport)

优化说明 #

• 实体设计更合理：所有机场统一使用Airport标签，同一个机场全局仅存在一个节点，后续查询任意机场的出发、到达航线都可以直接关联，不存在冗余节点。
• 匹配规则更严谨：联合唯一约束避免了同航班号不同日期的航班被误合并的问题，导入数据准确率更高。
• 关系语义更清晰：DEPARTS_FROM和ARRIVES_AT的关系指向明确，不会出现逻辑混乱的关联。

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