Operações em massa

Visão geral

Neste guia, você pode aprender como usar operações em massa no MongoDB Kotlin Driver.

Para operações CRUD individuais, você pode usar o método relevante. Por exemplo, para inserir um documento e atualizar vários documentos, você pode usar o método insertOne() e o método updateMany() .

O MongoClient executa estas operações fazendo uma solicitação ao reconhecimento de data center correspondente a cada operação. Você pode reduzir o número de chamadas para o reconhecimento de data center usando operações em massa.

Execução de operações em massa

As operações em massa consistem em um grande número de operações de escrita. Para executar uma operação em massa, passe um List contendo WriteModel documentos para o método bulkWrite() . Um WriteModel é um modelo que representa uma única operação de gravação.

As seções a seguir mostram como criar e usar cada variação do tipo WriteModel . Os exemplos em cada seção utilizam os seguintes documento na collection people :

{ "_id": 1, "name": "Karen Sandoval", "age": 31 }
{ "_id": 2, "name": "William Chin", "age": 54 }
{ "_id": 8, "name": "Shayla Ray", "age": 20 }

Esses dados são modelados com a seguinte classe de dados Kotlin:

data class Person(
    @BsonId val id: Int,
    val name: String,
    val age: Int? = null,
    val location: String? = null
)

Para obter mais informações sobre os métodos e as classes mencionadas nesta seção, consulte a seguinte documentação da API:

• bulkWrite()

• WriteModel

• BulkWriteOptions

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={}}].

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

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

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

Ordem de execução

O método bulkWrite() aceita um BulkWriteOptions opcional como segundo parâmetro para especificar se você deseja executar as operações em massa como ordenadas ou não.

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 }

Resumo

Para executar uma operação em massa, crie e passe uma lista de documentos do WriteModel para o método bulkWrite() .

Existem seis variações de WriteModel:

• InsertOneModel

• ReplaceOneModel

• UpdateOneModel

• UpdateManyModel

• DeleteOneModel

• DeleteManyModel

Há duas maneiras de executar o método bulkWrite():

• Solicitado, onde o driver executa as operações de gravação para ocorrer qualquer erro

• Não ordenado, onde o driver executa todas as operações de gravação em qualquer ordem e relata quaisquer erros após a conclusão das operações