/ /

Escritura de datos

Docs Home

Librerías de clientes

Scala

Escritura de datos

Docs Home

Librerías de clientes

Scala

Escritura de datos

Update Documents

Overview

En esta guía, aprenderás a usar el driver de Scala para actualizar documentos en una colección de MongoDB updateOne() y updateMany() métodos.

Datos de muestra

Los ejemplos de esta guía usan 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 tu aplicación Scala, crea un MongoClient que se conecte a un clúster de Atlas y asigna los siguientes valores a tus variables database y collection:

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 ejemplo, consulta la guía MongoDB Get Started.

Operaciones de actualizar

Puedes actualizar documentos en MongoDB utilizando los siguientes métodos:

updateOne()que actualiza el primer documento que coincide con los criterios de búsqueda
updateMany(), 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 query, que coincide con los documentos que deseas actualizar. Para aprender más sobre los filtros de query, consulte la Guía 'Especificar una query' .
Actualizar documento, que especifica el operador de actualización y los campos y valores a actualizar. El operador de actualización especifica el tipo de actualización a realizar. Para ver una lista de operadores de actualización y aprender sobre 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 usa el método updateMany() para actualizar todos los documentos en los que el 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

Personaliza la operación de actualizar

Los métodos updateOne() y updateMany() aceptan opcionalmente un parámetro que establece opciones para configurar la operación de actualización. Si no especifica ninguna opción, el driver realizará operaciones con la configuración predeterminada.

La siguiente tabla describe los métodos setter que puedes usar para configurar una instancia de UpdateOptions:

Método	Descripción
`upsert()`	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`
`sort()`	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.
`bypassDocumentValidation()`	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`.
`collation()`	Specifies the kind of language collation to use when sorting results. For more information, see Collation in the MongoDB Server manual.
`arrayFilters()`	Provides a list of filters that you specify to select which array elements the update applies to.
`hint()`	Sets the index to use when matching documents. For more information, see the hint statement in the MongoDB Server manual.
`let()`	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.
`comment()`	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.

Modificar ejemplo de actualización

Este ejemplo crea y pasa opciones al método updateOne(). El ejemplo usa el método asistente equal() para hacer coincidir documentos en los que el valor del campo name es "Sunrise Pizzeria". Luego utiliza el método set() para establecer el valor del campo borough en el primer documento coincidente a "Queens" y el valor del campo cuisine a "Italian". El código utiliza el método combine() para especificar varias actualizaciones en un único documento de actualización.

Debido a que la opción upsert está configurada en true en la instancia UpdateOptions, el controlador inserta un nuevo documento que tiene los campos y valores especificados en el filtro y en el documento de actualización si el filtro de query 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 utilizar los siguientes métodos para acceder a la información desde una instancia de UpdateResult:

Método	Descripción
`getMatchedCount()`	Returns the number of documents that matched the query filter, regardless of how many updates were performed.
`getModifiedCount()`	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.
`wasAcknowledged()`	Returns `true` if the server acknowledged the result.
`getUpsertedId()`	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() retorna false, intentar acceder a otra información desde la instancia UpdateResult resulta en una excepción InvalidOperation. El driver no puede determinar estos valores si el servidor no reconoce la operación de guardado.

Información Adicional

Para ver ejemplos de código ejecutable que demuestran cómo actualizar documentos utilizando el driver de Scala, consulta Guardar 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:

Volver

Reemplaza

Borrar