问题描述
我有一个 gremlin 查询,我想返回一组用户 ID。目前它正在返回一个数组数组。每个投影一个数组。
有没有办法将这个数组数组转换为查询中的单个用户 ID 数组,或者这是我需要在应用程序级别处理的事情?
非常感谢任何帮助。
g.V('testUser').fold()
.coalesce(
unfold().project('bi_directional_connection','single_directional_connection')
.by(
bothE('bi_directional_connection')
.has('status','ACCEPTED')
.otherV()
.has('active',true)
.values('user_id')
.fold()
.dedup()
.limit(100)
)
.by(
outE('single_directional_connection')
.otherV()
.values('user_id')
.fold()
.dedup()
.limit(100)
).select(values),project('err').by(constant("user does not exist"))
)
编辑: 这是我的示例数据
// Set up test data
g.addV('joshTest1')
.property(T.id,'joshTest1')
.property(single,'user_id','role','test-user')
.property(single,'active',true)
.addV('joshTest2')
.property(T.id,'joshTest2')
.property(single,true)
.addV('joshTest3')
.property(T.id,'joshTest3')
.property(single,true)
.addV('joshTest4')
.property(T.id,'joshTest4')
.property(single,true)
.addE('single_directional_connection')
.from(V('joshTest2'))
.to(V('joshTest1'))
.property('status','ACCEPTED')
.addE('single_directional_connection')
.from(V('joshTest3'))
.to(V('joshTest1'))
.property('status','ACCEPTED')
.addE('bi_directional_connection')
.from(V('joshTest2'))
.to(V('joshTest3'))
.property('status','ACCEPTED')
.addE('bi_directional_connection')
.from(V('joshTest3'))
.to(V('joshTest2'))
.property('status','ACCEPTED')
.addE('bi_directional_connection')
.from(V('joshTest2'))
.to(V('joshTest4'))
.property('status','ACCEPTED')
.addE('bi_directional_connection')
.from(V('joshTest4'))
.to(V('joshTest2'))
.property('status','ACCEPTED')
这是我通过对示例数据运行查询得到的响应。我正在 AWS Jupyter 笔记本中执行此操作。
[['joshTest3','joshTest4','joshTest3','joshTest4'],['joshTest1']]
请注意,我也收到了我不想要的重复项。
我想得到的是:
['joshTest3','joshTest1']
解决方法
这是一个让你前进的答案。我在 dedup
之前移动了 fold
并在最后调整了结果。我将进一步研究这个查询,如果我想出一个更简单的查询作为选项,我会更新这个答案。
g.V('joshTest2').fold()
.coalesce(
unfold().project('bi_directional_connection','single_directional_connection')
.by(
bothE('bi_directional_connection')
.has('status','ACCEPTED')
.otherV()
.has('active',true)
.values('user_id')
.dedup()
.fold()
.limit(100)
)
.by(
outE('single_directional_connection')
.otherV()
.values('user_id')
.dedup()
.fold()
.limit(100)
).select(values)
.unfold()
.unfold()
.fold(),project('err').by(constant("user does not exist"))
)
这产生了
['joshTest3','joshTest4','joshTest1']