Operações em massa

Dados de amostra

Os exemplos deste guia utilizam o seguinte Book estruturado como um modelo para documentos na coleção books:

type Book struct {
	Title  string
	Author string
	Length int32
}

Para executar os exemplos nesta aba, carregue os dados de amostra na coleção db.books com o seguinte trecho:

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 contém uma descrição de um livro que inclui o título, o autor e o comprimento da página correspondentes aos campos title, author e length em cada documento.

Modificar comportamento

Opcionalmente, o método BulkWrite() usa o tipo BulkWriteOptions, que representa as opções que você pode usar para modificar seu comportamento. Se você não especificar um BulkWriteOptions, o driver utilizará os valores padrão para cada opção.

O tipo BulkWriteOptions permite a você configurar opções com os seguintes métodos:

Return Values

O método BulkWrite() retorna um tipo BulkWriteResult, que contém informações sobre a operação em massa, se ela for bem-sucedida. O tipo BulkWriteResult contém as seguintes propriedades:

Insert

Para executar uma operação de inserção, crie um InsertOneModel especificando o documento que você deseja inserir. Para inserir vários documentos, crie um InsertOneModel para cada documento que você deseja inserir.

O InsertOneModel permite a você especificar seu comportamento com o seguinte 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}),
}

Substituir

Para executar uma operação de substituição, crie um ReplaceOneModel especificando o documento que deseja substituir e um documento de substituição. Para substituir vários documentos, crie um ReplaceOneModel para cada documento que deseja substituir.

O ReplaceOneModel permite a você especificar seu comportamento com os seguintes métodos:

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

Update

Para executar uma operação de atualização, crie um UpdateOneModel especificando o documento que você deseja atualizar e um documento de atualização. Para atualizar vários documentos, use o UpdateManyModel.

O UpdateOneModel e UpdateManyModel permitem a você especificar seu comportamento com os seguintes métodos:

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

Excluir

Para executar uma operação de exclusão, crie um DeleteOneModel especificando o documento que você deseja excluir. Para excluir vários documentos, use o DeleteManyModel.

O DeleteOneModel e DeleteManyModel permitem a você especificar seu comportamento com os seguintes métodos:

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

Pedido

Por padrão, o método BulkWrite() executa operações em massa para que você as adicione e pare se ocorrer um erro.

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

Não ordenado

Para executar operações de gravação em massa em qualquer ordem e continuar se ocorrer um erro, especifique false no método SetOrdered(). O método relata os erros posteriormente.

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}

Operações relacionadas

Para saber mais sobre como executar as operações mencionadas, consulte os seguintes guias:

• Especificar uma query
• Insira um documento
• Modificar documentos
• Exclua documentos

• Operações de gravação em massa

Documentação da API

Para saber mais sobre qualquer um dos métodos ou tipos discutidos neste guia, consulte a seguinte documentação da API:

• BulkWrite()

• BulkWriteOptions

• BulkWriteResult

• NewInsertOneModel()

• NewReplaceOneModel()

• NewReplaceOneModel()

• NewUpdateOneModel()

• NewUpdateManyModel()

• NewDeleteOneModel()

• NewDeleteManyModel()