Operações de gravação em massa

Visão geral

Neste guia, você aprenderá a executar várias operações de gravação em uma única chamada de banco de dados de dados usando operações de gravação em massa.

Considere um cenário no qual você deseja inserir um documento em uma coleção, atualizar vários outros documentos e excluir um documento. Se você usar métodos individuais, cada operação exigirá sua própria chamada de banco de dados de dados. Este guia mostra como usar operações de gravação em massa para reduzir o número de chamadas para o banco de dados de dados.

Definir as operações de gravação

Para cada operação de gravação que você deseja executar, crie uma instância de uma das seguintes classes:

• InsertOneModel

• UpdateOneModel

• UpdateManyModel

• ReplaceOneModel

• DeleteOneModel

• DeleteManyModel

Em seguida, passe uma lista dessas instâncias para o método bulkWrite() .

As seções seguintes mostram como criar e utilizar instâncias das classes anteriores.

InsertOneModel<Document> operation = new InsertOneModel<>(
        new Document("name", "Mongo's Deli")
                .append("cuisine", "Sandwiches"));

UpdateOneModel<Document> operation = new UpdateOneModel<>(
        eq("name", "Mongo's Deli"),
        set("cuisine", "Sandwiches and Salads"));

UpdateManyModel<Document> operation = new UpdateManyModel<>(
        eq("name", "Mongo's Deli"),
        set("cuisine", "Sandwiches and Salads"));

ReplaceOneModel<Document> operation = new ReplaceOneModel<>(
        eq("name", "Original Pizza"),
        new Document("name", "Mongo's Pizza")
                .append("borough", "Manhattan"));

DeleteOneModel<Document> operation = new DeleteOneModel<>(
        eq("restaurant_id", "5678"));

DeleteManyModel<Document> operation = new DeleteManyModel<>(
        eq("name", "Mongo's Deli"));

Chame o bulkWrite() método

Depois de definir uma instância de classe para cada operação que deseja executar, passe uma lista dessas instâncias para o método bulkWrite() . Por padrão, o método executa as operações na ordem em que foram definidas na lista.

O exemplo a seguir executa diversas operações de gravação usando o método bulkWrite() :

Publisher<BulkWriteResult> bulkWritePublisher = restaurants.bulkWrite(
        Arrays.asList(new InsertOneModel<>(
                        new Document("name", "Mongo's Deli")
                                .append("cuisine", "Sandwiches")
                                .append("borough", "Manhattan")
                                .append("restaurant_id", "1234")),
                new InsertOneModel<>(new Document("name", "Mongo's Deli")
                                .append("cuisine", "Sandwiches")
                                .append("borough", "Brooklyn")
                                .append("restaurant_id", "5678")),
                new UpdateManyModel<>(eq("name", "Mongo's Deli"),
                        set("cuisine", "Sandwiches and Salads")),
                new DeleteOneModel<>(eq("restaurant_id", "1234"))));
BulkWriteResult bulkResult = Mono.from(bulkWritePublisher).block();
System.out.println(bulkResult.toString());

AcknowledgedBulkWriteResult{insertedCount=2, matchedCount=2, removedCount=1, modifiedCount=2, upserts=[], inserts=[BulkWriteInsert{index=0, id=BsonObjectId{value=66a7e0a6c08025218b657208}}, BulkWriteInsert{index=1, id=BsonObjectId{value=66a7e0a6c08025218b657209}}]}

Se qualquer uma das operações de gravação falhar, o driver Java Reactive Streams sinalizará um MongoBulkWriteException e não executará mais nenhuma operação individual. MongoBulkWriteException inclui um BulkWriteError que pode ser acessado usando o método MongoBulkWriteException.getWriteErrors() , que fornece detalhes da falha individual.

Personalizar operações de gravação em massa

A classe BulkWriteOptions contém métodos que modificam o comportamento do método bulkWrite() . Para usar a classe BulkWriteOptions , construa uma nova instância da classe e, em seguida, chame um ou mais de seus métodos para modificar a operação de gravação. Você pode encadear essas chamadas de método. Para modificar o comportamento da operação de gravação, passe a instância da classe como o último argumento para o método bulkWrite() .

Você pode utilizar os seguintes métodos na classe BulkWriteOptions para modificar um método de escrita. Todos os métodos são opcionais.

O exemplo a seguir chama o método bulkWrite() do exemplo anterior, mas define a opção ordered como False:

Publisher<BulkWriteResult> bulkWritePublisher = restaurants.bulkWrite(
        Arrays.asList(new InsertOneModel<>(
                        new Document("name", "Mongo's Deli")
                                .append("cuisine", "Sandwiches")
                                .append("borough", "Manhattan")
                                .append("restaurant_id", "1234")),
                new InsertOneModel<>(new Document("name", "Mongo's Deli")
                                .append("cuisine", "Sandwiches")
                                .append("borough", "Brooklyn")
                                .append("restaurant_id", "5678")),
                new UpdateManyModel<>(eq("name", "Mongo's Deli"),
                        set("cuisine", "Sandwiches and Salads")),
                new DeleteOneModel<>(eq("restaurant_id", "1234"))), 
                new BulkWriteOptions().ordered(false));
BulkWriteResult bulkResult = Mono.from(bulkWritePublisher).block();
System.out.println(bulkResult.toString());

AcknowledgedBulkWriteResult{insertedCount=2, matchedCount=2, removedCount=1, modifiedCount=2, upserts=[], inserts=[BulkWriteInsert{index=0, id=BsonObjectId{value=66a7e03cce430c5854b6caf9}}, BulkWriteInsert{index=1, id=BsonObjectId{value=66a7e03cce430c5854b6cafa}}]}

Se qualquer uma das operações de gravação em uma gravação em massa não ordenada falhar, o driver Java Reactive Streams relatará os erros somente depois de tentar todas as operações.

Informações adicionais

Para saber como realizar operações de escrita individuais, consulte os seguintes guias:

• Insira documentos

• Atualize documentos

• Substituir documentos

• Exclua documentos