求助：如何用Python在Neo4j中正确创建国家边境关系？

我需要用Python在Neo4j中创建国家间的边境关系，但现有代码存在问题：

问题1：仅创建节点，未生成关系 #

以下代码运行后只会生成孤立的Country节点，无法创建HAS_BORDER_WITH关系：

from neo4j import GraphDatabase
driver = GraphDatabase.driver("neo4j://localhost:7687",
                              auth=("neo4j", "test"))

def create_country(tx, name,continent,population_mln,govrm_system,bcountry):
    tx.run("CREATE (a:Country {name: $name,continent: $continent,population_mln: $population_mln,govrm_system:$govrm_system,bcountry: $bcountry})")
           name=name,continent=continent,population_mln=population_mln,govrm_system=govrm_system,bcountry=bcountry)

with driver.session() as session:
    session.execute_write(create_country, "russia","Asia",143,"terrorist state",["Kazakhstan","Lithuania","Finland","China","Japan"])
    session.execute_write(create_country, "India","Asia",1393,"Parliamentary Republic","China")
    session.execute_write(create_country, "China","Asia",1412,"One-party state",["India","russia","Philipines","Japan"])
    session.execute_write(create_country, "Poland","Europe",37,"Parliamentary Republic",["Lithuania","Germany","Czechia"])
    session.execute_write(create_country, "Kazakhstan","Asia",19,"Presidential system Republic","russia")
    session.execute_write(create_country, "Lithuania","Europe",2.7,"Parliamentary Republic",["russia","Poland"])
    session.execute_write(create_country, "Finland","Europe",5.5,"Parliamentary Republic","russia")
    session.execute_write(create_country, "Philipines","Asia",111,"Parliamentary Republic",["Japan","China"])
    session.execute_write(create_country, "Japan","Asia",125,"Constitutional Monarchy",["Philipines","China","russia"])
    session.execute_write(create_country, "Germany","Europoe",83,"Parliamentary Republic",["Czechia","Austria","Poland"])
    session.execute_write(create_country, "Czechia","Europoe",10,"Parliamentary Republic",["Austria","Poland","Germany"])
    session.execute_write(create_country, "Austria","Europoe",9,"Parliamentary Republic",["Czechia","Germany"])

def create_bordering_country(tx, name, bcountry):
    tx.run("FOREACH (n IN a.bcountry | MERGE (bcountry:Country {name: n}) MERGE (a)-[:HAS_BORDER_WITH]-(bcountry))") 

问题原因： #

1. create_bordering_country函数定义后未被调用，关系逻辑从未执行
2. Cypher语句中a未绑定任何参数，无法匹配已创建的节点
3. 将邻国列表存储为节点属性不符合Neo4j的关系设计范式，边境关联应使用边而非属性

问题2：创建关系但产生重复节点 #

以下代码能创建关系，但会生成重复的国家节点：

def create_bordering_country(tx, name, bcountry):
    tx.run("MATCH (a:Country) WHERE a.name = $name "
           "MERGE (a)-[:HAS_BORDER_WITH]-(:Country {name: $bcountry}) RETURN DISTINCT a.name",
           name=name, bcountry=bcountry)

session.execute_write(create_bordering_country, "russia", "China")
session.execute_write(create_bordering_country, "India", "China")
session.execute_write(create_bordering_country, "russia", "Kazakhstan")
session.execute_write(create_bordering_country, "russia", "Lithuania")
session.execute_write(create_bordering_country, "russia", "Finland")
session.execute_write(create_bordering_country, "Poland", "Lithuania")
session.execute_write(create_bordering_country, "China", "Japan")
session.execute_write(create_bordering_country, "Russia", "Japan")
session.execute_write(create_bordering_country, "Philipines", "Japan")
session.execute_write(create_bordering_country, "Philipines", "China")
session.execute_write(create_bordering_country, "Germany", "Poland")
session.execute_write(create_bordering_country, "Austria", "Poland")
session.execute_write(create_bordering_country, "Czechia", "Poland")
session.execute_write(create_bordering_country, "Czechia", "Austria")
session.execute_write(create_bordering_country, "Czechia", "Germany")
session.execute_write(create_bordering_country, "Germany", "Austria") 

