CouchDB视图为每个键减少一个文档



我正试图用couchDb视图解决一个看似相当简单的问题,但我的结果集甚至还没有达到目标。

我不是更新文档,而是每次都创建一个新文档作为我的版本控制策略,并用一个名为ver的版本控制字段将这些文档绑定在一起。版本链中的第一个文档将看到具有相同值的ver字段和_id字段。链中的所有后续文档都将具有与链中先前文档相同的ver字段,但将具有唯一的_id字段。这些文档还有一个createdTime字段,这是我知道哪一个文档是最新的。

这是我的文件:

{
"_id": "abcd-1234-efgh-9876",
"ver": "abcd-1234-efgh-9876",
"createdTime": "2020-01-12 01:15:00 PM -0600",
...
},
{
"_id": "uopa-3849-pmdi-1935",
"ver": "abcd-1234-efgh-9876",
"createdTime": "2020-02-16 02:39:00 PM -0600",
...
}

这是我的地图功能:

function (doc) {
emit(doc.ver, doc);
}

这是我的reduce函数:

function(keys, values, rereduce) {
var latestVersions = {};
for (var i = 0; i < keys.length; i++) {
var found = latestVersions[keys[i][0]];
if (!found || found.createdTime < values[i].createdTime) {
latestVersions[keys[i][0]] = values[i];
} 
}
return latestVersions;
}

最后,这是我想要的视图输出(只是我想要的文档(:

{
"_id": "uopa-3849-pmdi-1935",
"ver": "abcd-1234-efgh-9876",
"createdTime": "2020-02-16 02:39:00 PM -0600",
...
}

我在这里错过了什么?reduce函数返回两个记录,这不是我想要的。我试图实现的目标是可能的吗?或者有更好的方法吗?

更新

当使用单个键访问视图时,我就可以实现这一点,这是我的一个用例。

function (keys, values, rereduce) {
var toReturn = values[0];
for (var i = 1; i < values.length; i++) {
if (values[i].createdTime > toReturn.createdTime) {
toReturn = values[i];
}
}
return toReturn;
}

然而,我有另一个用例,它将返回视图中的所有数据。所需的结果与上面相同,但我为单个键使用的函数只会返回一个结果。如何使用共享密钥过滤多个值,使1个"共享"密钥:n个值->1个密钥:1个值。

当我偶然发现这篇基于沙发的文章时,我终于能够解决这个问题。它比其他一些枯燥的计算机科学文档清晰得多。

我仍然不明白为什么某些项目以reduce方法分组,而其他项目则不分组。例如,对于共享相同密钥的6个项目,reduce被调用了5次;只有一个键真正对任何内容进行了分组——一个由两个文档组成的数组。这可能与我掩盖的那些枯燥的计算机科学B树文档有关。

无论如何,我能够确定,在两种情况下,我所需要做的就是通过ver字段对值进行分组(唯一的区别是reduce有一个二维数组(。以下是我的reduce函数的结果:

function (keys, values, rereduce) {
var toValues = function(myMap) {
return Object.keys(myMap).map(function(key) {
return myMap[key];
});
}
if (rereduce) {
// values should look like [[{...}, {...}], [{...}]]
var outputMap = {};
for (var i = 0; i < values.length; i++) {
for (var j = 0; j < values[i].length; j++) {
var currentEl = values[i][j];
var found = outputMap[currentEl.ver];
if ((found && found.createdDate < currentEl.createdDate) || !found) {
outputMap[currentEl.ver] = currentEl;
}
}
}
return toValues(outputMap);
} else {
var outputMap = {};
for (var i = 0; i < values.length; i++) {
var found = outputMap[values[i].ver];
if ((found && found.createdDate < values[i].createdDate) || !found) {
outputMap[values[i].ver] = values[i];
}
}
return toValues(outputMap);
}
}

相关内容

  • 没有找到相关文章

最新更新