在单个记录中的MongoDB中的一系列对象中查找重复值

Question

我是在 Mongo 中查询的新手。我有这条记录，我需要找到具有相同链接的部分。

我的记录：

{
    "_id" : ObjectId("1234"),
    "name": "singleRecordInMongo",
    "__v" : 0,
    "sections" : [ 
        {
            "name" : "firstElement",
            "link" : "https://www.test.com/",
            "_id" : ObjectId("624dd0aca5fb565661da1161")
        }, 
        {
            "name" : "secondElement",
            "link" : "https://www.test.com/",
            "_id" : ObjectId("624dd0aca5fb565661da1162")
        }, 
        {
            "name" : "thirdElement",
            "link" : "https://www.other.com",
            "_id" : ObjectId("624dd0aca5fb565661da1163")
        }
   ]
}

预期结果：

    "sections" : [ 
        {
            "times" : 2,
            "link" : "https://www.test.com/"
        }
   ]

我尝试了类似的方法，但没有成功

db.getCollection('records').aggregate(
  {$unwind: "$sections"},
  { $project: {_id: '$_id', value: '$sections'} },
  { $group: {
        _id: null, 
        occurances: {$push: {'value': '$link', count: '$count'}}
        }
   }
);

Answer 1

编辑：
您可以使用 $ group ：

db.collection.aggregate([
  {$unwind: "$sections"},
  {
    $group: {
      _id: "$sections.link",
      orig_id: {$first: "$sections._id" },
      count: {$sum: 1 }
    }
  },
  {$match: { "count": {$gt: 1 }}},
  {
    $group: {
      _id: 0,
      sections: {$push: { link: "$_id", count: "$count"}}
    }
  }
])

喜欢 playground> playground 返回：

  {
    "_id": 0,
    "sections": [
      {
        "count": 2,
        "link": "https://www.test.com/"
      }
    ]
  }

Answer 2

用于使用JavaScript函数的综合操作， 操作员，您可以使用哈希地图来跟踪重复项，如下所示：

db.records.aggregate([
   { $addFields: {
      sections: {
         $map: {
            input: "$sections",
            in: { times: 1, link: "$this.link" }
         }
      }
   } },
   { $addFields: {
      sections: {
         $filter: {
            input: {
               $function: {
                  body: function (data) { 
                     const map = {}; 
                     data = data.map((item) => { 
                        if (map[item.link]) {
                           map[item.link].times += item.times
                        } else { 
                           map[item.link] = item; 
                        }
                        return item; 
                     }); 
                     
                     return data.filter((item) => item !== undefined); 
                  },
                  args: [ "$sections" ],
                  lang: "js"
               }
            },
            cond: { $gt: ["$this.times", 1] }
         }
      }
   } }
])

请记住

在聚合表达式内执行JavaScript可能会减少
表现。仅使用 $ function 操作员如果提供了 pipeline
运营商无法满足您的应用程序的需求。




mongo playground