array ( 0 => 'index.php', 1 => 'PHP Manual', ), 'head' => array ( 0 => 'UTF-8', 1 => 'es', ), 'this' => array ( 0 => 'class.mongodb-driver-bulkwritecommand.php', 1 => 'MongoDB\\Driver\\BulkWriteCommand', 2 => 'La clase MongoDB\\Driver\\BulkWriteCommand', ), 'up' => array ( 0 => 'mongodb.mongodb.php', 1 => 'MongoDB\\Driver', ), 'prev' => array ( 0 => 'mongodb-driver-bulkwrite.update.php', 1 => 'MongoDB\\Driver\\BulkWrite::update', ), 'next' => array ( 0 => 'mongodb-driver-bulkwritecommand.construct.php', 1 => 'MongoDB\\Driver\\BulkWriteCommand::__construct', ), 'alternatives' => array ( ), 'source' => array ( 'lang' => 'es', 'path' => 'reference/mongodb/mongodb/driver/bulkwritecommand.xml', ), 'history' => array ( ), 'extra_header_links' => array ( 'rel' => 'alternate', 'href' => '/manual/en/feeds/class.mongodb-driver-bulkwritecommand.atom', 'type' => 'application/atom+xml', ), ); $setup["toc"] = $TOC; $setup["toc_deprecated"] = $TOC_DEPRECATED; $setup["parents"] = $PARENTS; manual_setup($setup); contributors($setup); ?>

La clase MongoDB\Driver\BulkWriteCommand

(mongodb >=2.1.0)

Introducción

MongoDB\Driver\BulkWriteCommand recupera una o varias operaciones de escritura que deben ser enviadas al servidor mediante el comando » bulkWrite introducido en MongoDB 8.0. Tras añadir cualquier número de operaciones de escritura, operaciones de modificación y operaciones de eliminación, el comando puede ser ejecutado a través de MongoDB\Driver\Manager::executeBulkWriteCommand().

A diferencia de MongoDB\Driver\BulkWrite, donde todas las operaciones de escritura deben apuntar a la misma colección, cada operación de escritura en MongoDB\Driver\BulkWriteCommand debe apuntar a una colección diferente.

Las operaciones de escritura pueden ser ordenadas (por defecto) o no ordenadas. Las operaciones ordenadas son enviadas al servidor, en el orden proporcionado, para una ejecución serial. Si una escritura falla, todas las operaciones restantes serán canceladas. Las operaciones no ordenadas son enviadas al servidor en un orden arbitrario donde pueden ser ejecutadas en paralelo. Todos los errores que ocurran son reportados después de que todas las operaciones hayan sido intentadas.

Sinopsis de la Clase

final class MongoDB\Driver\BulkWriteCommand implements Countable {
/* Métodos */
public __construct(?array $options = null)
public count(): int
public deleteMany(string $namespace, array|object $filter, ?array $options = null): void
public deleteOne(string $namespace, array|object $filter, ?array $options = null): void
public insertOne(string $namespace, array|object $document): mixed
public replaceOne(
    string $namespace,
    array|object $filter,
    array|object $replacement,
    ?array $options = null
): void
public updateMany(
    string $namespace,
    array|object $filter,
    array|object $update,
    ?array $options = null
): void
public updateOne(
    string $namespace,
    array|object $filter,
    array|object $update,
    ?array $options = null
): void
}

Ejemplos

Ejemplo #1 Operaciones de escritura mixtas

Las operaciones de escritura mixtas (por ejemplo, inserciones, actualizaciones y eliminaciones) serán enviadas al servidor mediante una sola comando » bulkWrite.

<?php

$manager = new MongoDB\Driver\Manager;

$bulk = new MongoDB\Driver\BulkWriteCommand;

// Eliminar documentos de ambas colecciones
$bulk->deleteMany('db.coll_one', []);
$bulk->deleteMany('db.coll_two', []);

// Insertar documentos en dos colecciones
$bulk->insertOne('db.coll_one', ['_id' => 1]);
$bulk->insertOne('db.coll_two', ['_id' => 2]);
$bulk->insertOne('db.coll_two', ['_id' => 3]);

// Actualizar un documento en "coll_one"
$bulk->updateOne('db.coll_one', ['_id' => 1], ['$set' => ['x' => 1]]);

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

printf("%d documento(s) han sido insertado(s)\n", $result->getInsertedCount());
printf("%d documento(s) han sido actualizado(s)\n", $result->getModifiedCount());

?>

El ejemplo anterior mostrará:

3 documento(s) han sido insertado(s)
1 documento(s) han sido actualizado(s)

Ejemplo #2 Operaciones de escritura ordenadas que causan un error

<?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("%d documento(s) han sido insertado(s)\n", $result->getInsertedCount());

?>

Resultado del ejemplo anterior es similar 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) {
    }
  }
}
2 documento(s) han sido insertado(s)

Tabla de contenidos