Menu Docs

Página inicial do Docs → Desenvolver aplicações → MongoDB Drivers → Java síncrono

Realizar operações em massa

O método bulkWrite() executa operações de gravação em lote em uma collection. Esse método reduz o número de viagens de ida e volta da rede do seu aplicativo para a instância do MongoDB, o que aumenta o desempenho do seu aplicativo. Como você só recebe o status de sucesso depois que todas as operações retornam, recomendamos usar isso se for atender aos requisitos do seu caso de uso.

Você pode especificar uma ou mais das seguintes operações de gravação no bulkWrite():

  • insertOne

  • updateOne

  • updateMany

  • deleteOne

  • deleteMany

  • replaceOne

O método bulkWrite() aceita os seguintes parâmetros:

  • Um List de objetos que implementam o WriteModel: as classes que implementam o WriteModel correspondem às operações de gravação mencionadas acima. Por exemplo, a classe InsertOneModel envolve a operação de gravação insertOne. Consulte os links para a documentação da API na parte inferior desta página para obter mais informações sobre cada classe.

  • BulkWriteOptions: objeto opcional que especifica configurações, por exemplo, como garantir que a instância do MongoDB ordene suas operações de gravação.

Observação

Retryable writes são executadas nas versões 3.6 ou posteriores do Servidor MongoDB em operações de gravação em massa, a menos que incluam uma ou mais instâncias de UpdateManyModel ou DeleteManyModel.

Dica

Por padrão, o MongoDB executa operações de gravação em massa, uma a uma, na ordem especificada (por exemplo, em série). Durante uma gravação em massa ordenada, se ocorrer um erro durante o processamento de uma operação, o MongoDB retornará sem processar as operações restantes na lista. Por outro lado, quando você define ordered como false, o MongoDB continua processando as operações de gravação restantes na lista no caso de um erro. As operações não ordenadas são teoricamente mais rápidas, já que o MongoDB pode executá-las em paralelo, mas só devem ser usadas se as gravações não dependerem da ordem.

O método bulkWrite() gera um objeto BulkWriteResult que contém informações sobre os resultados da operação de gravação, incluindo o número de documentos inseridos, modificados e excluídos.

Se uma ou mais de suas operações tentarem definir um valor que viole um índice único em sua collection, uma exceção será gerada da seguinte forma:

The bulk write operation failed due to an error: Bulk write operation error on server <hostname>. Write errors: [BulkWriteError{index=0, code=11000, message='E11000 duplicate key error collection: ... }].

Da mesma forma, se você tentar executar uma gravação em massa em uma coleção que usa validação de esquema e uma ou mais de suas operações de escrita fornecer um formato inesperado, você pode encontrar exceções.

Exemplo

A amostra de código a seguir executa uma operação de gravação ordenada em massa na collection movies do banco de dados sample_mflix. A chamada de exemplo para bulkWrite() inclui exemplos de InsertOneModel, UpdateOneModel e DeleteOneModel.

Observação

Esse exemplo se conecta a uma instância do MongoDB usando um URI de conexão. Para saber mais sobre como se conectar à sua instância do MongoDB, consulte o Guia de conexão.

package usage.examples;
import java.util.Arrays;
import org.bson.Document;
import com.mongodb.MongoException;
import com.mongodb.bulk.BulkWriteResult;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.DeleteOneModel;
import com.mongodb.client.model.InsertOneModel;
import com.mongodb.client.model.ReplaceOneModel;
import com.mongodb.client.model.UpdateOneModel;
import com.mongodb.client.model.UpdateOptions;
public class BulkWrite {
    public static void main(String[] args) {
        // Replace the uri string with your MongoDB deployment's connection string
        String uri = "<connection string uri>";
        try (MongoClient mongoClient = MongoClients.create(uri)) {
            MongoDatabase database = mongoClient.getDatabase("sample_mflix");
            MongoCollection<Document> collection = database.getCollection("movies");
            try {
                BulkWriteResult result = collection.bulkWrite(
                        Arrays.asList(
                                new InsertOneModel<>(new Document("name", "A Sample Movie")),
                                new InsertOneModel<>(new Document("name", "Another Sample Movie")),
                                new InsertOneModel<>(new Document("name", "Yet Another Sample Movie")),
                                new UpdateOneModel<>(new Document("name", "A Sample Movie"),
                                        new Document("$set", new Document("name", "An Old Sample Movie")),
                                        new UpdateOptions().upsert(true)),
                                new DeleteOneModel<>(new Document("name", "Yet Another Sample Movie")),
                                new ReplaceOneModel<>(new Document("name", "Yet Another Sample Movie"),
                                        new Document("name", "The Other Sample Movie").append("runtime",  "42"))
                                ));
                System.out.println("Result statistics:" +
                        "\ninserted: " + result.getInsertedCount() +
                        "\nupdated: " + result.getModifiedCount() +
                        "\ndeleted: " + result.getDeletedCount());
            } catch (MongoException me) {
                System.err.println("The bulk write operation failed due to an error: " + me);
            }
        }
    }
}

A saída deve ser semelhante a esta:

Result statistics:
inserted: 3
updated: 2
deleted: 1

Dica

API legado

Se você estiver usando a API herdada, consulte nossa página de perguntas frequentes para saber quais alterações devem ser feitas nesse exemplo de código.

Para obter informações adicionais sobre as classes e métodos mencionados nesta página, consulte os seguintes recursos:

  • Entrada manual do servidor de índice único

  • Validação de esquema Entrada manual do servidor

  • escrita em massa() Documentação da API

  • BulkWriteOptions Documentação da API

  • BulkWriteResult Documentação da API

  • InsertOneModel Documentação da API

  • Documentação da API do UpdateOneModel

  • Documentação da API do UpdateManyModel

  • Documentação da API do DeleteOneModel

  • Documentação da API do DeleteManyModel

  • Documentação da API do ReplaceOneModel

← Excluir vários documentos
Fique atento às mudanças →