我有一个mongodb集合,其中包含这种类型的结构。
modules: [ { systems:[ { systemId: 13, count: 2 }, { systemId: 20, count: 7 }, { systemId: 8, count: 1 } ] }, { systems:[ { systemId: 13, count: 2 }, { systemId: 20, count: 7 } ] } ]
我想做的是update
每个module
包含system
withsystemId = 13
和$set
整个系统的{d: null}
这样以后看起来像这样:
modules: [ { systems:[ { d: null }, { systemId: 20, count: 7 }, { systemId: 8, count: 1 } ] }, { systems:[ { d: null }, { systemId: 20, count: 7 } ] } ]
由于您具有嵌套数组,因此只有添加了SERVER-831的功能请求后,才能通过单个查询来实现。一旦$elemMatch
允许嵌套运算符,则您的更新将如下所示。注意:这目前尚无法使用,语法尚未定义-仅用于说明目的:
db.foo.update(
{modules: {$elemMatch: { systems: {$elemMatch: {systemId : 13}}}}},
{ $set : {"modules.$0.systems.$1" : {d : null}}}
);
该查询的查找部分当前有效,但即使您$
从理论值$0
和恢复为当前值,该更新部分也不允许多个位置运算符$1
。
即使那样,您仍然会遇到$ elemMatch的第一个元素匹配限制(它不匹配多个/所有元素,只是它找到的第一个元素),因此您可能必须多次运行才能更新所有文档,至少直到SERVER-1243完成。
为了说明如何使用单个数组,这非常简单,让我们插入示例文档并删除modules字段:
db.bar.insert([{
systems:[
{ systemId: 13, count: 2 },
{ systemId: 20, count: 7 },
{ systemId: 8, count: 1 }
]
},
{
systems:[
{ systemId: 13, count: 2 },
{ systemId: 20, count: 7 }
]
}
]);
这实际上创建了两个文档(它将数组中的每个元素都视为要插入的文档)。因此,我们现在有2个文档:
> db.bar.find()
{ "_id" : ObjectId("5450e0708e1b8924251e1330"), "systems" : [ { "systemId" : 13, "count" : 2 }, { "systemId" : 20, "count" : 7 }, { "systemId" : 8, "count" : 1 } ] }
{ "_id" : ObjectId("5450e0708e1b8924251e1331"), "systems" : [ { "systemId" : 13, "count" : 2 }, { "systemId" : 20, "count" : 7 } ] }
要按概述更新这些文档(只要存在的唯一匹配项systemId : 13
,则可以执行以下操作:
>db.bar.update(
{ systems: {$elemMatch: {systemId : 13}}},
{ $set : {"systems.$" : {d : null}}},
{multi : true}
);
WriteResult({ "nMatched" : 2, "nUpserted" : 0, "nModified" : 2 })
让我们再次看一下我们的文档:
> db.bar.find()
{ "_id" : ObjectId("5450e1198e1b8924251e1332"), "systems" : [ { "d" : null }, { "systemId" : 20, "count" : 7 }, { "systemId" : 8, "count" : 1 } ] }
{ "_id" : ObjectId("5450e1198e1b8924251e1333"), "systems" : [ { "d" : null }, { "systemId" : 20, "count" : 7 } ] }
您可以暂时将数据转换成这种格式吗?是的,但这意味着一个新集合:
db.foo.aggregate([
{$match: {modules: {$elemMatch: { "systems": {$elemMatch: {"systemId" : 13}}}}}},
{$unwind : "$modules"},
{$project : {"_id" : 0, "systems" : "$modules.systems"}},
{$out : "flattened_systems"}
])
// confirm the new doc structure
db.flattened_systems.find()
{ "_id" : ObjectId("5450e4702127b5e51e8a9e0a"), "systems" : [ { "systemId" : 13, "count" : 2 }, { "systemId" : 20, "count" : 7 }, { "systemId" : 8, "count" : 1 } ] }
{ "_id" : ObjectId("5450e4702127b5e51e8a9e0b"), "systems" : [ { "systemId" : 13, "count" : 2 }, { "systemId" : 20, "count" : 7 } ] }
然后,您可以运行上面的更新以修改systemIds
和重新聚合以返回到原始结构:
db.flattened_systems.update(
{ systems: {$elemMatch: {systemId : 13}}},
{ $set : {"systems.$" : {d : null}}},
{multi : true}
);
db.flattened_systems.aggregate([
{$group : { "_id" : 0, "modules" : {$push : {"systems" : "$systems"}}}},
{$project : {"_id" : 0, "modules" : 1, "flag" : {$literal : "new"}}},
{$out : "processed_systems"}
])
因此,该processed_systems
集合现在具有所需格式的文档(附加的“新”标志是可选的,以显示如何将其标记为已更新):
> db.processed_systems.find()
{ "_id" : ObjectId("5450e9e92127b5e51e8a9e10"), "modules" : [ { "systems" : [ { "d" : null }, { "systemId" : 20, "count" : 7 }, { "systemId" : 8, "count" : 1 } ] }, { "systems" : [ { "d" : null }, { "systemId" : 20, "count" : 7 } ] } ], "flag" : "new" }
这并不理想,特别是如果正在积极更新文档(无法自动执行此操作)的情况下,但希望它可以使您对过渡期间的处理方法有所了解。我很确定您也可以使用Map Reduce做到这一点,但最好将其作为一个单独的问题来提出。
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句