MongoDB系列8：MongoDB集合的增量更新
邓开表同学实战MongoDB系列文章，非常不错，赞！大力推荐！
本文是第 8 篇，主要讲述MongoDB集合的增量更新的实战经验，非常值得一看。
前面系列文章：
MongoDB安全实战之Kerberos认证
MongoDB Compass--MongoDB DBA必备的管理工具
MongoDB安全实战之审计
MongoDB安全实战之SSL协议加密
MongoDB安全实战之网络安全加固
MongoDB索引的介绍
MongoDB存储引擎
在关系型数据库中，经常会遇到这样的场景：用某张表或是多张表的关联产生的结果集，然后持续地更新另外一张表的数据，有时为了方便，只更新变化的数据，即增量更新。那么在MongoDB中如何实现这种场景呢？
1、现有student集合，数据如下（s_id--学号，c_id--课程号，name--姓名，sex---性别，score--成绩）：
图1
场景一 ：将student集合数据复制到另外一个集合target里面，在关系型数据库中，复制一张表的数据可以采用insert into table_a select .....或create table table_aas select .....方式，而在MongoDB中，可以使用如下语句实现：
db.student.find().forEach( function(m) {
db.target.insert(m);
});
图2
场景二 ：现在student集合和target集合有一样的数据，后续如果student集合的数据有变化，target集合需要根据student集合的数据进行更新，而且每次只需要更新变化的数据，即增量更新。使用以下的语句来是实现集合的增量更新：
1）先向student集合新增一个文档和修改s_id学号为001的文档：
db.student.insert({"_id":15,"s_id":"006","c_id":7,"name":"ken","sex":"male","score":67})
db.student.update({"s_id":"001"},{"$set":{"sex":"female"}},false,true)
图3
2) 更新集合target的数据：
db.student.find().forEach(function(m){
db.target.findAndModify({
query: { _id : m._id },
update: {Sset : {“s_id”:m.s_id, ”c_id”:m.c_id,”name”:m.name,”sex”:m.sex,”score”:m.score}},
upsert: true
});
});
图4
说明：
query：对应是查询文档，用于检索文档的条件；
update: 对应修改器的文档，用于更新所找到的文档；
upsert: 指当没有文档匹配时，是否插入；
场景三 ：多集合关联增量更新另一个集合。
集合student：s_id--学号，c_id--课程号，name--姓名，sex--性别，score--成绩
集合course：_id--课程号，c_name--课程名称
student和course集合数据分别如下图：
图5
图6
1) 现需要查询出成绩合格（大于等于60分），的学生号、学生姓名和课程名称。代码如下：
db.student.aggregate([{
$lookup:
{
from :"course",
localField:"c_id",
foreignField: "_id",
as:"course_documents"
}
},
{
$replaceRoot:{newRoot: {$mergeObjects: [{ $arrayElemAt:["$course_documents",0]},"$$ROOT"] }}
},
{$project:{course_documents:0}},
{$match : {"score":{"$gte":60}}}
]).forEach(function(m) {
db.pass.insert({"_id":m._id,"s_id":m.s_id,"name":m.name,"c_name":m.c_name});
});
图7
说明：
$lookup相当于关系型数据库SQL的join。
其中from参数指定要关联集合B；
localField参数指定集合A的等值对比的键。
foreignField参数指定集合B要与集合A做等值对比的键。
as参数指定符合关联的集合B记录，以指定名称作为键，集合B记录为值的数组形式返回。
$replcaceRoot作用是指定文档提升到顶层，由于$lookup关联后，集合B的记录是作为as参数指定名称的键的值，和集合A的字段不在同个层级，可以使用$replaceRoot实现文档提升到顶层。
$project作用是指定的键是否排除，0表示排除，1表示保留。
$match相当于关系型数据库SQL的where子句。
2) 当student和course集合数据增加时，增量更新pass集合。
分别向student、course添加两个文档：
db.student.insert({"_id":16,"s_id":"007","c_id":11,"name":"tony","sex":"male","score":57})
db.student.insert({"_id":17,"s_id":"007","c_id":12,"name":"tony","sex":"male","score":67})
db.course.insert({"_id":11,"c_name":"Spark"})
db.course.insert({"_id":12,"c_name":"Hbase"})
增量更新pass：
db.student.aggregate([{
$lookup:
{
from :"course",
localField:"c_id",
foreignField:"_id",
as:"course_documents"
}
},
{
$replaceRoot:{newRoot: {$mergeObjects: [{ $arrayElemAt:["$course_documents",0]},"$$ROOT"] }}
},
{$project:{course_documents:0}},
{$match : {"score":{"$gte":60}}}
]).forEach(function(m) {
db.pass.findAndModify({
query:{_id:m._id},
update:{$set :{"s_id":m.s_id,"name":m.name,"c_name":m.c_name}},
upsert:true
});
});
图8
小结：
使用惯关系型数据库后，对于转用No-SQL数据库的人，许多场景在关系型数据库中实现方式，在No-SQL数据库不一定可用。本文讲述了增量更新场景在MongoDB中的实现，希望对大家有帮助。
