db.collection.findAndModify()

성능

재시도 가능한 쓰기는 findAndModify() 메서드를 필요로 하며 업데이트를 수행하기 전에 복제본 세트의 각 노드에 대해 전체 문서를 특수 사이드 컬렉션으로 복사합니다. 이로 인해 대용량 문서나 대규모 복제 세트를 처리할 때 findAndModify() 작업에 많은 비용이 들 수 있습니다.

fields 프로젝션

fields 옵션에서는 다음 형식의 문서를 사용합니다.

{ field1: <value>, field2: <value> ... }

고유 인덱스가 포함된 업서트

중복을 방지하는 고유 인덱스 가 없는 경우 업서트는 중복 문서를 생성할 수 있습니다.

이름이 Andy인 문서가 없고 여러 클라이언트가 대략 동시에 다음 명령을 실행하는 예시를 가정해 보겠습니다.

db.people.findAndModify(
   {
     query: { name: "Andy" },
     update: { $inc: { score: 1 } },
     upsert: true
   }
)

클라이언트가 데이터를 성공적으로 삽입하기 전에 모든 findOneAndUpdate() 작업이 쿼리 단계를 완료 하고 name 필드에 고유 인덱스가 없는 경우, findOneAndUpdate() 작업마다 삽입이 발생하여 name: Andy 이 포함된 여러 문서가 생성될 수 있습니다.

name 필드에 대한 고유 인덱스는 하나의 문서만 생성되도록 합니다. 고유 인덱스가 적용되면 이제 여러 findOneAndUpdate() 작업에서 다음과 같은 동작이 발생합니다.

• findOneAndUpdate()번의 연산을 정확히 한 번 실행하면 새 문서를 삽입할 수 있습니다.

• 다른 findOneAndUpdate() 작업은 새로 삽입된 문서를 업데이트하거나 고유 키 충돌로 인해 실패합니다.

  다른 findOneAndUpdate() 작업에서 새로 삽입된 문서를 업데이트하려면 다음 조건이 모두 충족되어야 합니다.

  • target collection에 중복 키 오류를 일으킬 수 있는 고유 인덱스가 있습니다.

  • 업데이트 작업이 updateMany 이 아니거나 multi 이 false 입니다.

  • 업데이트 일치 조건은 둘 중 하나입니다:

    • 단일 동등성 조건자. 예를 들면 다음과 같습니다. { "fieldA" : "valueA" }

    • 동등성 조건자의 논리적 AND. 예를 들면 다음과 같습니다. { "fieldA" : "valueA", "fieldB" : "valueB" }

  • 동등성 조건자의 필드는 고유 인덱스 키 패턴의 필드와 일치합니다.

  • 업데이트 작업은 고유 인덱스 키 패턴의 필드를 수정하지 않습니다.

다음 표는 키 충돌이 발생하면 업데이트를 초래하거나 실패하는 upsert 작업의 예를 보여줍니다.

{ name : 1 }

db.people.updateOne(
   { name: "Andy" },
   { $inc: { score: 1 } },
   { upsert: true }
)

{ name : 1 }

db.people.updateOne(
   { name: { $ne: "Joe" } },
   { $set: { name: "Andy" } },
   { upsert: true }
 )

{ name : 1 }

db.people.updateOne(
  { name: "Andy", email: "andy@xyz.com" },
  { $set: { active: false } },
  { upsert: true }
)

샤드 컬렉션

샤드 컬렉션에서 findAndModify을(를) 사용하려면 다음 방법대로 하세요.

• 샤드 1개만을 대상으로 하는 경우 query 필드에 부분 샤드 키를 사용하거나,

• query 필드의 전체 샤드 키에 대한 동등성 조건을 제공할 수 있습니다.

• 버전 7.1부터는 쿼리 사양에서 샤드 키나 _id 필드를 제공할 필요가 없습니다.

