mongoDB聚合查询

管道

管道在Unix和Linux中一般用于将当前命令的输出结果作为下一个命令的参数。
MongoDB的聚合管道将MongoDB文档在一个管道处理完毕后将结果传递给下一个管道处理。
管道操作是可以重复的。

聚合管道操作

可参考菜鸟文档：菜鸟文档

命令	功能描述
$project	指定输出文档里的字段.
$match	选择要处理的文档，与fine()类似。
$limit	限制传递给下一步的文档数量。
$skip	跳过一定数量的文档。
$unwind	扩展数组，为每个数组入口生成一个输出文档。（把列表拆开）
$group	根据key来分组文档。
$sort	排序文档。
$geoNear	选择某个地理位置附近的的文档。
$out	把管道的结果写入某个集合。
$redact	控制特定数据的访问。
$lookup	多表关联（3.2版本新增）

$lookup

相当关系型数据库中多表关联查询

属性	作用
from	同一个数据库下等待被Join的集合。
localField	源集合中的match值，如果输入的集合中，某文档没有 localField这个Key（Field），在处理的过程中，会默认为此文档含有 localField：null的键值对。
foreignField	待Join的集合的match值，如果待Join的集合中，文档没有foreignField值，在处理的过程中，会默认为此文档含有 foreignField：null的键值对。
as	为输出文档的新增值命名。如果输入的集合中已存在该值，则会覆盖掉

// 管道是一个切片,里面可以放很多操作
db.collection.aggregate([{ $lookup: { from: "外键表",localField: "本表外键字段", foreignField: "外键表字段", as: "起别名" } 
})

实操

准备表1：
准备表2：
查询：

unc main() {VulnInfo:=GetCollection("SVD_DATA","VulnInfo")cur,err:=VulnInfo.Aggregate(context.Background(),[]bson.M{// 外键查询{"$lookup":bson.M{"from":"VulnTags","localField":"tags","foreignField":"id","as":"vuln_tags",}},// 限制两个{"$limit":2,},// 不要_id{"$project":bson.M{"_id":false,},},},)if err!=nil{fmt.Println(err)}else{dic:=make(map[string]interface{})for cur.Next(context.TODO()){err:=cur.Decode(dic)if err!=nil{fmt.Println(err)}else{fmt.Println(dic)}}}
}