MongoDB\Driver\Manager::executeBulkWriteCommand

(mongodb >=2.1.0)

MongoDB\Driver\Manager::executeBulkWriteCommand ā€” Executa operaƧƵes de gravaĆ§Ć£o usando o comando bulkWrite

DescriĆ§Ć£o

final public function MongoDB\Driver\Manager::executeBulkWriteCommand(MongoDB\Driver\BulkWriteCommand $bulk, ?array $options = null): MongoDB\Driver\BulkWriteCommandResult

Executa uma ou mais operaƧƵes de gravaĆ§Ć£o no servidor primĆ”rio usando o comando Ā»Ā bulkWrite introduzido no MongoDB 8.0.

Um MongoDB\Driver\BulkWriteCommand pode ser construĆ­do com uma ou mais operaƧƵes de gravaĆ§Ć£o de tipos variados (por exemplo, inserƧƵes, atualizaƧƵes e exclusƵes). Cada operaĆ§Ć£o de gravaĆ§Ć£o pode ter como alvo uma coleĆ§Ć£o diferente.

O valor padrĆ£o para a opĆ§Ć£o "writeConcern" serĆ” inferido a partir de uma transaĆ§Ć£o ativa (indicada pela opĆ§Ć£o "session"), seguida pelo URI de conexĆ£o.

ParĆ¢metros

bulk (MongoDB\Driver\BulkWriteCommand)
O comando de gravaƧƵes a ser executado.
options

OpƧƵes
OpĆ§Ć£o Tipo DescriĆ§Ć£o
session MongoDB\Driver\Session Uma sessĆ£o para associar Ć  operaĆ§Ć£o.
writeConcern MongoDB\Driver\WriteConcern Um write concern a ser aplicado Ć  operaĆ§Ć£o.

Valor Retornado

Retorna MongoDB\Driver\BulkWriteCommandResult em caso de sucesso.

Erros/ExceƧƵes

Exemplos

Exemplo #1 OperaƧƵes de gravaĆ§Ć£o mistas

OperaƧƵes de gravaĆ§Ć£o mistas (ou seja, inserƧƵes, atualizaƧƵes e exclusƵes) serĆ£o enviadas para o servidor usando um Ćŗnico comando Ā»Ā bulkWrite.

<?php

$manager = new MongoDB\Driver\Manager;

$bulk = new MongoDB\Driver\BulkWriteCommand;

// Exclui documentos de ambas as coleƧƵes
$bulk->deleteMany('db.coll_one', []);
$bulk->deleteMany('db.coll_two', []);

// Insere documentos em duas coleƧƵes
$bulk->insertOne('db.coll_one', ['_id' => 1]);
$bulk->insertOne('db.coll_two', ['_id' => 2]);
$bulk->insertOne('db.coll_two', ['_id' => 3]);

// Atualiza um documento em "coll_one"
$bulk->updateOne('db.coll_one', ['_id' => 1], ['$set' => ['x' => 1]]);

$result = $manager->executeBulkWriteCommand($bulk);

printf("Inserido(s) %d documento(s)\n", $result->getInsertedCount());
printf("Atualizado(s) %d documento(s)\n", $result->getModifiedCount());

?>

O exemplo acima produzirĆ”:

Inserido(s) 3 documento(s)
Atualizado(s) 1 documento(s)

Exemplo #2 OperaƧƵes de gravaĆ§Ć£o ordenadas causando um erro

<?php

$manager = new MongoDB\Driver\Manager;

$bulk = new MongoDB\Driver\BulkWriteCommand;

$bulk->deleteMany('db.coll', []);
$bulk->insertOne('db.coll', ['_id' => 1]);
$bulk->insertOne('db.coll', ['_id' => 2]);
$bulk->insertOne('db.coll', ['_id' => 1]);
$bulk->insertOne('db.coll', ['_id' => 3]);

try {
$result = $manager->executeBulkWriteCommand($bulk);
} catch (MongoDB\Driver\Exception\BulkWriteCommandException $e) {
$result = $e->getPartialResult();

var_dump($e->getWriteErrors());
}

printf("Inserido(s) %d documento(s)\n", $result->getInsertedCount());

?>

O exemplo acima produzirĆ” algo semelhante a:

array(1) {
  [3]=>
  object(MongoDB\Driver\WriteError)#5 (4) {
    ["message"]=>
    string(78) "E11000 duplicate key error collection: db.coll index: _id_ dup key: { _id: 1 }"
    ["code"]=>
    int(11000)
    ["index"]=>
    int(3)
    ["info"]=>
    object(stdClass)#6 (0) {
    }
  }
}
Inserido(s) 2 documento(s)

Veja TambƩm

Melhore Esta PƔgina

Aprenda Como Melhorar Esta PĆ”gina ā€¢ Envie uma SolicitaĆ§Ć£o de ModificaĆ§Ć£o ā€¢ Reporte um Problema
ļ¼‹adicionar nota

Notas de UsuƔrios

NĆ£o hĆ” notas de usuĆ”rios para esta pĆ”gina.