Neo4j Cypher转Gremlin查询：extract方法等效实现求助

以下是与你提供的Cypher查询功能完全匹配的Gremlin查询，其中用Gremlin的路径处理逻辑替代了Cypher的extract方法：

g.V()
  // 匹配起始节点：Person标签、title为John的节点
  .hasLabel('Person').has('title', 'John')
  // 遍历1-5跳路径，直到匹配目标节点
  .repeat(outE().inV())
    .times(1, 5)
    .hasLabel('Location').has('title', 'New York City')
  // 获取完整路径
  .path()
  // 构造目标输出结构
  .project('title', 'relation', 'node', 'len', 'node_data', 'id', 'rel_id', 'start', 'end')
    // 提取路径中所有节点的title属性列表
    .by(path().nodes().values('title').fold())
    // 提取路径中所有边的标签（关系类型）列表
    .by(path().edges().label().fold())
    // 提取路径中所有节点的标签（对应Cypher的j.nt，若nt是属性则替换为values('nt')）
    .by(path().nodes().label().fold())
    // 路径长度（边的数量）
    .by(path().edges().count())
    // 提取路径中所有节点的完整属性（将属性值从列表转为单个值）
    .by(path().nodes().valueMap().by(unfold()).fold())
    // 提取路径中所有节点的ID列表
    .by(path().nodes().id().fold())
    // 提取路径中所有边的ID列表
    .by(path().edges().id().fold())
    // 提取每条边的起始节点ID列表
    .by(path().edges().outV().id().fold())
    // 提取每条边的结束节点ID列表
    .by(path().edges().inV().id().fold())

关键映射说明 #

Cypher的extract本质是对集合元素做遍历转换，Gremlin通过path().nodes()/path().edges()获取路径中的节点/边集合，再结合属性提取步骤完成转换，最后用fold()将结果收集为列表：

• extract(x IN nodes(p) | x.title) → path().nodes().values('title').fold()：提取所有节点的title属性并转为列表
• extract(i IN relationships(p)| type(i)) → path().edges().label().fold()：提取所有边的标签（对应Cypher的关系类型）
• extract(j IN nodes(p) | j.nt) → 若nt是节点标签则用path().nodes().label().fold()，若为自定义属性则替换为path().nodes().values('nt').fold()
• length(p) → path().edges().count()：统计路径中边的数量，与Cypher的length(p)逻辑一致
• extract(x IN nodes(p) | x) → path().nodes().valueMap().by(unfold()).fold()：获取节点的完整属性集，by(unfold())确保属性值为单个值（而非Gremlin默认的列表格式）
• extract(i in nodes(p)| id(i)) → path().nodes().id().fold()：提取所有节点的ID
• extract(i IN relationships(p)| id(i)) → path().edges().id().fold()：提取所有边的ID
• extract(rel IN relationships(p) | id(startNode(rel))) → path().edges().outV().id().fold()：提取每条边的起始节点ID
• extract(rel IN relationships(p) | id(endNode(rel))) → path().edges().inV().id().fold()：提取每条边的结束节点ID

注意事项 #

• 若你的图数据库中节点标签不是通过label()获取（而是存储在nt属性中），请将path().nodes().label().fold()替换为path().nodes().values('nt').fold()
• times(1,5)对应Cypher的[rel*..5]，限制路径边数为1-5跳；若需要允许0跳（即起始节点等于目标节点），可改为repeat(...).until(has(...).or().loops().is(eq(5)))

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