出于演示目的,创建一个样本收集集进行测试:
db.collection.insert([
{ "data1": 158000, "data2": 0.25 },
{ "data1": 200000, "data2": 0.5 },
{ "data1": 208000, "data2": 0.75 }
]);
创建具有更新查询的对象列表以及要根据查询更新的派生对象:
var queryList = [
{ "data1": 158000, "data2": 0.25 },
{ "data1": 200000, "data2": 0.5 },
{ "data1": 208000, "data2": 0.75 }
],
updateList = [],
query = {},
obj = {},
update = { "$set": {} },
variable1 = 300000;
如果您想查询每个文档并且事先不知道键,您可以使用 Collection.find() 游标动态生成 updateList 数组并使用 forEach 方法遍历游标,例如:
var queryList = [];
db.collection.find().forEach(function(doc){
var obj = {};
obj["data1"] = doc.data1;
obj["data2"] = doc.data2;
queryList.push(obj);
});
下一步是使用forEach 遍历查询列表数组并使用$set 运算符进行更新:
queryList.forEach(function (item){
obj["data1"] = item["data1"];
obj["data2"] = item["data2"];
obj["data3"] = variable1;
obj["data4"] = variable1 - item["data1"];
obj["data5"] = obj["data4"] * item["data2"];
query["data1"] = item["data1"];
update["$set"] = obj;
db.collection.update(query, update);
});
最后查询集合中的所有文档以显示更新:
db.collection.find();
结果:
/* 0 */
{
"_id" : ObjectId("5530d9f0180e849972938fd7"),
"data1" : 158000,
"data2" : 0.25,
"data3" : 300000,
"data4" : 142000,
"data5" : 35500
}
/* 1 */
{
"_id" : ObjectId("5530d9f0180e849972938fd8"),
"data1" : 200000,
"data2" : 0.5,
"data3" : 300000,
"data4" : 100000,
"data5" : 50000
}
/* 2 */
{
"_id" : ObjectId("5530d9f0180e849972938fd9"),
"data1" : 208000,
"data2" : 0.75,
"data3" : 300000,
"data4" : 92000,
"data5" : 69000
}