基于顶点属性过滤Gremlin路径的问题及查询失效排查

图构造代码 #

g.addV('ORG').as('1').
  property(single, 'orgId', 'f5c').addV('COMP').
    as('2').
  property(single, 'compId', 2112896).
  property(single, 'owner', 'def').addV('COMP').
    as('3').
  property(single, 'compId', 2100198).
  property(single, 'owner', 'def').addV('COMP').
    as('4').
  property(single, 'compId', 4007384).
  property(single, 'owner', 'def').addV('COMP').
    as('5').
  property(single, 'compId', 2106827).
  property(single, 'owner', 'abc').addV('COMP').
    as('6').
  property(single, 'compId', 2106829).
  property(single, 'owner', 'abc').addV('COMP').
    as('7').
  property(single, 'compId', 2104080).
  property(single, 'owner', 'abc').addV('COMP').
    as('8').
  property(single, 'compId', 2110851).
  property(single, 'owner', 'abc').addV('ORG').
    as('9').
  property(single, 'orgId', 28932).addE('edge').
  from('1').to('5').property('sub', '951a').
  addE('edge').from('1').to('2').
  property(single, 'sub', 5779).addE('edge').from('2').
  to('3').property(single, 'sub', 5779).addE('edge').
  from('3').to('4').property(single, 'sub', 5779).
  addE('edge').from('5').to('6').
  property(single, 'sub', '951a').addE('edge').
  from('6').to('7').property(single, 'sub', '951a').addE('edge').
  from('7').to('8').
  property(single, 'sub', '951a').addE('edge').
  from('4').to('9').property(single, 'sub', 1234).
  addE('edge').from('8').to('9').
  property(single, 'sub', 465474)

基础查询结果 #

执行以下查询可得到2条符合预期的路径：

g.V().has("orgId", "f5c")
.repeat(bothE().otherV().simplePath())
.until(hasLabel("ORG")).path().by(valueMap())

问题1：过滤路径中所有顶点owner≠def的查询未生效 #

原查询问题分析

原查询将hasNot("owner","def")放在repeat的每一步跳转后，这会要求每一步跳转到的顶点都必须满足owner≠def，但你实际需要的是整条路径中所有顶点都不存在owner=def的情况。这种写法会直接过滤掉从起点跳转到owner=def顶点的分支，但如果起始顶点（ORG类型）没有owner属性，逻辑上也需要兼容，原写法的过滤时机不对。

正确查询

方案1：生成路径后对整条路径进行过滤（更直观）

g.V().has("orgId", "f5c")
.repeat(bothE().otherV().simplePath())
.until(hasLabel("ORG"))
.path().by(valueMap())
// 过滤掉路径中包含owner=def的顶点的结果
.filter(unfold().coalesce(has("owner", "def"), constant(false)).not())

方案2：遍历过程中提前过滤不符合条件的分支

g.V().has("orgId", "f5c")
.repeat(
  bothE().otherV().simplePath()
  // 保留无owner属性或owner≠def的顶点
  .hasNot("owner", "def")
)
.until(hasLabel("ORG"))
.path().by(valueMap())

问题2：查询经过compId=2100198的顶点无结果 #

原查询问题分析

原查询将has("compId", 2100198)放在repeat的每一步跳转后，意味着每一步跳转到的顶点都必须是compId=2100198的顶点，但该顶点只是路径中的一个中间节点，并非每一步都要到达它，这种写法会直接过滤掉所有正常路径，导致无结果。

正确查询

方案1：生成路径后检查是否包含目标顶点

g.V().has("orgId", "f5c")
.repeat(bothE().otherV().simplePath())
.until(hasLabel("ORG"))
.path().by(valueMap())
// 过滤出包含compId=2100198顶点的路径
.filter(unfold().has("compId", 2100198))

方案2：遍历过程中匹配目标顶点后继续遍历到终点

g.V().has("orgId", "f5c").as("start")
.match(
  __.from("start").repeat(bothE().otherV().simplePath()).until(has("compId", 2100198)).as("target"),
  __.from("target").repeat(bothE().otherV().simplePath()).until(hasLabel("ORG")).as("end")
)
.path("start", "target", "end").by(valueMap())

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