如何使用 gremlin API 在 Azure Cosmos DB 中进行左连接

Question

我正在研究 Azure Cosmos DB 的 Gremlin API，并试图将一些 SQL 语句转换为 Gremlin 遍历。

以下命令：

//add product vertex
g.addV('product').property('id', 'product1')
g.addV('product').property('id', 'product2')
g.addV('product').property('id', 'product3')
g.addV('product').property('id', 'product4')
g.addV('product').property('id', 'product5')

//add product_category vertex
g.addV('product_category').property('id', 'category1')
g.addV('product_category').property('id', 'category2')

//connect product and product_categories

g.V('product1').addE('belongs_to').to(g.V('category1'))
g.V('product2').addE('belongs_to').to(g.V('category1'))
g.V('product3').addE('belongs_to').to(g.V('category2'))
g.V('product4').addE('belongs_to').to(g.V('category2'))
g.V('product5').addE('belongs_to').to(g.V('category2'))

//add image vertex
g.addV('image').property('public_url', 'url_1').property('id', 'image1')
g.addV('image').property('public_url', 'url_2').property('id', 'image2')


//link products to images

g.V('product1').addE('belongs_to').property('primary', true).to(g.V('image1'))
g.V('product2').addE('belongs_to').property('primary', true).to(g.V('image2'))

现在您可以看到，并非所有产品都有图片。

我希望能够选择所有具有类别和图像属性的产品。 如果产品没有图像，则仍应选择具有空图像属性的产品。

我正在尝试通过以下链接执行类似于左连接的操作： http://sql2gremlin.com/#_left_join

但遗憾的是 Azure Cosmos 的 Gremlin API 尚不支持 match() 步骤。

我当前的查询只选择具有图像输出边缘的产品：

g.V()
.has('label', 'product')
.as('product')
.outE('has_image')
.has('primary', true)
.inV()
.as('primary_image')
.in('has_image')
.out('belongs_to')
.as('category')
.select('product','primary_image','category')
.by(__.valueMap()).by(__.values('public_url')).by(__.values('name'))

Answer 1

所以这里发生了几件事：

1) 您上面的脚本无法正常工作，无法将数据插入到 TinkerGraph（我没有 Cosmos 帐户）。我在下面添加了更新的脚本。

2) 你想要的不需要左连接。由于这两种关系都与产品无关，因此您可以从产品顶点投影结果，如下所示：

g.V().
  hasLabel('product').
  project('product', 'category', 'image').
    by(id()).
    by(out('belongs_to').id()).
    by(
      __.out('has_image').fold().
      coalesce(
        unfold().id(), 
        constant('No Image')
      )
    )

这是通过查找所有产品顶点然后返回图像和类别来实现的

3) 那里的 coalesce 语句基于 this Gremlin 配方来检查元素是否存在。如果它没有找到任何东西，因为配方不存在，它会返回一个常量值

4) Gremlin 不允许返回 null 值，因此您需要返回一些内容

更新了添加脚本

//add product vertex
g.addV('product').property(id, 'product1')
g.addV('product').property(id, 'product2')
g.addV('product').property(id, 'product3')
g.addV('product').property(id, 'product4')
g.addV('product').property(id, 'product5')

//add product_category vertex
g.addV('product_category').property(id, 'category1')
g.addV('product_category').property(id, 'category2')

//connect product and product_categories

g.V('product1').addE('belongs_to').to(g.V('category1'))
g.V('product2').addE('belongs_to').to(g.V('category1'))
g.V('product3').addE('belongs_to').to(g.V('category2'))
g.V('product4').addE('belongs_to').to(g.V('category2'))
g.V('product5').addE('belongs_to').to(g.V('category2'))

//add image vertex
g.addV('image').property(id, 'image1').property('public_url', 'url_1')
g.addV('image').property(id, 'image2').property('public_url', 'url_2')


//link products to images

g.V('product1').addE('has_image').to(V('image1')).property('primary', true)
g.V('product2').addE('has_image').to(V('image2')).property('primary', true)