Operaciones masivas

Datos de muestra

Los ejemplos en esta guía usan la siguiente estructura Book como modelo para documentos en la colección books:

type Book struct {
	Title  string
	Author string
	Length int32
}

Para ejecutar los ejemplos en esta guía, carga los datos de muestra en la colección db.books con el siguiente fragmento:

coll := client.Database("db").Collection("books")
docs := []interface{}{
	Book{Title: "My Brilliant Friend", Author: "Elena Ferrante", Length: 331},
	Book{Title: "Lucy", Author: "Jamaica Kincaid", Length: 103},
}
result, err := coll.InsertMany(context.TODO(), docs)

Cada documento contiene una descripción de un libro que incluye el título, el autor y la extensión en páginas que corresponden a los campos title, author y length en cada documento.

Modificar comportamiento

El método BulkWrite() opcionalmente acepta un tipo BulkWriteOptions, que representa opciones que puede utilizar para modificar su comportamiento. Si no especifica un BulkWriteOptions, el driver utiliza los valores por defecto para cada opción.

El tipo BulkWriteOptions te permite configurar opciones con los siguientes métodos:

Return Values

El método BulkWrite() devuelve un tipo BulkWriteResult, que contiene información sobre la operación por lotes si tiene éxito. El tipo BulkWriteResult contiene las siguientes propiedades:

Insert

Para realizar una operación de inserción, crea un InsertOneModel especificando el documento que desea insertar. Para insertar varios documentos, crea un InsertOneModel para cada documento que desees insertar.

El InsertOneModel permite especificar su comportamiento con el siguiente método:

models := []mongo.WriteModel{
	mongo.NewInsertOneModel().SetDocument(Book{Title: "Beloved", Author: "Toni Morrison", Length: 324}),
	mongo.NewInsertOneModel().SetDocument(Book{Title: "Outline", Author: "Rachel Cusk", Length: 258}),
}

Reemplaza

Para realizar una operación de reemplazo, crea un ReplaceOneModel especificando el documento que deseas reemplazar y un documento de reemplazo. Para reemplazar varios documentos, cree un ReplaceOneModel para cada documento que desee reemplazar.

El ReplaceOneModel te permite especificar su comportamiento con los siguientes métodos:

models := []mongo.WriteModel{
	mongo.NewReplaceOneModel().SetFilter(bson.D{{"title", "Lucy"}}).
		SetReplacement(Book{Title: "On Beauty", Author: "Zadie Smith", Length: 473}),
}

Update

Para realizar una operación de actualización, crea un UpdateOneModel que especifique el documento que deseas actualizar y un documento de actualización. Para actualizar varios documentos, use el UpdateManyModel.

El UpdateOneModel y el UpdateManyModel permiten especificar su comportamiento con los siguientes métodos:

models := []mongo.WriteModel{
	mongo.NewUpdateOneModel().SetFilter(bson.D{{"author", "Elena Ferrante"}}).
		SetUpdate(bson.D{{"$inc", bson.D{{"length", -15}}}}),
}

Borrar

Para realizar una operación de borrado, cree un DeleteOneModel especificando el documento que desea eliminar. Para borrar varios documentos, utilice el DeleteManyModel.

El DeleteOneModel y el DeleteManyModel permiten especificar su comportamiento con los siguientes métodos:

models := []mongo.WriteModel{
	mongo.NewDeleteManyModel().SetFilter(bson.D{{"length", bson.D{{"$gt", 300}}}}),
}

Ordenado

Por defecto, el método BulkWrite() ejecuta las operaciones en lote en el orden en que se agregaron y se detiene si se produce un error.

opts := options.BulkWrite().SetOrdered(true)

Desordenado

Para ejecutar operaciones de escritura masiva en cualquier orden y continuar si ocurre un error, especifique false en el método SetOrdered(). El método informa los errores después.

models := []mongo.WriteModel{
  mongo.NewInsertOneModel().SetDocument(Book{Title: "Middlemarch", Author: "George Eliot", Length: 904}),
  mongo.NewInsertOneModel().SetDocument(Book{Title: "Pale Fire", Author: "Vladimir Nabokov", Length: 246}),
  mongo.NewReplaceOneModel().SetFilter(bson.D{{"title", "My Brilliant Friend"}}).
    SetReplacement(Book{Title: "Atonement", Author: "Ian McEwan", Length: 351}),
  mongo.NewUpdateManyModel().SetFilter(bson.D{{"length", bson.D{{"$lt", 200}}}}).
    SetUpdate(bson.D{{"$inc", bson.D{{"length", 10}}}}),
  mongo.NewDeleteManyModel().SetFilter(bson.D{{"author", bson.D{{"$regex", "Jam"}}}}),
}
opts := options.BulkWrite().SetOrdered(false)
results, err := coll.BulkWrite(context.TODO(), models, opts)
if err != nil {
   panic(err)
}
fmt.Printf("Number of documents inserted: %d\n", results.InsertedCount)
fmt.Printf("Number of documents replaced or updated: %d\n", results.ModifiedCount)
fmt.Printf("Number of documents deleted: %d\n", results.DeletedCount)

Number of documents inserted: 2
Number of documents replaced or updated: 2
Number of documents deleted: 1

{"title":"Atonement","author":"Ian McEwan","length":351}
{"title":"Middlemarch","author":"George Eliot","length":904}
{"title":"Pale Fire","author":"Vladimir Nabokov","length":246}

Operaciones Relacionadas

Para obtener más información sobre cómo realizar las operaciones mencionadas, consulte las siguientes guías:

• Especifica un query
• Insertar un documento
• Modificar documentos
• Delete Documents

• Operaciones de escritura masiva

Documentación de la API

Para obtener más información sobre cualquiera de los métodos o tipos discutidos en esta guía, consultar la siguiente documentación de la API:

• bulkWrite()

• BulkWriteOptions

• BulkWriteResult

• NewInsertOneModel()

• NewReplaceOneModel()

• NewReplaceOneModel()

• NewUpdateOneModel()

• NewUpdateManyModel()

• NewDeleteOneModel()

• NewDeleteManyModel()