$merge

  • 적용 대상: ✅ Azure DocumentDB

$merge 집계 파이프라인의 단계는 집계 쿼리의 결과를 지정된 컬렉션에 쓰는 데 사용됩니다. 이 단계는 집계 작업의 출력에 따라 문서를 대상 컬렉션에 업데이트하거나 삽입하는 등의 작업에 특히 유용합니다. 단일 작업에서 데이터 변환 및 데이터 지속성을 결합하여 워크플로를 간소화하는 데 도움이 됩니다.

문법

{
  $merge: {
    into: <collection>,
    on: <field or fields>,
    whenMatched: <action>,
    whenNotMatched: <action>
  }
}

매개 변수

매개 변수 Description
into 집계 결과가 기록될 대상 컬렉션을 지정합니다.
on 대상 컬렉션에서 일치하는 문서를 식별할 필드를 지정합니다.
whenMatched 일치하는 문서를 찾을 때 수행할 작업을 지정합니다. 옵션에는 merge, replace, keepExisting, fail 또는 사용자 지정 파이프라인이 포함됩니다.
whenNotMatched 일치하는 문서를 찾을 수 없을 때 수행할 작업을 지정합니다. 옵션은 insert 또는 discard입니다.

예시

스토어 컬렉션에서 이 샘플 문서를 고려합니다.

{
  "_id": "7954bd5c-9ac2-4c10-bb7a-2b79bd0963c5",
   "name": "Lakeshore Retail | DJ Equipment Stop - Port Cecile",
  "location": {
    "lat": 60.1441,
    "lon": -141.5012
  },
  "staff": {
    "totalStaff": {
      "fullTime": 2,
      "partTime": 0
    }
  },
  "sales": {
    "salesByCategory": [
      {
        "categoryName": "DJ Headphones",
        "totalSales": 35921
      }
    ],
    "fullSales": 3700
  },
  "promotionEvents": [
    {
      "eventName": "Bargain Blitz Days",
      "promotionalDates": {
        "startDate": {
          "Year": 2024,
          "Month": 3,
          "Day": 11
        },
        "endDate": {
          "Year": 2024,
          "Month": 2,
          "Day": 18
        }
      },
      "discounts": [
        {
          "categoryName": "DJ Turntables",
          "discountPercentage": 18
        },
        {
          "categoryName": "DJ Mixers",
          "discountPercentage": 15
        }
      ]
    }
  ],
  "tag": [
    "#ShopLocal",
    "#SeasonalSale",
    "#FreeShipping",
    "#MembershipDeals"
  ]
}

예제 1: 컬렉션에 데이터 병합

이 쿼리는 문서를 집계하고, 일치하는 기존 문서를 업데이트하고, 그렇지 않으면 새 문서를 삽입하는 컬렉션 salesSummary에 _id 결과를 씁니다.

db.sales.aggregate([
  {
    $group: {
      _id: "$sales.salesByCategory.categoryName",
      totalSales: { $sum: "$sales.salesByCategory.totalSales" }
    }
  },
  {
    $merge: {
      into: "salesSummary",
      on: "_id",
      whenMatched: "merge",
      whenNotMatched: "insert"
    }
  }
])

예제 2: 대상 컬렉션의 문서 바꾸기

promotionEventsSummary 필드를 기준으로 _id 컬렉션의 문서를 바꾸는 예제입니다.

db.promotionEvents.aggregate([
  {
    $project: {
      _id: "$eventName",
      startDate: "$promotionalDates.startDate",
      endDate: "$promotionalDates.endDate",
      totalDiscounts: { $size: "$discounts" }
    }
  },
  {
    $merge: {
      into: "promotionEventsSummary",
      on: "_id",
      whenMatched: "replace",
      whenNotMatched: "insert"
    }
  }
])
  • Last updated on