MongoDB嵌套对象数组查询

Question

我知道这个问题已经被问了无数次，但是我找不到我的确切情况，所以在这里：

我的数据看起来像这样：

{
"_id" : ObjectId("55bf22a73d64bd3c495adf3d"),
"_data_type" : "questionnaire",
"title" : "Food quality",
"_namespace" : "questionnaire",
"description" : "tell us your opinion",
"created_time" : ISODate("2015-08-03T08:13:27.874Z"),
"questions" : {
    "sub_id_1" : {
        "o2" : "Bad",
        "o1" : "Good",
        "_namespace" : "questionnaire::question",
        "question" : "How do you rate our food quality"
    },
    "sub_id_2" : {
        "o2" : "Bad",
        "o1" : "Good",
        "_namespace" : "questionnaire::question",
        "question" : "How do you rate the colouring of our dishes "
    },
    "sub_id_3" : {
        "o2" : "I don't care!",
        "o1" : "It is greate",
        "_namespace" : "questionnaire::question",
        "question" : "How do you like our couches"
    }
},
"updated_time" : ISODate("2015-08-03T08:20:37.982Z")
}

我想获取所有"o2"等于"Bad"的问题。

我尝试了以下方法，但没有成功。

> db.questionnaire.find({"questions.$.o2": "Bad"})
> db.questionnaire.find({"questions.o2": "Bad"})

- user1221612

---

你能展示一下预期的结果吗？ - styvane

我想要返回所有包含“questions”数组且至少有一个问题的o2 =“Bad”的文档。 - user1221612

我认为目前还没有这个选项！有什么解决方法吗？！ - user1221612

Answer 1

根据您当前的文档结构，您需要使用$where运算符进行JavaScript评估。

db.collection.find(function(){
    for (var key in this.questions) {     
        if (this.questions[key]["o2"] == "Bad")         
            return true; 
    }
})

---

但我建议您更改文档结构，因为通常情况下 您不想使用 $where。要做到这一点，您需要使用Bulk() Api。

var bulk = db.collection.initializeUnorderedBulkOp();
var questions = [];
var subdoc = {};
var count  = 0;

db.collection.find().forEach(function(doc) { 
    for (var key in doc.questions) {     
        subdoc["o2"] = doc.questions[key]["o2"];    
        subdoc["o1"] = doc.questions[key]["o1"];    
        subdoc["_namespace"] = doc.questions[key]["_namespace"]; 
        subdoc["question"] = doc.questions[key]["question"];   
        subdoc["id"] = key;     
        questions.push(subdoc); 
        subdoc = {};
    } 

    bulk.find({ "_id": doc._id }).updateOne({
        "$set": { "questions": questions }});
    count++; 
    if (count % 1000 == 0) {  
        // Execute per 1000 operations and re-init.   
        bulk.execute();    
        bulk = db.collection.initializeUnorderedBulkOp(); 
    } 
})

// Clean up queues
if ( count % 1000 != 0 ) { 
    bulk.execute(); 
}

---

然后你的文档看起来像这样：

> db.collection.find().pretty()
{
        "_id" : ObjectId("55bf22a73d64bd3c495adf3d"),
        "_data_type" : "questionnaire",
        "title" : "Food quality",
        "_namespace" : "questionnaire",
        "description" : "tell us your opinion",
        "created_time" : ISODate("2015-08-03T08:13:27.874Z"),
        "questions" : [
                {
                        "o2" : "Bad",
                        "o1" : "Good",
                        "_namespace" : "questionnaire::question",
                        "question" : "How do you rate our food quality",
                        "id" : "sub_id_1"
                },
                {
                        "o2" : "Bad",
                        "o1" : "Good",
                        "_namespace" : "questionnaire::question",
                        "question" : "How do you rate the colouring of our dishes ",
                        "id" : "sub_id_2"
                },
                {
                        "o2" : "I don't care!",
                        "o1" : "It is greate",
                        "_namespace" : "questionnaire::question",
                        "question" : "How do you like our couches",
                        "id" : "sub_id_3"
                }
        ],
        "updated_time" : ISODate("2015-08-03T08:20:37.982Z")
}

---

你的查询会变得更简单，如果有索引可以使用。

db.collection.find({ "questions.o2": "Bad" })

- styvane