Overview
En esta guía, puede aprender a usar el controlador Scala para actualizar documentos en una colección MongoDB mediante el uso de updateOne() y updateMany() métodos.
Datos de muestra
Los ejemplos de esta guía utilizan la colección restaurants en la base de datos sample_restaurants de la Conjuntos de datos de muestra de Atlas. Para acceder a esta colección desde su aplicación Scala, cree un MongoClient que se conecte a un clúster de Atlas y asigne los siguientes valores a las variables database collection y:
val database: MongoDatabase = mongoClient.getDatabase("sample_restaurants") val collection: MongoCollection[Document] = database.getCollection("restaurants")
Para aprender cómo crear un clúster gratuito de MongoDB Atlas y cargar los conjuntos de datos de muestra, consulte la guía de introducción a MongoDB.
Operaciones de actualizar
Puede actualizar documentos en MongoDB utilizando los siguientes métodos:
updateOne(), que actualiza el primer documento que coincide con los criterios de búsquedaupdateMany(), que actualiza todos los documentos que coinciden con los criterios de búsqueda
Cada método de actualización requiere los siguientes parámetros:
Filtro de consulta, que coincide con los documentos que desea actualizar. Para obtener más información sobre los filtros de consulta, consulte Especifique una guía de consulta.
Documento de actualización, que especifica el operador de actualización y los campos y valores que se actualizarán. El operador de actualización especifica el tipo de actualización que se realizará. Para ver una lista de operadores de actualización y conocer sus usos, consulte la página de la guía "Operadores de actualización de campos" en el manual de MongoDB Server.
Ejemplo de actualización de un documento
El siguiente ejemplo utiliza el método updateOne() para actualizar el valor del campo name de un documento de "Happy Garden" a "Mountain
House". El documento de actualización utiliza el método set() para actualizar el valor del campo name:
val filter = equal("name", "Happy Garden") val update = set("name", "Mountain House") val observable: Observable[UpdateResult] = collection.updateOne(filter, update) observable.subscribe(new Observer[UpdateResult] { override def onNext(result: UpdateResult): Unit = println(s"Updated document count: ${result.getModifiedCount}") override def onError(e: Throwable): Unit = println(s"Failed: ${e.getMessage}") override def onComplete(): Unit = println("Completed") })
Updated document count: 1 Completed
Ejemplo para actualizar muchos documentos
El siguiente ejemplo utiliza el método updateMany() para actualizar todos los documentos cuyo valor del campo name es "Starbucks". El documento de actualización utiliza el método rename() para cambiar el nombre del campo address a location:
val filter = equal("name", "Starbucks") val update = rename("address", "location") val observable: Observable[UpdateResult] = collection.updateMany(filter, update) observable.subscribe(new Observer[UpdateResult] { override def onNext(result: UpdateResult): Unit = println(s"Updated document count: ${result.getModifiedCount}") override def onError(e: Throwable): Unit = println(s"Failed: ${e.getMessage}") override def onComplete(): Unit = println("Completed") })
Updated document count: 11 Completed
Personalizar la operación de actualización
Los métodos updateOne() y updateMany() aceptan opcionalmente un parámetro que establece opciones para configurar la operación de actualización. Si no se especifica ninguna opción, el controlador realiza las operaciones de actualización con la configuración predeterminada.
La siguiente tabla describe los métodos de configuración que puede utilizar para configurar una instancia UpdateOptions:
Método | Descripción |
|---|---|
| Specifies whether the update operation performs an upsert operation if no
documents match the query filter. For more information, see the upsert
statement
in the MongoDB Server manual. Defaults to false |
| Sets the sort criteria to apply to the operation. If multiple
documents match the query filter that you pass to the
updateOne() method, the operation updates the first
result. You can set this option to apply an order to matched
documents to have more control over which document is updated. |
| Specifies whether the update operation bypasses document validation. This lets you
update documents that don't meet the schema validation requirements, if any
exist. For more information about schema validation, see Schema
Validation in the MongoDB
Server manual. Defaults to false. |
| Specifies the kind of language collation to use when sorting
results. For more information, see Collation
in the MongoDB Server manual. |
| Provides a list of filters that you specify to select which
array elements the update applies to. |
| Sets the index to use when matching documents.
For more information, see the hint statement
in the MongoDB Server manual. |
| Provides a map of parameter names and values to set top-level
variables for the operation. Values must be constant or closed
expressions that don't reference document fields. For more information,
see the let statement in the
MongoDB Server manual. |
| Sets a comment to attach to the operation. For more
information, see the update command
fields guide in the
MongoDB Server manual for more information. |
Ejemplo de modificación y actualización
Este ejemplo crea y pasa opciones al método updateOne(). El ejemplo utiliza el método auxiliar equal() para buscar documentos cuyo valor del campo name sea "Sunrise Pizzeria". A continuación, utiliza el método set() para establecer el valor del campo borough en el primer documento coincidente como "Queens" y el valor del campo cuisine como "Italian". El código utiliza el método combine() para especificar varias actualizaciones en un documento de actualización.
Debido a que la opción upsert está establecida en true en la instancia UpdateOptions, el controlador inserta un nuevo documento que tiene los campos y valores especificados en el filtro y actualiza el documento si el filtro de consulta no coincide con ningún documento existente.
val filter = equal("name", "Sunrise Pizzeria") val opts = UpdateOptions().upsert(true) val update = combine( set("borough", "Queens"), set("cuisine", "Italian") ) val observable: Observable[UpdateResult] = collection.updateOne(filter, update, opts) observable.subscribe(new Observer[UpdateResult] { override def onNext(result: UpdateResult): Unit = println(s"Updated document count: ${result.getModifiedCount}") override def onError(e: Throwable): Unit = println(s"Failed: ${e.getMessage}") override def onComplete(): Unit = println("Completed") })
Updated document count: 1 Completed
Valor de retorno
Los métodos updateOne() y updateMany() devuelven cada uno un objeto UpdateResult. Puede usar los siguientes métodos para acceder a la información de una instancia UpdateResult:
Método | Descripción |
|---|---|
| Returns the number of documents that matched the query filter, regardless of
how many updates were performed. |
| Returns the number of documents modified by the update operation. If an updated
document is identical to the original, it is not included in this
count. |
| Returns true if the server acknowledged the result. |
| Returns the _id value of the document that was upserted
in the database, if the driver performed an upsert. |
Nota
Si el método wasAcknowledged() devuelve false, al intentar acceder a otra información de la instancia UpdateResult se genera una excepción InvalidOperation. El controlador no puede determinar estos valores si el servidor no confirma la operación de escritura.
Información Adicional
Para ver ejemplos de código ejecutables que demuestran cómo actualizar documentos mediante el controlador Scala, consulte Escribir datos en MongoDB.
Documentación de la API
Para aprender más sobre cualquiera de los métodos o tipos analizados en esta guía, consulta la siguiente documentación de API: