查询MongoDB数组中的数组；如果存在则更新，如果为空则插入

Question

我想修改MongoDB中的文档。以下是相关文档结构的示例摘录：

{ values : { M1 : [[1395964800, 0.083434], ... , [1395964860, 0.043424]] } }

首先，keyM1包含一个数组数组。我必须搜索嵌套数组中的[0]项（纪元时间，例如1395964800,1395964860）。如何通过[0]嵌套数组值查找文档？例如，我尝试搜索：

db.myCollection.find({ "values" : { "M1" : [1395964800, 0.083434] } }).limit(1);

诚然，我预计这种方法将通过[0]嵌套数组值进行搜索

其次，如果这个[0]数组值已经存在（纪元时间），我想更新/覆盖嵌套数组中的[1]元素（数据值）。如果[0]数组值在M1数组中不存在，我想将其（以及随附的数据值）添加到M1数组中。

我希望我会使用类似的东西：

db.collection("myCollection").findAndModify(
   { ........ }, // query
   { }, // sort
   { $set : { ... : ... }}, // set
   { upsert: true }, // insert if does not exist
   function (err, result) {
      (err) throw err
   }
);

问题

1. 如何按说明进行搜索
2. 如何按说明更新

Answer 1

这里有匿名嵌套数组，这不是在MongoDB中处理数据的好格式。除了选择问题之外，匹配要更新的项目是一个真正的问题，因为只有在尝试实际匹配位置时，您才仅限于第一个索引匹配*。

请参见位置$运算符留档。

要解决这个问题，您实际上需要一个适合的模式，例如：

{ 
    values : { 
        M1 : [
            { "time": 1395964800, "value": 0.083434 },
            { "time": 1395964860, "value": 0.043424 } 
        ]
    }
}

使用该结构，您可以搜索“时间”值，如下所示：

db.collection.find(
    { "values.M1.time": 1395964860 },
    { "values.M1.$": 1 }
)

这将把数组的“匹配”元素投影到文档中找到它的地方。

对于更新，您可以使用相同的位置运算符：

db.collection.update(
   { "values.M1.time": 1395964860 },
   { "$set": { "values.M1.$.value": 0.055000 } }
)

但是对于当前的嵌套形式，您不能比显式匹配更好:

db.collection.find({ "values.M1.0.0": 1395964800 })

您需要知道要匹配的内容的索引值，这违背了存储它的目的。

更改您的架构，这将是一个更加灵活的解决方案。

Answer 2

下面的代码是我为解决我的问题而创建的解决方案。特别是，以下线索帮助了我:

• MongoDB 嵌套数组查询
• 对嵌套数组元素的 Mongodb 查询

需要明确的是，在我的情况下，unixTime值在数组本身和嵌套数组之间都是唯一的。我希望其他人觉得这有帮助。

var unixTime = 1395964800; // e.g. This can be programmatically changed
var _query = {'values.M1' : { '$elemMatch' : { '$in' : [unixTime] } } } ; // This allows us to search within the nested arrays for a specific value (in any position).

db.collection("myCollection").findAndModify(
    _query, // query
    { start_timestamp : -1 }, // sort
    { $set : { 'values.M1.$' : [unixTime, value] }}, // set with $, which is crucual because it uses the previously found/matched array item
    { upsert: true}, // insert if does not exist
    function (err, result) {
        if (err) console.log(error);
        console.log('results',results);
    }
);