21

这个问题与这个问题密切相关，我将考虑在 NoSQL 上下文中给出的关于模式设计的建议，但我很想了解这一点：

实际问题

假设您有以下文档：

    _id : 2      abcd
    name : 2     unittest.com
    paths : 4    
        0 : 3    
            path : 2     home
            queries : 4      
                0 : 3    
                    name : 2     query1
                    url : 2      www.unittest.com/home?query1
                    requests: 4

                1 : 3    
                    name : 2     query2
                    url : 2      www.unittest.com/home?query2
                    requests: 4

基本上，我想知道

  1. 如果可以在涉及“嵌套度”大于 1 的数组/文档结构的更新场景中多次使用 MongoDB 的位置$运算符（details ），或者换一种说法：

    { <update operator>: { "paths.$.queries.$.requests" : value } }（不起作用）

    而不是“仅”能够对顶级数组使用$ 一次，并且必须对“更高级别”的数组使用显式索引：

    { <update operator>: { "paths.$.queries.0.requests" : value } }) (作品)

  2. 如果可能的话，相应的 R 语法会是什么样子。

您将在下面找到一个可重现的示例。我尽量简洁。

代码示例

数据库连接

require("rmongodb")
db  <- "__unittest" 
ns  <- paste(db, "hosts", sep=".")
# CONNCETION OBJECT
con <- mongo.create(db=db)
# ENSURE EMPTY DB
mongo.remove(mongo=con, ns=ns)

示例文档

q <- list("_id"="abcd")
b <- list("_id"="abcd", name="unittest.com")
mongo.insert(mongo=con, ns=ns, b=b)
q <- list("_id"="abcd")
b <- list("$push"=list(paths=list(path="home")))
mongo.update(mongo=con, ns, criteria=q, objNew=b)
q <- list("_id"="abcd", paths.path="home")
b <- list("$push"=list("paths.$.queries"=list(
    name="query1", url="www.unittest.com/home?query1")))
mongo.update(mongo=con, ns, criteria=q, objNew=b)
b <- list("$push"=list("paths.$.queries"=list(
    name="query2", url="www.unittest.com/home?query2")))
mongo.update(mongo=con, ns, criteria=q, objNew=b)

使用显式位置索引更新嵌套数组（有效）

这可行，但它涉及二级数组的显式queries索引（嵌套在 array 的子文档元素中paths）：

q <- list("_id"="abcd", paths.path="home", paths.queries.name="query1")
b <- list("$push"=list("paths.$.queries.0.requests"=list(time="2013-02-13")))
> mongo.bson.from.list(b)
    $push : 3    
        paths.$.queries.0.requests : 3   
            time : 2     2013-02-13

mongo.update(mongo=con, ns, criteria=q, objNew=b)
res <- mongo.find.one(mongo=con, ns=ns, query=q)
> res
    _id : 2      abcd
    name : 2     unittest.com
    paths : 4    
        0 : 3    
            path : 2     home
            queries : 4      
                0 : 3    
                    name : 2     query1
                    requests : 4     
                        0 : 3    
                            time : 2     2013-02-13


                    url : 2      www.unittest.com/home?query1

                1 : 3    
                    name : 2     query2
                    url : 2      www.unittest.com/home?query2

使用位置索引更新嵌套数组$（不起作用）

现在，我想0用位置$运算符替换显式，就像我所做的那样，以便让服务器找到所需的数组paths( paths.$.queries) 的子文档元素。

AFAIU文档，这应该起作用，因为关键是指定一个“正确”的查询选择器：

位置 $ 运算符，与 update() 方法一起使用时，充当更新查询选择器的第一个匹配项的占位符：

我想我指定了一个查询选择器，它确实找到了正确的嵌套元素（由于paths.queries.name="query1"部分）：

q <- list("_id"="abcd", paths.path="home", paths.queries.name="query1")

我猜翻译成“普通的 MongoDB”语法，查询选择器看起来有点像这样

{ _id: abcd, paths.path: home, paths.queries.name: query1 }

这对我来说似乎是一个有效的查询选择器。事实上，它确实匹配所需的元素/文档：

> !is.null(mongo.find.one(mongo=con, ns=ns, query=q))
[1] TRUE

我的想法是，如果它适用于顶层，为什么它不能适用于更高级别（只要查询选择器指向正确的嵌套组件）？

但是，服务器似乎不喜欢嵌套或多次使用$：

b <- list("$push"=list("paths.$.queries.$.requests"=list(time="2013-02-14")))
> mongo.bson.from.list(b)
    $push : 3    
        paths.$.queries.$.requests : 3   
            time : 2     2013-02-14

> mongo.update(mongo=con, ns, criteria=q, objNew=b)
[1] FALSE

我不确定它是否不起作用，因为 MongoDB 不支持这一点，或者我没有得到正确的 R 语法。

4

2 回答 2

19

位置运算符只支持一个深度并且只支持第一个匹配元素。

这里有一个 JIRA 可跟踪您想要的那种行为：https ://jira.mongodb.org/browse/SERVER-831

我不确定它是否会允许不止一场比赛，但我相信这将是由于它需要如何工作的动态。

于 2013-02-13T14:20:49.830 回答
5

如果您可以从 MongoDB shell 执行查询，则可以利用 MongoDB 游标的forEach函数（http://docs.mongodb.org/manual/reference/method/cursor.forEach/）绕过此限制

这是一个包含 3 个嵌套数组的示例：

var collectionNameCursor = db.collection_name.find({...});

collectionNameCursor.forEach(function(collectionDocument) {
    var firstArray = collectionDocument.firstArray;
    for(var i = 0; i < firstArray.length; i++) {
        var secondArray = firstArray[i].secondArray;
        for(var j = 0; j < secondArray.length; j++) {
            var thirdArray = secondArray[j].thirdArray;
            for(var k = 0; k < thirdArray.length; k++) {
                //... do some logic here with thirdArray's elements
                db.collection_name.save(collectionDocument);
            }
        }
    }
});

请注意，这更像是一次性解决方案，而不是生产代码，但如果您必须编写修复脚本，它就会完成这项工作。

于 2013-09-10T14:30:50.263 回答