샤딩된 컬렉션의 문서에는 샤드 키 필드가 누락될 수 있습니다. 샤드 키가 누락된 문서를 대상으로 하려면 null 동등성 매치를 다른 필터 조건(예: _id 필드)과 함께 사용할 수 있습니다. 예를 들면 다음과 같습니다.

{ _id: <value>, <shardkeyfield>: null } // _id of the document missing shard key

문서 유효성 검사

db.collection.findAndModify() 메서드는 유효성 검사 규칙이 있는 컬렉션에 문서를 삽입하거나 업데이트할 때 문서 유효성 검사를 건너뛸 수 있는 bypassDocumentValidation 옵션에 대한 지원을 추가합니다.

update 메서드와의 비교

문서를 업데이트할 때 db.collection.findAndModify() 메서드와 updateOne() 메서드는 다음과 같이 서로 다르게 작동합니다.

• 여러 문서가 업데이트 기준과 일치하는 경우 db.collection.findAndModify()에 sort를 지정하여 업데이트할 문서에 제어 수단을 제공할 수 있습니다.

  updateOne() 일치하는 첫 번째 문서를 업데이트합니다.

• db.collection.findAndModify()는 기본적으로 이 문서의 수정 전 버전을 반환합니다. 업데이트된 문서를 받으려면 new 옵션을 사용하세요.

  updateOne() 메서드는 연산의 상태가 포함된 WriteResult() 객체를 반환합니다.

  업데이트된 문서를 반환하려면 find() 메서드를 사용하세요. 그러나 업데이트와 문서 검색 사이에 다른 업데이트로 인해 문서가 수정되었을 수 있습니다. 게다가 해당 업데이트로 인해 문서가 1개만 수정되었으나 여러 문서가 일치한 경우, 업데이트된 문서를 식별하기 위해서는 추가 로직을 사용해야 합니다.

단일 문서를 수정할 때는 db.collection.findAndModify() 메서드 및 updateOne() 메서드 둘 다 문서를 원자 단위로 업데이트합니다. 이 메서드들의 상호작용과 연산 순서에 대한 자세한 내용은 원자성 및 트랜잭션을 참조하세요.

트랜잭션

db.collection.findAndModify()는 분산 트랜잭션 내에서 사용할 수 있습니다.

oplog 항목

db.collection.findAndModify() 작업이 문서를 성공적으로 찾아서 수정하면 작업은 oplog(작업 로그)에 항목을 추가합니다. 작업이 실패하거나 수정할 문서를 찾지 못하면 작업은 oplog에 항목을 추가하지 않습니다.

업데이트 및 반환

다음 메서드는 문서가 쿼리 기준과 일치하는 사람 컬렉션의 기존 문서를 업데이트하고 반환합니다.

db.people.findAndModify({
    query: { name: "Tom", state: "active", rating: { $gt: 10 } },
    sort: { rating: 1 },
    update: { $inc: { score: 1 } }
})

이 메서드는 다음 작업을 실행합니다.

1. query은(는) name 필드의 값이 Tom(이)고, state 필드의 값이 active(이)고, rating 필드의 값이 10 greater than인 people 컬렉션에서 문서를 찾습니다.

2. sort은(는) 쿼리 결과를 오름차순으로 정렬합니다. 여러 문서가 query 조건을 충족할 경우, 이 메서드는 이 sort(으)로 정렬된 첫 번째 문서를 수정하기로 선택합니다.

3. increments은(는) score 필드의 값을 1씩 업데이트합니다.

4. 이 메서드는 이 업데이트를 위해 선택된 원본(즉 수정 전) 문서를 반환합니다.

   {
     "_id" : ObjectId("50f1e2c99beb36a0f45c6453"),
     "name" : "Tom",
     "state" : "active",
     "rating" : 100,
     "score" : 5
   }

   업데이트된 문서를 반환하려면 메서드에 new:true 옵션을 추가합니다.

   query 조건과 일치하는 문서가 없을 경우 이 메서드는 null을(를) 반환합니다.

업서트

다음 메서드에는 일치하는 문서를 업데이트하거나, 일치하는 문서가 없는 경우 새 문서를 생성하는 update 연산의 upsert: true 옵션이 포함되어 있습니다.

