让我们从创建示例图开始:
gremlin> g = TinkerGraph.open().traversal()
==>graphtraversalsource[tinkergraph[vertices:0 edges:0], standard]
gremlin> g.addV("person").property("name", "Person A").as("pa").
......1> addV("person").property("name", "Person B").as("pb").
......2> addV("food").property("name", "Hamburgers").as("hb").
......3> addV("food").property("name", "Chips").as("c").
......4> addV("food").property("name", "Cheeseburgers").as("cb").
......5> addV("food").property("name", "Fries").as("f").
......6> addV("category").property("name", "Burgers").as("b").
......7> addV("category").property("name", "Appetizers").as("a").
......8> addE("most").from("pa").to("hb").
......9> addE("most").from("pb").to("cb").
.....10> addE("least").from("pa").to("c").
.....11> addE("least").from("pb").to("f").
.....12> addE("similar").from("hb").to("b").
.....13> addE("similar").from("cb").to("b").
.....14> addE("similar").from("c").to("a").
.....15> addE("similar").from("f").to("a").iterate()
您正在寻找的查询如下(我将在后面解释每个步骤):
gremlin> g.V().has("person", "name", "Person A").as("p").
......1> outE("most","least","refuses").as("e").inV().out("similar").
......2> store("x").by(constant(1)).
......3> in("similar").inE().where(eq("e")).by(label).outV().where(neq("p")).
......4> groupCount().as("m").
......5> select("x").by(count(local)).as("c").
......6> select("m").unfold().
......7> where(select(values).as("c")).select(keys).values("name")
==>Person B
现在,当我们添加“拒绝吃苹果”关系时:
gremlin> g.V().has("person", "name", "Person A").as("p").
......1> addV("food").property("name", "Apples").as("a").
......2> addV("category").property("name", "Fruits").as("f").
......3> addE("refuses").from("p").to("a").
......4> addE("similar").from("a").to("f").iterate()
...B 不再匹配:
gremlin> g.V().has("person", "name", "Person A").as("p").
......1> outE("most","least","refuses").as("e").inV().out("similar").
......2> store("x").by(constant(1)).
......3> in("similar").inE().where(eq("e")).by(label).outV().where(neq("p")).
......4> groupCount().as("m").
......5> select("x").by(count(local)).as("c").
......6> select("m").unfold().
......7> where(select(values).as("c")).select(keys).values("name")
gremlin>
让我们一步一步/一行一行的看一遍查询:
g.V().has("person", "name", "Person A").as("p").
这应该很清楚:从人 A 开始。
outE("most","least","refuses").as("e").inV().out("similar").
遍历出边并设置一个标记,以便我们以后可以参考这些边。然后遍历到我称之为category的顶点。
store("x").by(constant(1)).
为每个category 顶点添加一个1 到内部集合。您也可以存储顶点本身,但这会浪费内存,因为我们不需要来自顶点的任何信息。
in("similar").inE().where(eq("e")).by(label).outV().where(neq("p")).
沿similar 边缘向另一个方向移动到food,然后沿与标记边缘具有相同标签的那些边缘从头开始。最后忽略遍历开始的人(人A)。
groupCount().as("m").
计算到达每个人顶点的遍历器数量。
select("x").by(count(local)).as("c").
计算Category 顶点的数量(1s)。
select("m").unfold().
展开人员计数器,因此键将是人员顶点,值将是到达此顶点的遍历器的数量。
where(select(values).as("c")).select(keys).values("name")
最终,交叉的category 顶点的数量必须与person 顶点上的遍历器数量相匹配。如果是这样,我们就有了比赛。
注意,similar 边缘必须与 Apples 顶点发生事件。