대량 쓰기 작업

개요

이 가이드 에서는 코틀린 동기 (Kotlin Sync) 운전자 를 사용하여 한 번의 데이터베이스 호출로 데이터를 여러 번 변경하는 대량 쓰기 (write) 작업을 수행하는 방법을 설명합니다.

동일한 작업 에 대해 문서를 삽입하고, 문서를 업데이트 하고, 문서를 삭제 해야 하는 상황을 생각해 보세요. 개별 쓰기 (write) 메서드를 사용하여 각 유형의 작업을 수행하는 경우 각 쓰기 (write) 는 데이터베이스 에 별도로 액세스합니다. 대량 쓰기 (write) 작업을 사용하여 애플리케이션 에서 서버 에 대해 수행하는 호출 수를 최적화할 수 있습니다.

data class Restaurant(
    val name: String,
    val borough: String,
    val cuisine: String
)

쓰기 작업 정의

수행하려는 각 쓰기 (write) 작업에 대해 일반 WriteModel 클래스에서 상속되는 다음 작업 클래스 중 하나의 해당 인스턴스 를 만듭니다.

• InsertOneModel

• UpdateOneModel

• UpdateManyModel

• ReplaceOneModel

• DeleteOneModel

• DeleteManyModel

그런 다음 이러한 인스턴스 목록을 bulkWrite() 메서드에 전달합니다.

다음 섹션에서는 이전 클래스의 인스턴스를 만들고 사용하는 방법을 보여줍니다. 대량 작업 수행 섹션에서는 모델 목록을 bulkWrite() 메서드에 전달하여 대량 작업을 수행하는 방법을 보여 줍니다.

val blueMoon = InsertOneModel(Restaurant("Blue Moon Grill", "Brooklyn", "American"))

val updateOneFilter = Filters.eq(Restaurant::name.name, "White Horse Tavern")
val updateOneDoc = Updates.set(Restaurant::borough.name, "Queens")
val tavernUpdate = UpdateOneModel<Restaurant>(updateOneFilter, updateOneDoc)

val updateManyFilter = Filters.eq(Restaurant::name.name, "Wendy's")
val updateManyDoc = Updates.set(Restaurant::cuisine.name, "Fast food")
val wendysUpdate = UpdateManyModel<Restaurant>(updateManyFilter, updateManyDoc)

val replaceFilter = Filters.eq(Restaurant::name.name, "Cooper Town Diner")
val replaceDoc = Restaurant("Smith Town Diner", "Brooklyn", "American")
val replacement = ReplaceOneModel(replaceFilter, replaceDoc)

val deleteOne = DeleteOneModel<Restaurant>(Filters.eq(
    Restaurant::name.name,
    "Morris Park Bake Shop"
))

val deleteMany = DeleteManyModel<Restaurant>(Filters.eq(
    Restaurant::cuisine.name,
    "Experimental"
))

대량 작업 수행

수행하려는 각 작업에 대한 모델 인스턴스 를 정의한 후 이러한 인스턴스 목록을 bulkWrite() 메서드에 전달합니다. 기본값 으로 이 메서드는 모델 목록에 지정된 순서대로 작업을 실행합니다.

다음 예시 에서는 bulkWrite() 메서드를 사용하여 여러 쓰기 (write) 작업을 수행합니다.

val insertOneMdl = InsertOneModel(Restaurant("Red's Pizza", "Brooklyn", "Pizzeria"))
val updateOneMdl = UpdateOneModel<Restaurant>(
    Filters.eq(Restaurant::name.name, "Moonlit Tavern"),
    Updates.set(Restaurant::borough.name, "Queens")
)
val deleteManyMdl = DeleteManyModel<Restaurant>(
    Filters.eq(Restaurant::name.name, "Crepe")
)
val bulkResult = collection.bulkWrite(
    listOf(insertOneMdl, updateOneMdl, deleteManyMdl)
)
println(bulkResult)

AcknowledgedBulkWriteResult{insertedCount=1, matchedCount=5, removedCount=3,
modifiedCount=2, upserts=[], inserts=[BulkWriteInsert{index=0,
id=BsonObjectId{value=...}}]}

쓰기 (write) 작업 중 하나라도 실패하면 코틀린 동기 (Kotlin Sync) 운전자 는 BulkWriteError 를 발생시키고 추가 작업을 수행하지 않습니다. BulkWriteError 은(는) 실패한 작업이 포함된 details 항목과 예외에 대한 세부 정보를 제공합니다.

대량 쓰기 작업 사용자 지정

bulkWrite() 메서드는 대량 쓰기 (write) 작업을 구성하는 데 사용할 수 있는 옵션을 지정하는 매개 변수를 선택적으로 허용합니다. 옵션을 지정하지 않으면 운전자 는 기본값 설정으로 대량 작업을 수행합니다.

다음 표에서는 BulkWriteOptions 인스턴스 를 구성하는 데 사용할 수 있는 setter 메서드에 대해 설명합니다.

다음 코드는 옵션을 생성하고 ordered(false) 옵션을 사용하여 순서가 지정되지 않은 대량 쓰기 (write) 를 지정합니다. 그런 다음 이 예시 에서는 bulkWrite() 메서드를 사용하여 대량 작업을 수행합니다.

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

순서가 지정되지 않은 대량 쓰기 (write) 의 쓰기 (write) 작업 중 하나라도 실패하면 코틀린 동기 (Kotlin Sync) 운전자 는 모든 작업을 시도한 후에만 오류를 보고합니다.

반환 값

bulkWrite() 메서드는 BulkWriteResult 객체 를 반환합니다. BulkWriteResult 인스턴스 에서 다음 정보에 액세스 할 수 있습니다.

추가 정보

개별 쓰기 작업을 수행하는 방법을 알아보려면 다음 가이드를 참조하세요.

• 문서 삽입

• 문서 업데이트

• 문서 삭제