db.people.findAndModify({
    query: { name: "Gus", state: "active", rating: 100 },
    sort: { rating: 1 },
    update: { $inc: { score: 1 } },
    upsert: true
})

이 메서드가 일치하는 문서를 찾으면 업데이트가 실행됩니다.

이 메서드가 일치하는 문서를 찾지 못하면 새 문서가 생성됩니다. 이 메서드에 sort 옵션이 포함되어 있으므로 빈 문서 { }이(가) 원본(수정 전) 문서로 반환됩니다.

{ }

이 메서드에 sort 옵션이 포함되지 않은 경우에는 null이(가) 반환됩니다.

null

새 문서 반환하기

다음 메서드에는 upsert: true 옵션과 new:true 옵션이 모두 포함되어 있습니다. 이 메서드는 일치하는 문서를 업데이트하고 업데이트된 문서를 반환하거나, 일치하는 문서가 없는 경우 문서를 삽입하고 새로 삽입된 문서를 value 필드에 반환합니다.

다음 예시에서는 people 컬렉션의 어떤 문서도 query 조건과 일치하지 않습니다.

db.people.findAndModify({
    query: { name: "Pascal", state: "active", rating: 25 },
    sort: { rating: 1 },
    update: { $inc: { score: 1 } },
    upsert: true,
    new: true
})

이 메서드는 새로 삽입된 문서를 다음과 같이 반환합니다.

{
   "_id" : ObjectId("50f49ad6444c11ac2448a5d6"),
   "name" : "Pascal",
   "rating" : 25,
   "score" : 1,
   "state" : "active"
}

정렬 및 제거

다음 예시에서는 rating 필드에 sort 사양을 포함시킴으로써, state 값이 active(이)면서 일치하는 문서 중 rating 값이 가장 낮은 단일 문서를 people 컬렉션에서 제거합니다.

db.people.findAndModify(
   {
     query: { state: "active" },
     sort: { rating: 1 },
     remove: true
   }
)

이 메서드는 삭제된 문서를 다음과 같이 반환합니다.

{
   "_id" : ObjectId("52fba867ab5fdca1299674ad"),
   "name" : "XYZ123",
   "score" : 1,
   "state" : "active",
   "rating" : 3
}

데이터 정렬 지정

데이터 정렬을 사용하면 대소문자 및 악센트 표시 규칙과 같은 문자열 비교에 대한 언어별 규칙을 지정할 수 있습니다.

컬렉션 myColl에는 다음 문서가 있습니다.

{ _id: 1, category: "café", status: "A" }
{ _id: 2, category: "cafe", status: "a" }
{ _id: 3, category: "cafE", status: "a" }

다음 작업에는 데이터 정렬 옵션이 포함됩니다.

db.myColl.findAndModify({
    query: { category: "cafe", status: "a" },
    sort: { category: 1 },
    update: { $set: { status: "Updated" } },
    collation: { locale: "fr", strength: 1 }
});

연산은 다음 문서를 반환합니다.

{ "_id" : 1, "category" : "café", "status" : "A" }

arrayFilters 배열 업데이트 작업에 지정

배열 필드를 업데이트할 때 업데이트할 배열 요소를 결정하는 arrayFilters를 지정할 수 있습니다.

db.students.insertMany( [
   { "_id" : 1, "grades" : [ 95, 92, 90 ] },
   { "_id" : 2, "grades" : [ 98, 100, 102 ] },
   { "_id" : 3, "grades" : [ 95, 110, 100 ] }
] )

db.students.findAndModify({
   query: { grades: { $gte: 100 } },
   update: { $set: { "grades.$[element]" : 100 } },
   arrayFilters: [ { "element": { $gte: 100 } } ]
})

{ "_id" : 1, "grades" : [ 95, 92, 90 ] }
{ "_id" : 2, "grades" : [ 98, 100, 100 ] }
{ "_id" : 3, "grades" : [ 95, 110, 100 ] }

