couchbase - 如何使用函数或运算符遍历Couchbase中的记录

我的沙发床群集中有两个水桶。我想为bucket1中的每个jsonDocument迭代bucket2中存在的所有jsonDocuments，并且我想使用某种逻辑将bucket1中的选定字段合并到bucket2中。

以下是伪步骤

for(JsonDocument inDoc: bucket1Docs) {
    for(JsonDocument outDoc: bucket2Docs) {
        JsonObject obj = outDoc.content();
        // After some arithmetic calculations
        obj.put(inDoc.content().get("key1"));
         bucket2.upsert(JsonDocument.create(key, obj));
    }
}

注意:bucket2包含10万条记录。我也有兴趣以分页方式执行此操作。

我需要一个沙发床查询字符串来执行上述操作。

任何建议都非常感谢。

最佳答案

如果要直接从N1QL执行此操作，可以使用以下语句:

upsert into bucket2 (KEY original_id, VALUE original_doc)
    select meta().id original_id, b original_doc from bucket1 b

如果要在现有文档已经存在的情况下进行一些更复杂的合并，请查看MERGE语句:
https://docs.couchbase.com/server/6.0/n1ql/n1ql-language-reference/merge.html

如果要将两个对象的值合并为一个，OBJECT_CONCAT()函数可能也很有用。
https://docs.couchbase.com/server/6.0/n1ql/n1ql-language-reference/objectfun.html#object_concat