Operaciones masivas

Overview

En esta guía, puede aprender a utilizar operaciones masivas en el controlador MongoDB Kotlin.

Para operaciones CRUD individuales, puede usar el método correspondiente. Por ejemplo, para insertar un documento y luego actualizar varios, puede usar el insertOne() método y el método updateMany().

El MongoClient realiza estas operaciones mediante una solicitud a la base de datos correspondiente a cada operación. Puede reducir el número de llamadas a la base de datos mediante operaciones masivas.

Realización de operaciones masivas

Las operaciones masivas consisten en un gran número de operaciones de escritura. Para realizar una operación masiva, pase un List que contenga WriteModel documentos al método bulkWrite(). Un WriteModel es un modelo que representa una sola operación de escritura.

Las siguientes secciones muestran cómo crear y usar cada variación del tipo WriteModel. Los ejemplos de cada sección utilizan los siguientes documentos en la colección people:

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

Estos datos se modelan con la siguiente clase de datos Kotlin:

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

Para obtener más información sobre los métodos y clases mencionados en esta sección, consulte la siguiente documentación de API:

• bulkWrite()

• WriteModel

• Opciones de escritura masiva

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))

Orden de ejecución

El método bulkWrite() acepta un BulkWriteOptions opcional como segundo parámetro para especificar si desea ejecutar las operaciones masivas de forma ordenada o desordenada.

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 }

Resumen

Para realizar una operación masiva, cree y pase una lista de WriteModel documentos al método bulkWrite().

Hay seis variaciones de WriteModel:

• InsertOneModel

• ReplaceOneModel

• UpdateOneModel

• UpdateManyModel

• DeleteOneModel

• DeleteManyModel

Hay dos formas de ejecutar el método bulkWrite():

• Ordenado, donde el driver realiza las operaciones de guardado en orden hasta que ocurre algún error

• Desordenado, donde el controlador realiza todas las operaciones de escritura en cualquier orden e informa cualquier error una vez completadas las operaciones