Computer >> 컴퓨터 >  >> 프로그램 작성 >> MongoDB

MongoDB Aggregate 구현 - 긴장을 풀고, 그룹화하고, 프로젝트를 진행하시겠습니까?

<시간/>

MongoDB의 $unwind는 입력 문서에서 배열 필드를 분해하여 각 요소에 대한 문서를 출력합니다.

$group은 지정된 _id 표현식으로 입력 문서를 그룹화하는 데 사용되며 각 개별 그룹화에 대해 문서를 출력합니다.

$project는 요청된 필드가 있는 문서를 파이프라인의 다음 단계로 전달하는 데 사용됩니다.

문서로 컬렉션을 만들자 −

> db.demo238.insertOne(
...   {
...
...      "EmailId" : "John@gmail.com",
...      "details" : [
...         {
...            "Name" : "Bob",
...            "isActive" : true
...         }
...      ]
...   }
...);
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e4418e3f4cebbeaebec5152")
}
>
> db.demo238.insertOne(
...   {
...
...      "EmailId" : "Chris@gmail.com",
...      "details" : [
...         {
...            "Name" : "David"
...         }
...      ]
...   }
...);
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e4418e3f4cebbeaebec5153")
}
>
>
> db.demo238.insertOne(
...   {
...
...      "EmailId" : "Mike@gmail.com",
...      "details" : [
...         {
...            "Name" : "Carol",
...            "isActive" : true
...         }
...      ]
...   }
...);
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e4418e4f4cebbeaebec5154")
}

find() 메서드를 사용하여 컬렉션의 모든 문서 표시:

> db.demo238.find().pretty();

이것은 다음과 같은 출력을 생성합니다 -

{
   "_id" : ObjectId("5e4418e3f4cebbeaebec5152"),
   "EmailId" : "John@gmail.com",
   "details" : [
      {
         "Name" : "Bob",
         "isActive" : true
      }
   ]
}
{
   "_id" : ObjectId("5e4418e3f4cebbeaebec5153"),
   "EmailId" : "Chris@gmail.com",
   "details" : [
      {
         "Name" : "David"
      }
   ]
}
{
   "_id" : ObjectId("5e4418e4f4cebbeaebec5154"),
   "EmailId" : "Mike@gmail.com",
   "details" : [
      {
         "Name" : "Carol",
         "isActive" : true
      }
   ]
}

다음은 MongoDB Aggregate를 구현하는 쿼리입니다 - 해제, 그룹 및 프로젝트 −

> db.demo238.aggregate(
...   [
...      { "$match": { "details.isActive": true } },
...      { "$unwind": "$details" },
...      { "$match": { "details.isActive": true } },
...      { "$group": {
...         "_id": "$details.Name",
...         "active": { "$first": "$_id" }
...      }}
...   ],
...   function(err,result) {
...
...   }
...);

이것은 다음과 같은 출력을 생성합니다 -

{ "_id" : "Carol", "active" : ObjectId("5e4418e4f4cebbeaebec5154") }
{ "_id" : "Bob", "active" : ObjectId("5e4418e3f4cebbeaebec5152") }