问题原因： #

MERGE (a)-[:HAS_BORDER_WITH]-(:Country {name: $bcountry})直接创建匿名节点，当国家名称大小写不一致（如russia和Russia）时，会生成新节点而非匹配已存在的节点。

正确实现方案 #

步骤1：修正节点创建逻辑 #

先确保所有国家节点正确创建，去掉冗余的bcountry属性，统一名称拼写（如Europoe改为Europe）：

from neo4j import GraphDatabase
driver = GraphDatabase.driver("neo4j://localhost:7687", auth=("neo4j", "test"))

def create_country(tx, name, continent, population_mln, govrm_system):
    # 使用MERGE避免重复创建节点
    tx.run("""
        MERGE (a:Country {name: $name})
        SET a.continent = $continent,
            a.population_mln = $population_mln,
            a.govrm_system = $govrm_system
    """, name=name, continent=continent, population_mln=population_mln, govrm_system=govrm_system)

# 统一国家名称大小写，避免后续匹配错误
country_data = [
    ("Russia", "Asia", 143, "terrorist state"),
    ("India", "Asia", 1393, "Parliamentary Republic"),
    ("China", "Asia", 1412, "One-party state"),
    ("Poland", "Europe", 37, "Parliamentary Republic"),
    ("Kazakhstan", "Asia", 19, "Presidential system Republic"),
    ("Lithuania", "Europe", 2.7, "Parliamentary Republic"),
    ("Finland", "Europe", 5.5, "Parliamentary Republic"),
    ("Philippines", "Asia", 111, "Parliamentary Republic"),  # 修正拼写错误Philipines
    ("Japan", "Asia", 125, "Constitutional Monarchy"),
    ("Germany", "Europe", 83, "Parliamentary Republic"),
    ("Czechia", "Europe", 10, "Parliamentary Republic"),
    ("Austria", "Europe", 9, "Parliamentary Republic")
]

with driver.session() as session:
    for data in country_data:
        session.execute_write(create_country, *data)

步骤2：创建边境关系 #

编写函数匹配已存在的节点，再创建关系，避免重复节点和重复关系：

def create_border_relation(tx, country_name, neighbor_name):
    tx.run("""
        MATCH (a:Country {name: $country_name})
        MATCH (b:Country {name: $neighbor_name})
        MERGE (a)-[:HAS_BORDER_WITH]-(b)
    """, country_name=country_name, neighbor_name=neighbor_name)

# 定义边境关系数据，统一名称大小写
border_relations = [
    ("Russia", "Kazakhstan"),
    ("Russia", "Lithuania"),
    ("Russia", "Finland"),
    ("Russia", "China"),
    ("Russia", "Japan"),
    ("India", "China"),
    ("China", "Philippines"),
    ("China", "Japan"),
    ("Poland", "Lithuania"),
    ("Poland", "Germany"),
    ("Poland", "Czechia"),
    ("Germany", "Czechia"),
    ("Germany", "Austria"),
    ("Czechia", "Austria"),
    ("Philippines", "Japan")
]

with driver.session() as session:
    for rel in border_relations:
        session.execute_write(create_border_relation, *rel)

driver.close()

关键说明： #

1. 使用MERGE创建节点，确保重复执行时不会生成重复节点
2. 创建关系时先通过MATCH找到两个已存在的国家节点，再用MERGE创建关系，避免生成重复节点和重复关系
3. 统一所有国家名称的大小写和拼写，消除匹配误差
4. 移除节点的bcountry属性，改用Neo4j的边来表示边境关联，符合图数据库设计规范

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