db.students2.insertMany( [
   {
      "_id" : 1,
      "grades" : [
         { "grade" : 80, "mean" : 75, "std" : 6 },
         { "grade" : 85, "mean" : 90, "std" : 4 },
         { "grade" : 85, "mean" : 85, "std" : 6 }
      ]
   },
   {
      "_id" : 2,
      "grades" : [
         { "grade" : 90, "mean" : 75, "std" : 6 },
         { "grade" : 87, "mean" : 90, "std" : 3 },
         { "grade" : 85, "mean" : 85, "std" : 4 }
      ]
   }
] )

db.students2.findAndModify({
   query: { _id : 1 },
   update: { $set: { "grades.$[elem].mean" : 100 } },
   arrayFilters: [ { "elem.grade": { $gte: 85 } } ]
})

{
   "_id" : 1,
   "grades" : [
      { "grade" : 80, "mean" : 75, "std" : 6 },
      { "grade" : 85, "mean" : 100, "std" : 4 },
      { "grade" : 85, "mean" : 100, "std" : 6 }
   ]
}
{
   "_id" : 2,
   "grades" : [
      { "grade" : 90, "mean" : 75, "std" : 6 },
      { "grade" : 87, "mean" : 90, "std" : 3 },
      { "grade" : 85, "mean" : 85, "std" : 4 }
   ]
}

업데이트에 집계 파이프라인 사용하기

db.collection.findAndModify() 업데이트를 위한 집계 파이프라인을 수락할 수 있습니다. 파이프라인은 다음 단계로 구성될 수 있습니다.

• $addFields 및 그 별칭 $set

• $project 및 그 별칭 $unset

• $replaceRoot 및 별칭 $replaceWith입니다.

집계 파이프라인e을 사용하면 현재 필드 값을 기반으로 조건부 업데이트를 표현하거나 다른 필드의 값을 사용하여 한 필드를 업데이트하는 등 보다 표현력이 풍부한 업데이트 구문을 작성할 수 있습니다.

그 예로 다음 문서를 사용해 students2 컬렉션을 생성하세요.

db.students2.insertMany( [
   {
      "_id" : 1,
      "grades" : [
         { "grade" : 80, "mean" : 75, "std" : 6 },
         { "grade" : 85, "mean" : 90, "std" : 4 },
         { "grade" : 85, "mean" : 85, "std" : 6 }
      ]
   },
   {
      "_id" : 2,
      "grades" : [
         { "grade" : 90, "mean" : 75, "std" : 6 },
         { "grade" : 87, "mean" : 90, "std" : 3 },
         { "grade" : 85, "mean" : 85, "std" : 4 }
      ]
   }
] )

다음 연산은 _id 필드가 1인 문서를 찾고, 집계 파이프라인을 사용하여 grades 필드에서 새 필드 total을(를) 계산합니다.

db.students2.findAndModify( {
   query: {  "_id" : 1 },
   update: [ { $set: { "total" : { $sum: "$grades.grade" } } } ],  // The $set stage is an alias for ``$addFields`` stage
   new: true
} )

이 연산은 업데이트된 문서를 다음과 같이 반환합니다.

{
   "_id" : 1,
   "grades" : [ { "grade" : 80, "mean" : 75, "std" : 6 }, { "grade" : 85, "mean" : 90, "std" : 4 }, { "grade" : 85, "mean" : 85, "std" : 6 } ],
   "total" : 250
}

에서 변수 사용 let

명령의 다른 곳에서 액세스할 수 있는 변수를 정의하려면 let 옵션을 사용합니다.

컬렉션 cakeFlavors을 만듭니다:

db.cakeFlavors.insertMany( [
   { _id: 1, flavor: "chocolate" },
   { _id: 2, flavor: "strawberry" },
   { _id: 3, flavor: "cherry" }
] )

다음 예시에서는 let의 targetFlavor 변수를 정의하고, 이 변수를 사용하여 케이크 맛을 체리에서 오렌지로 변경합니다.

