如何使用Neomodel编写多节点关联复杂查询，实现同订单产品检索

前置模型对齐 #

要实现跨Order、Product两类节点的路径匹配，首先需要在Neomodel中明确声明两类节点和CONTAIN关系的结构，这是所有查询的基础：

from neomodel import (StructuredNode, RelationshipTo, 
                      StructuredRel)

# 定义CONTAIN关系结构
class ContainRelation(StructuredRel):
    # 可按需添加关系上的属性，比如订单中购买的商品数量等
    pass

class Product(StructuredNode):
    # 产品业务属性按需定义
    # 关系：标记当前产品被哪些订单包含
    appeared_in_order = RelationshipTo("Order", "CONTAIN", model=ContainRelation)

class Order(StructuredNode):
    # 订单业务属性按需定义
    # 关系：标记当前订单包含哪些产品
    includes_product = RelationshipTo(Product, "CONTAIN", model=ContainRelation)

实现方式1：纯Neomodel ORM链式查询 #

Neomodel的Relationship属性本身就是对图遍历路径的封装，顺着关系逐层遍历即可完全等价匹配你需要的图路径，不需要手写Cypher：

def fetch_co_purchased_products(target_product_id: str):
    # 1. 定位目标产品节点
    target_product = Product.nodes.get(element_id=target_product_id)
    
    # 2. 沿着关系遍历并做聚合统计
    co_purchase_stats = (
        target_product
        .appeared_in_order  # 路径第一步：目标产品 → 所有包含它的Order节点
        .includes_product   # 路径第二步：关联的Order → 这些Order下的所有Product节点
        .exclude(            # 过滤掉目标产品本身，避免自统计
            element_id=target_product_id
        )
        .group_by("self")   # 按遍历到的其他产品节点分组
        .count()            # 统计每个产品的共同购买次数，对应原Cypher的bought_count
    )
    return co_purchase_stats

• 这种写法的优势是查询逻辑和你定义的Neomodel模型强绑定，后续如果调整关系名、节点标签，ORM会自动同步查询逻辑，不会出现手写Cypher和模型不一致的维护问题。

实现方式2：原生Cypher执行接口 #

如果后续查询逻辑更复杂（比如加时间范围筛选、多条件过滤），可以直接使用Neomodel提供的原生Cypher执行能力，适配灵活的复杂查询场景：

from neomodel import db

def fetch_co_purchased_products_native(target_product_id: str):
    cypher_query = """
    MATCH (n:Product)-[:CONTAIN]-(:Order)-[:CONTAIN]-(p2:Product)
    WHERE elementId(n) = $target_id
    RETURN elementId(p2) AS product_id, count(*) AS bought_count
    """
    # 传参执行查询，返回结果列表和列名元组
    query_res, columns = db.cypher_query(
        cypher_query, 
        {"target_id": target_product_id}
    )
    # 将结果转换为结构化字典，方便业务层处理
    return [dict(zip(columns, row)) for row in query_res]

注意：原Cypher中使用的ID(n)是Neo4j旧版本的内部节点ID获取方式，Neo4j 5.x之后推荐使用elementId(n)获取全局唯一节点标识，写查询时要和当前数据库版本匹配，避免兼容性问题。

实现注意事项 #

• 关系方向校验：定义关系时如果是从Order指向Product的CONTAIN有向关系，遍历路径时要对应关系的方向写对，否则会出现路径匹配不到节点的问题
• 自连接过滤：必须在查询中排除目标产品本身，否则会把目标产品自身的购买次数计入统计结果，导致数据失真
• 性能优化：如果节点和关系的数据量较大，需要为Product的唯一标识属性、Order的时间类筛选属性建立索引，避免全量扫描拖慢查询速度

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