use('local')//切换到数据库
db.getCollection('jobs').aggregate([
{
/* 把目标collection与当前collection连接起来 */
$lookup: {
from: "classifiedJob",
localField: "标题",
foreignField: "标题",
/* 外来的fields打包全部保存在当前collection中的指定field中 */
as: "joined"
}
},
{
/* 把数组展开 */
$unwind: "$joined"
},
{
/* 给查询结果添加若干个fields */
$addFields: {
"职业类别A": "$joined.职业类别A",
"职业类别B": "$joined.职业类别B",
"职业类别C": "$joined.职业类别C"
}
},
{
/* 修改查询结果 */
$project: {
"joined": 0,/* 将joined这个field去掉 */
}
},
{
/* 将查询结果写入到指定collection中 */
$merge: {
into: { db: 'test', coll: "joinedJobs" }
}
}
])