db.cakeFlavors.findAndModify( {
   query: {
      $expr: { $eq: [ "$flavor", "$$targetFlavor" ] }
   },
   update: { flavor: "orange" },
   let: { targetFlavor: "cherry" }
} )

사용자 역할 및 문서 업데이트

MongoDB 7.0부터는 새로운 USER_ROLES 시스템 변수를 사용하여 사용자 역할을 반환할 수 있습니다.

이 섹션의 예시에서는 의료 정보가 포함된 컬렉션의 필드에 대한 업데이트를 보여줍니다. 이 예시에서는 USER_ROLES 시스템 변수로부터 현재 사용자 역할을 읽고, 사용자에게 특정 역할이 있는 경우에만 업데이트를 실행합니다.

시스템 변수를 사용하려면 변수 이름 시작 부분에 $$를 추가합니다. USER_ROLES 시스템 변수를 $$USER_ROLES로 지정합니다.

이 예시에서는 다음과 같은 사용자를 생성합니다.

• James Billing 역할이 있습니다.

• Michelle Provider 역할이 있습니다.

역할, 사용자 및 컬렉션을 생성하려면 다음 단계를 수행하세요.

db.createRole( { role: "Billing", privileges: [ { resource: { db: "test",
   collection: "medicalView" }, actions: [ "find" ] } ], roles: [ ] } )
db.createRole( { role: "Provider", privileges: [ { resource: { db: "test",
   collection: "medicalView" }, actions: [ "find" ] } ], roles: [ ] } )

db.createUser( {
   user: "James",
   pwd: "js008",
   roles: [
      { role: "Billing", db: "test" }
   ]
} )
db.createUser( {
   user: "Michelle",
   pwd: "me009",
   roles: [
      { role: "Provider", db: "test" }
   ]
} )

db.medical.insertMany( [
   {
      _id: 0,
      patientName: "Jack Jones",
      diagnosisCode: "CAS 17",
      creditCard: "1234-5678-9012-3456"
   },
   {
      _id: 1,
      patientName: "Mary Smith",
      diagnosisCode: "ACH 01",
      creditCard: "6541-7534-9637-3456"
   }
] )

Provider 역할이 있는 Michelle(으)로 로그인하여 다음과 같이 업데이트를 실행하세요.

db.auth( "Michelle", "me009" )

// Attempt to find and modify document
db.medical.findAndModify( {
   query:
      { $and: [
         {
            // Only update the document for Mary Smith
            patientName: { $eq: "Mary Smith" }
         },
         {
            // User must have the Provider role to perform the update
            $expr: { $ne: [ {
               $setIntersection: [ [ "Provider" ], "$$USER_ROLES.role" ]
            }, [] ] }
         }
      ]
   },
   // Update document
   update: {
      patientName: "Mary Smith",
      diagnosisCode: "ACH 03",
      creditCard: "6541-7534-9637-3456"
   }
} )

이전 예시에서는 $setIntersection을(를) 사용하여 "Provider" 문자열과 $$USER_ROLES.role 소속 사용자 역할 사이의 교차점이 비어 있지 않은 문서를 반환합니다. Michelle에게 Provider 역할이 있으므로 업데이트가 실행되었습니다.

이어서 Provider 역할이 없는 James(으)로 로그인하고 동일한 업데이트를 실행해 보세요.

db.auth( "James", "js008" )

// Attempt to find and modify document
db.medical.findAndModify( {
   query:
      { $and: [
         {
            // Only update the document for Mary Smith
            patientName: { $eq: "Mary Smith" }
         },
         {
            // User must have the Provider role to perform the update
            $expr: { $ne: [ {
               $setIntersection: [ [ "Provider" ], "$$USER_ROLES.role" ]
            }, [] ] }
         }
      ]
   },
   // Update document
   update: {
      patientName: "Mary Smith",
      diagnosisCode: "ACH 03",
      creditCard: "6541-7534-9637-3456"
   }
} )

이전 예시에서는 어떤 문서도 업데이트하지 않습니다.