hasNext 返回错误结果

Question

我想检查两个节点之间的关系是否存在。如果存在，我想更新属性，否则在指定节点之间添加新关系。一个 groovy 脚本用于从 CSV 文件中读取数据并运行查询。

g.V().has('label_A','A').outE('to').inV().has('label_B','B').hasNext() ? g.V().has('label_A','A').outE('to').as('e').inV().has('label_B','B').select('e').property('created','existed') : g.V().has('label_A','A').as('fromV').V().has('label_B','B').as('toV').addE('to').from('fromV').to('toV').property('created','newAdded')

g.V().has('label_A','A').outE('to').inV().has('label_B','B').hasNext() 即使通过 groovy 脚本运行时，给定两个节点之间存在关系。 gremlin 控制台上的相同命令返回预期的输出。因此，总是会创建新的关系。

还尝试了以下查询

g.V().hasLabel('label_A','A').as('v').V().has('label_B','B').coalesce(__.inE('to').where(outV().as('v')),addE('to').from('v').property('created','newAdded')).property('created','existed')

上述查询无效。没有添加任何关系。

Answer 1

从纯粹的 Gremlin 角度来看，我认为您更愿意将遍历写为：

g.V().has('label_A','A').
  outE('to').where(inV().has('label_B','B')).
  fold().
  coalesce(unfold().property('created','existed'),
           addE('to').
           from(V().has('label_A','A')).
           to(V().has('label_B','B')).
           property('created','newAdded'))

通过这种方式，它将在单个请求/事务中执行，而不是两个单独的操作。您可以在以下与 TinkerGraph 的 Gremlin 控制台会话中看到它的实际效果：

gremlin> g = TinkerGraph.open().traversal()
==>graphtraversalsource[tinkergraph[vertices:0 edges:0], standard]
gremlin> g.addV().property('label_A','A').iterate()
gremlin> g.addV().property('label_B','B').iterate()
gremlin> g.V().has('label_A','A').
......1>   outE('to').where(inV().has('label_B','B')).
......2>   fold().
......3>   coalesce(unfold().property('created','existed'),
......4>            addE('to').
......5>            from(V().has('label_A','A')).
......6>            to(V().has('label_B','B')).
......7>            property('created','newAdded'))
==>e[4][0-to->2]
gremlin> g.E().elementMap()
==>[id:4,label:to,IN:[id:2,label:vertex],OUT:[id:0,label:vertex],created:newAdded]
gremlin> g.V().has('label_A','A').
......1>   outE('to').where(inV().has('label_B','B')).
......2>   fold().
......3>   coalesce(unfold().property('created','existed'),
......4>            addE('to').
......5>            from(V().has('label_A','A')).
......6>            to(V().has('label_B','B')).
......7>            property('created','newAdded'))
==>e[4][0-to->2]
gremlin> g.E().elementMap()
==>[id:4,label:to,IN:[id:2,label:vertex],OUT:[id:0,label:vertex],created:existed]

至于为什么您的方法在 JanusGraph 中不起作用，鉴于所提供的信息很难说。也许您应该尝试使用 JanusGraph 自己重新创建我的 Gremlin 控制台会话，看看会发生什么。如果它仍然不适合您，您可以提供一个完全失败的示例供 JanusGraph 专家查看。