대량 작업

삽입 작업

삽입 작업을 수행하려면 삽입하려는 문서를 지정하는 InsertOneModel을 만듭니다. 여러 문서를 삽입하려면 삽입하려는 각 문서에 대해 InsertOneModel을 만듭니다.

val juneDoc = InsertOneModel(Person(3, "June Carrie", 17))
val kevinDoc = InsertOneModel(Person(4, "Kevin Moss", 22))

try {
    val bulkOperations = listOf(
        (InsertOneModel(Person(1, "James Smith", 13))),
        (InsertOneModel(Person(3, "Colin Samuels")))
    )
    val bulkWrite = collection.bulkWrite(bulkOperations)
} catch (e: MongoBulkWriteException) {
    println("A MongoBulkWriteException occurred with the following message: " + e.message)
}

A MongoBulkWriteException occurred with the following message:
Bulk write operation error on server sample-shard-00-02.pw0q4.mongodb.net:27017.
Write errors: [BulkWriteError{index=0, code=11000, message='E11000 duplicate key
error collection: crudOps.bulkWrite index: _id_ dup key: { _id: 1 }', details={}}].

대체 작업

대체 작업을 수행하려면 대체하려는 문서와 대체 문서에 대한 쿼리 필터를 지정하는 ReplaceOneModel 을 만듭니다.

val filter = Filters.eq("_id", 1)
val insert = Person(1, "Celine Stork", location = "San Diego, CA")
val doc = ReplaceOneModel(filter, insert)

val opts = ReplaceOptions().sort(Sorts.ascending("_id"))

업데이트 작업

업데이트 작업을 수행하려면 쿼리 필터와 업데이트 문서를 지정하는 UpdateOneModel 또는 UpdateManyModel 를 만듭니다.

UpdateOneModel은 쿼리 필터와 일치하는 첫 번째 문서를 업데이트하고, UpdateManyModel은 쿼리 필터와 일치하는 모든 문서를 업데이트합니다.

val filter = Filters.eq("_id", 2)
val update = Updates.inc(Person::age.name, 1)
val doc = UpdateOneModel<Person>(filter, update)

val opts = UpdateOptions().sort(Sorts.ascending("_id"))

삭제 작업

삭제 작업을 수행하려면 삭제하려는 문서에 대한 쿼리 필터를 지정하는 DeleteOneModel 또는 DeleteManyModel 를 만듭니다.

DeleteOneModel은 쿼리 필터와 일치하는 첫 번째 문서를 삭제하고 DeleteManyModel은 쿼리 필터와 일치하는 모든 문서를 삭제합니다.

val deleteId1 = DeleteOneModel<Person>(Filters.eq("_id", 1))
val deleteAgeLt30 = DeleteManyModel<Person>(Filters.lt(Person::age.name, 30))

실행 순서

bulkWrite() 메서드는 선택적 BulkWriteOptions 을 두 번째 매개 변수로 허용하여 대량 작업을 순서가 지정된 작업으로 실행할지, 순서가 지정되지 않은 상태로 실행할지 여부를 지정합니다.

val insertMdl = InsertOneModel(Person(6, "Zaynab Omar", 37))
val replaceMdl = ReplaceOneModel(
    Filters.eq("_id", 1),
    Person(1, "Sandy Kane", location = "Helena, MT")
)
val updateMdl  = UpdateOneModel<Person>(
        Filters.eq("_id", 6),
        Updates.set(Person::name.name, "Zaynab Hassan")
    )
val deleteMdl = DeleteManyModel<Person>(Filters.gt(Person::age.name, 50))
val bulkOperations = listOf(
    insertMdl,
    replaceMdl,
    updateMdl,
    deleteMdl
)
val result = collection.bulkWrite(bulkOperations)

{ "_id": 1, "name": "Sandy Kane", "location": "Helena, MT" }
{ "_id": 8, "name": "Shayla Ray", "age": 20 }
{ "_id": 6, "name": "Zaynab Hassan", "age": 37 }

val options = BulkWriteOptions().ordered(false)
val unorderedResult = collection.bulkWrite(bulkOperations, options)

{ "_id": 1, "name": "Sandy Kane", "location": "Helena, MT" }
{ "_id": 8, "name": "Shayla Ray", "age": 20 }
{ "_id": 6, "name": "Zaynab Omar", "age": 37 }

삽입 작업

이 예시 bulkWrite() 메서드를 사용하여 두 개의 문서를 삽입하는 방법을 보여 줍니다. 한 문서 sample_db.people 컬렉션 에 삽입되고 다른 문서 sample_db.objects 컬렉션 에 삽입됩니다. MongoNamespace 인스턴스 각 쓰기 (write) 작업이 적용되는 데이터베이스와 컬렉션을 정의합니다.

val docsToInsert = mutableListOf<ClientNamespacedWriteModel>()
docsToInsert.add(ClientNamespacedWriteModel
    .insertOne(
        MongoNamespace("sample_db", "people"),
        Person(2, "Julia Smith")
    )
)
docsToInsert.add(ClientNamespacedWriteModel
    .insertOne(
        MongoNamespace("sample_db", "objects"),
        Object(2, "washing machine")
    )
)
val clientBulkResult = client.bulkWrite(docsToInsert)

대체 작업

다음 예시 bulkWrite() 메서드를 사용하여 sample_db.people 및 sample_db.things 컬렉션의 기존 문서를 바꾸는 방법을 보여 줍니다.

val docsReplacements = mutableListOf<ClientNamespacedWriteModel>()
docsReplacements.add(ClientNamespacedWriteModel
    .replaceOne(
        MongoNamespace("sample_db", "people"),
        Filters.eq(Person::id.name, 1),
        Person(1, "Frederic Hilbert")
    )
)
docsReplacements.add(ClientNamespacedWriteModel
    .replaceOne(
        MongoNamespace("sample_db", "objects"),
        Filters.eq(Object::id.name, 1),
        Object(1, "ironing board")
    )
)
val clientBulkResult = client.bulkWrite(docsReplacements)

이 예시 성공적으로 실행되면 people 컬렉션 에서 _id 값이 1 인 문서 새 문서 로 대체됩니다. things 컬렉션 의 _id 값이 1 인 문서 새 문서 로 대체됩니다.

대량 쓰기 옵션

ClientBulkWriteOptions 의 인스턴스 bulkWrite() 메서드에 전달하여 대량 쓰기 (write) 작업을 실행 때 옵션을 지정할 수 있습니다.

val namespace = MongoNamespace("sample_db", "people")
val options = ClientBulkWriteOptions
    .clientBulkWriteOptions()
    .ordered(false)
val bulkOperations = listOf(
    ClientNamespacedWriteModel.insertOne(
        namespace,
        Person(2, "Rudra Suraj")
    ),
    // Causes duplicate key error
    ClientNamespacedWriteModel.insertOne(
        namespace,
        Person(2, "Wendy Zhang")
    ),
    ClientNamespacedWriteModel.insertOne(
        namespace,
        Person(4, "Mario Bianchi")
    )
)
val result = client.bulkWrite(bulkOperations, options)

MongoCollection.bulkWrite()

대량 작업을 수행하려면 WriteModel 인스턴스 목록을 만들어 bulkWrite() 메서드에 전달합니다.

InsertOneModel, ReplaceOneModel, UpdateOneModel, UpdateManyModel, DeleteOneModel, DeleteManyModel 등 6 개의 다양한 WriteModel 하위 유형이 있습니다.

bulkWrite() 메서드를 실행하는 방법에는 두 가지가 있습니다.

• 순서 지정됨 - 오류가 발생할 때까지 대량 작업을 순서대로 수행

• 순서 지정되지 않음 - 순서에 관계없이 모든 대량 작업을 수행하고 마지막에 오류를 보고

컬렉션 bulkWrite 명령에 대해 자세히 학습 db를 참조하세요. 컬렉션.bulkWrite() 메서드 참조는 MongoDB 서버 매뉴얼에서 확인 가능합니다.

MongoClient.bulkWrite()

MongoDB 서버 버전 8.0 이상을 실행 배포서버 에 연결할 때 MongoClient.bulkWrite() 메서드를 사용하여 여러 데이터베이스 및 컬렉션에서 한 번에 대량 작업을 수행할 수 있습니다.

클라이언트 일괄 작업을 수행하려면 이 메서드에 전달할 ClientNamespacedWriteModel 인스턴스 목록을 만듭니다.

쓰기 (write) 작업을 나타내는 데 사용되는 ClientNamespacedWriteModel 의 6가지 하위 유형이 있습니다. 이러한 쓰기 (write) 모델을 구성하려면 해당 ClientNamespacedWriteModel 메서드 insertOne(), updateOne(), updateMany(), replaceOne(), deleteOne() 및 deleteMany()를 사용할 수 있습니다. 이 메서드는 쓰기 (write) 데이터베이스 와 컬렉션 정의하는 MongoNamespace 객체 사용합니다.

MongoClient.bulkWrite() 메서드는 ClientBulkWriteOptions 객체 사용하여 명령이 실행되는 방식에 대한 다양한 옵션을 지정할 수도 있습니다.

클라이언트 bulkWrite 명령에 대해 자세히 학습 MongoDB 서버 매뉴얼에서 bulkWrite() 메서드 참조를 참조하세요.