5

我们有一个包含客户数据的 Couchbase 商店。

  • 每个客户在此存储桶中只有一个文档。
  • 每日交易将导致对此客户数据进行更新。

样本文件。让我们专注于购买的_product_ids数组。

{
  "customer_id" : 1000
  "purchased_product_ids" : [1, 2, 3, 4, 5 ] 
      # in reality this is a big array - hundreds of elements
  ... 
  ... many other elements ...
  ...
} 

Existing purchased_product_ids : 
    [1, 2, 3, 4, 5]

products purchased today : 
    [1, 2, 3, 6]  // 6 is a new entry, others existing already

Expected result after the update: 
    [1, 2, 3, 4, 5, 6]

我正在使用Subdocument API来避免服务器和客户端之间的大量数据传输。

选项1“arrayAppend”： 

customerBucket.mutateIn(customerKey)
    .arrayAppend("purchased_product_ids", JsonObject for [1,2,3,6] )
    .execute();

It results in duplicate elements. 
"purchased_product_ids" : [1, 2, 3, 4, 5, 1, 2, 3, 6]

选项 2“arrayAddUnique”： 

customerBucket.mutateIn(customerKey)
    .arrayAddUnqiue("purchased_product_ids", 1 )
    .arrayAddUnqiue("purchased_product_ids", 2 )
    .arrayAddUnqiue("purchased_product_ids", 3 )
    .arrayAddUnqiue("purchased_product_ids", 6 )
    .execute();

It throws exception for most of the times, 
because those elements already existing.

有没有更好的方法来做这个更新？

4

2 回答 2

4

您需要订购 purchase_product_ids 吗？如果没有，您可以将其转换为地图，例如

{
  "customer_id" : 1000
  "purchased_product_ids" : {1: {}, 3: {}, 5: {}, 2: {}, 4: {}}
}

然后使用 subdoc 写入该地图，知道您不会发生冲突（假设产品 ID 是唯一的）：

customerBucket.mutateIn(customerKey)
   .upsert("purchased_product_ids.1", JsonObject.create()) // already exists
   .upsert("purchased_product_ids.6", JsonObject.create()) // new product
   .execute();

这将导致：

{
  "customer_id" : 1000
  "purchased_product_ids" : {1: {}, 3: {}, 6: {}, 5: {}, 2: {}, 4: {}}
}

（我在这里使用 JsonObject.create() 作为占位符，以防您需要为每个支付的客户订单关联附加信息，但您同样可以只写 null。如果您确实需要订购 purchase_product_ids，您可以写订单的时间戳，例如1: {date: <TIMESTAMP>}，然后在您获取时在代码中对其进行排序。）

于 2018-11-28T11:48:24.307 回答
4

您可以使用 N1QL、ARRAY_APPEND() 和 ARRAY_DISTINCT() 函数。

UPDATE customer USE KEYS "foo" 
SET purchased_product_ids = ARRAY_DISTINCT(ARRAY_APPEND(purchased_product_ids, 9))

大概这将是一个准备好的语句，并且键本身和新值将作为参数提供。

此外，如果您想一次将多个元素添加到数组中，ARRAY_CONCAT() 将是一个更好的选择。更多在这里：

https://docs.couchbase.com/server/6.0/n1ql/n1ql-language-reference/arrayfun.html

于 2018-11-28T13:24:57.000 回答