上一篇我们介绍了MongoDB 聚合管道的文档筛选及分组统计：
$match：文档过滤
$group：文档分组，并介绍了分组中的常用操作：$addToSet，$avg，$sum，$min，$max等。
如果需要进一步了解可以参考：
MongoDB 聚合管道的文档筛选及分组统计
https://blog.csdn.net/m1729339749/article/details/130034658这篇我们主要介绍使用聚合管道实现字段映射：
一、准备工作
初始化零食数据
db.goods.insertMany([
{ "_id": 1, name: "薯片", size: "S", quantity: 10, price: 8, expirationTime: ISODate( "2023-08-08T00:00:00Z" ) },
{ "_id": 2, name: "薯片", size: "L", quantity: 8, price: 12, expirationTime: ISODate( "2023-08-08T00:00:00Z" ) },
{ "_id": 3, name: "牛肉干", size: "L", quantity: 5, price: 30, expirationTime: ISODate( "2023-10-10T00:00:00Z" ) },
{ "_id": 4, name: "可口可乐", size: "S", quantity: 10, price: 3, expirationTime: ISODate( "2025-01-06T00:00:00Z" ) },
{ "_id": 5, name: "可口可乐", size: "L", quantity: 6, price: 10, expirationTime: ISODate( "2025-01-06T00:00:00Z" ) },
{ "_id": 6, name: "旺仔牛奶", size: "L", quantity: 10, price: 5, expirationTime: ISODate( "2023-08-10T00:00:00Z" )}
])二、新增字段（$addFields）
语法：{ $addFields: { <newField>: <expression>, ... } }
添加字段，从4.2开始后也可以使用$set增加字段
例子：在聚合数据中增加 comment 字段
db.goods.aggregate([
{
$addFields: { "comment": "我是新增加的" }
}
])此操作等效于：
db.goods.aggregate([
{
$set: { "comment": "我是新增加的" }
}
])聚合查询的结果如下：
{ "_id" : 1, "name" : "薯片", "size" : "S", "quantity" : 10, "price" : 8, "expirationTime" : ISODate("2023-08-08T00:00:00Z"), "comment" : "我是新增加的" }
{ "_id" : 2, "name" : "薯片", "size" : "L", "quantity" : 8, "price" : 12, "expirationTime" : ISODate("2023-08-08T00:00:00Z"), "comment" : "我是新增加的" }
{ "_id" : 3, "name" : "牛肉干", "size" : "L", "quantity" : 5, "price" : 30, "expirationTime" : ISODate("2023-10-10T00:00:00Z"), "comment" : "我是新增加的" }
{ "_id" : 4, "name" : "可口可乐", "size" : "S", "quantity" : 10, "price" : 3, "expirationTime" : ISODate("2025-01-06T00:00:00Z"), "comment" : "我是新增加的" }
{ "_id" : 5, "name" : "可口可乐", "size" : "L", "quantity" : 6, "price" : 10, "expirationTime" : ISODate("2025-01-06T00:00:00Z"), "comment" : "我是新增加的" }
{ "_id" : 6, "name" : "旺仔牛奶", "size" : "L", "quantity" : 10, "price" : 5, "expirationTime" : ISODate("2023-08-10T00:00:00Z"), "comment" : "我是新增加的" }三、移除字段（$unset）
语法：{ $unset: "<field>" }
或 { $unset: [ "<field1>", "<field2>", ... ] }
移除字段，移除一个字段或者移除多个字段
例子：在聚合数据中移除 expirationTime字段
db.goods.aggregate([
{
"$unset": "expirationTime"
}
])聚合查询的结果如下：
{ "_id" : 1, "name" : "薯片", "size" : "S", "quantity" : 10, "price" : 8 }
{ "_id" : 2, "name" : "薯片", "size" : "L", "quantity" : 8, "price" : 12 }
{ "_id" : 3, "name" : "牛肉干", "size" : "L", "quantity" : 5, "price" : 30 }
{ "_id" : 4, "name" : "可口可乐", "size" : "S", "quantity" : 10, "price" : 3 }
{ "_id" : 5, "name" : "可口可乐", "size" : "L", "quantity" : 6, "price" : 10 }
{ "_id" : 6, "name" : "旺仔牛奶", "size" : "L", "quantity" : 10, "price" : 5 }四、字段投影（$project）
语法：{ $project: { <specification(s)> } }
对文档中的字段进行投影操作，例如：保留哪些字段、移除哪些字段、添加新的字段、重置字段的值等。
specifications的定义如下：
<field>: 1 or true：代表的是保留某个字段
<field>: 0 or false：代表的是移除某个字段
<field>: <expression>：代表的是添加新的字段或者重置字段的值
例子：移除商品的生产日期、编号，添加商品的总价值，并把size的值替换成小包装、大包装
db.goods.aggregate([
{
$project: {
"name": 1,
"price": 1,
"quantity": 1,
"size": {
$cond: {
if: { $eq: [ "S", "$size"] },
then: "小包装",
else: "大包装"
}
},
"totalWorth": { $multiply: [ "$quantity", "$price" ] }
}
}
])解释一下给出的聚合查询语句：
(1) 保留name、price、quantity三个字段；
(2) 重置size的值，如果字段size的值与"S"相等，返回“小包装”作为值，否则返回“大包装”作为值；里面的表达式运算符我们先做简单的介绍，后面会出一篇文章单独介绍；
(3) 新增总价值字段totalWorth，将数量与价格相乘的结果作为新增字段的值；里面的表达式运算符我们先做简单的介绍，后面会出一篇文章单独介绍
下面我们看一下聚合查询的结果：
{ "_id" : 1, "name" : "薯片", "quantity" : 10, "price" : 8, "size" : "小包装", "totalWorth" : 80 }
{ "_id" : 2, "name" : "薯片", "quantity" : 8, "price" : 12, "size" : "大包装", "totalWorth" : 96 }
{ "_id" : 3, "name" : "牛肉干", "quantity" : 5, "price" : 30, "size" : "大包装", "totalWorth" : 150 }
{ "_id" : 4, "name" : "可口可乐", "quantity" : 10, "price" : 3, "size" : "小包装", "totalWorth" : 30 }
{ "_id" : 5, "name" : "可口可乐", "quantity" : 6, "price" : 10, "size" : "大包装", "totalWorth" : 60 }
{ "_id" : 6, "name" : "旺仔牛奶", "quantity" : 10, "price" : 5, "size" : "大包装", "totalWorth" : 50 }可以看到里面的编号没有去除掉，原因是_id作为主键会自动保留，需要我们使用_id: 0 给强制去除掉：
db.goods.aggregate([
{
$project: {
"_id": 0,
"name": 1,
"price": 1,
"quantity": 1,
"size": {
$cond: {
if: { $eq: [ "S", "$size"] },
then: "小包装",
else: "大包装"
}
},
"totalWorth": { $multiply: [ "$quantity", "$price" ] }
}
}
])再次执行聚合查询的结果如下：
{ "name" : "薯片", "quantity" : 10, "price" : 8, "size" : "小包装", "totalWorth" : 80 }
{ "name" : "薯片", "quantity" : 8, "price" : 12, "size" : "大包装", "totalWorth" : 96 }
{ "name" : "牛肉干", "quantity" : 5, "price" : 30, "size" : "大包装", "totalWorth" : 150 }
{ "name" : "可口可乐", "quantity" : 10, "price" : 3, "size" : "小包装", "totalWorth" : 30 }
{ "name" : "可口可乐", "quantity" : 6, "price" : 10, "size" : "大包装", "totalWorth" : 60 }
{ "name" : "旺仔牛奶", "quantity" : 10, "price" : 5, "size" : "大包装", "totalWorth" : 50 }扩展：如何区分inclusion projection、exclusion projection
默认情况下是inclusion projection映射；
如果定义中出现的第一个非_id字段定义的映射为<field>: 0，则是exclusion projection映射；
如果定义中出现的第一个非_id字段定义的映射为<field>: 1，则是inclusion projection映射；
例子1：
db.goods.aggregate([
{
$project: {
"_id": 0,
"name": 1
}
}
])如上面的例子，第一个非_id的字段定义的映射是"name": 1，则判断其是inclusion projection映射
例子2：
db.goods.aggregate([
{
$project: {
"name": 0
}
}
])如上面的例子，第一个非_id的字段定义的映射是"name": 0，则判断其是exclusion projection映射
扩展：inclusion projection中除_id:0外只能包含<field>: 1
exclusion projection中除_id:1外只能包含<field>:0
例子1：
db.goods.aggregate([
{
$project: {
"name": 1,
"size": 0
}
}
])执行上面的聚合查询会报错：
{
"ok" : 0,
"errmsg" : "Invalid $project :: caused by :: Cannot do exclusion on field size in inclusion projection",
"code" : 31254,
"codeName" : "Location31254"
}分析原因：
第一个非_id的字段定义的映射是"name": 1，则判断其是inclusion projection映射，inclusion projection映射中除_id:0外只能包含<field>: 1，现在包含了"size": 0，则报了异常。
例子2：
db.goods.aggregate([
{
$project: {
"size": 0,
"name": 1
}
}
])执行上面的聚合查询会报错：
{
"ok" : 0,
"errmsg" : "Invalid $project :: caused by :: Cannot do inclusion on field name in exclusion projection",
"code" : 31253,
"codeName" : "Location31253"
}分析原因：
第一个非_id的字段定义的映射是"size": 0，则判断其是exclusion projection映射，exclusion projection映射中除_id:1外只能包含<field>: 0，现在包含了"name": 1，则报了异常。
