Mongo根据字段删除对象数组中的重复项

Question

Mongo 的新手，发现了很多使用聚合框架从字符串数组中删除欺骗的示例，但我想知道是否可以根据对象中的字段从对象数组中删除欺骗。例如

{
"_id" : ObjectId("5e82661d164941779c2380ca"),
"name" : "something",
"values" : [
    {
        "id" : 1,
        "val" : "x"
    },
    {
        "id" : 1,
        "val" : "x"
    },
    {
        "id" : 2,
        "val" : "y"
    },
    {
        "id" : 1,
        "val" : "xxxxxx"
    }
]
}

在这里，我想根据id 字段删除欺骗。所以最终会得到 ​​p>

{
"_id" : ObjectId("5e82661d164941779c2380ca"),
"name" : "something",
"values" : [
    {
        "id" : 1,
        "val" : "x"
    },
    {
        "id" : 2,
        "val" : "y"
    }
]
}

选择具有给定 id 的第一个/任何对象都有效。只想以每个 id 结束。这在聚合框架中可行吗？甚至在聚合框架之外，只是寻找一种干净的方法来做到这一点。需要在集合中的许多文档中执行此类操作，这似乎是聚合框架的一个很好的用例，但正如我所提到的，这里的新手......谢谢。

Answer 1

嗯，你可以通过两种方式得到想要的结果。

经典

展平 - 删除重复项（选择第一次出现） - 分组方式

db.collection.aggregate([
  {
    $unwind: "$values"
  },
  {
    $group: {
      _id: "$values.id",
      values: {
        $first: "$values"
      },
      id: {
        $first: "$_id"
      },
      name: {
        $first: "$name"
      }
    }
  },
  {
    $group: {
      _id: "$id",
      name: {
        $first: "$name"
      },
      values: {
        $push: "$values"
      }
    }
  }
])

MongoPlayground

现代

我们需要使用$reduce 运算符。

伪代码：

values : {
  var tmp = [];
  for (var value in values) {
      if !(value.id in tmp)
        tmp.push(value);
  }
  return tmp;
}

---

db.collection.aggregate([
  {
    $addFields: {
      values: {
        $reduce: {
          input: "$values",
          initialValue: [],
          in: {
            $concatArrays: [
              "$$value",
              {
                $cond: [
                  {
                    $in: [
                      "$$this.id",
                      "$$value.id"
                    ]
                  },
                  [],
                  [
                    "$$this"
                  ]
                ]
              }
            ]
          }
        }
      }
    }
  }
])

MongoPlayground

Answer 2

你可以使用$reduce，试试下面的查询：

db.collection.aggregate([
  {
    $addFields: {
      values: {
        $reduce: {
          input: "$values",
          initialValue: [],
          in: {
            $cond: [
              { $in: ["$$this.id", "$$value.id"] }, /** Check if 'id' exists in holding array if yes push same array or concat holding array with & array of new object */
              "$$value",
              { $concatArrays: ["$$value", ["$$this"]] }
            ]
          }
        }
      }
    }
  }
]);

测试： MongoDB-Playground