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

$addFields 파이프라인 사용 및 MongoDB $filter 연산자로 실행

<시간/>

먼저 문서로 컬렉션을 만들어 보겠습니다. −

> db.demo118.insertOne(
...    {
...       "Id" : "101",
...       "Name" : "Chris",
...       "Subjects" : [
...          "MySQL",
...          "MongoDB",
...          "Java"
...       ],
...       "Details" : [
...          {
...             "Name" : "David",
...             S:"MongoDB"
...          },
...          {
...             "Name" : "Bob",
...             S:"Python"
...          }
...       ]
...    }
... );
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e2f0c0cd8f64a552dae6364")
}

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

> db.demo118.find();

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

{ "_id" : ObjectId("5e2f0c0cd8f64a552dae6364"), "Id" : "101", "Name" : "Chris", "Subjects" : [ "MySQL", "MongoDB", "Java" ], "Details" : [ { "Name" : "David", "S" : "MongoDB" }, { "Name" : "Bob", "S" : "Python" } ] }

다음은 $addFields 파이프라인을 사용하는 쿼리입니다 -

> db.demo118.aggregate([
...    {
...       "$addFields": {
...          "Details": {
...             "$filter": {
...                "input": "$Details",
...                "as": "out",
...                "cond": { "$in": ["$$out.S", "$Subjects"] }
...             }
...          }
...       }
...    }
... ]).pretty();

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

{
   "_id" : ObjectId("5e2f0c0cd8f64a552dae6364"),
   "Id" : "101",
   "Name" : "Chris",
   "Subjects" : [
      "MySQL",
      "MongoDB",
      "Java"
   ],
   "Details" : [
      {
         "Name" : "David",
         "S" : "MongoDB"
      }
   ]
}