Operaciones de escritura masiva

Datos de muestra

Los ejemplos de esta guía utilizan las colecciones y de los sample_restaurants.restaurants sample_mflix.movies conjuntos de datos de muestra de Atlas. Para aprender a crear un clúster gratuito de MongoDB Atlas y cargar los conjuntos de datos de muestra, consulte la guía "Comenzar con Atlas".

Operaciones de inserción

Para especificar una operación de inserción, llame al método insertOne() en su instancia ClientBulkWrite.

El siguiente ejemplo especifica la inserción de documentos en las colecciones sample_restaurants.restaurants y sample_mflix.movies:

$restaurantCollection = $client->sample_restaurants->restaurants;
$movieCollection = $client->sample_mflix->movies;
$bulkWrite = MongoDB\ClientBulkWrite::createWithCollection($restaurantCollection);
$bulkWrite->insertOne(['name' => 'Mongo Deli', 'cuisine' => 'Sandwiches']);
$bulkWrite = $bulkWrite->withCollection($movieCollection);
$bulkWrite->insertOne(['title' => 'The Green Ray', 'year' => 1986]);

Operaciones de actualizar

Para especificar una operación de actualización en el primer documento coincidente, llame al método updateOne() en su instancia ClientBulkWrite.

El siguiente ejemplo especifica una actualización $set del primer documento de la colección sample_restaurants.restaurants que tiene un valor name de 'Dandelion Bakery':

$restaurantCollection = $client->sample_restaurants->restaurants;
$bulkWrite = MongoDB\ClientBulkWrite::createWithCollection($restaurantCollection);
$bulkWrite->updateOne(
    ['name' => 'Dandelion Bakery'],
    ['$set' => ['grade' => 'B+']],
    ['upsert' => true],
);

Para actualizar varios documentos, llame al updateMany() método. La operación especificada actualiza todos los documentos que coinciden con el filtro de consulta.

El siguiente ejemplo especifica una actualización $set para todos los documentos coincidentes en la colección sample_restaurants.restaurants que tengan un valor name de 'Starbucks':

$restaurantCollection = $client->sample_restaurants->restaurants;
$bulkWrite = MongoDB\ClientBulkWrite::createWithCollection($restaurantCollection);
$bulkWrite->updateMany(
    ['name' => 'Starbucks'],
    ['$set' => ['cuisine' => 'Coffee (Chain)']],
);

Reemplazar operaciones

Para especificar una operación de reemplazo en el primer documento coincidente, llame al método replaceOne() en su instancia ClientBulkWrite.

El siguiente ejemplo especifica una operación de reemplazo en el primer documento de la colección sample_restaurants.restaurants que tiene un valor name de 'Dandelion Bakery':

$restaurantCollection = $client->sample_restaurants->restaurants;
$bulkWrite = MongoDB\ClientBulkWrite::createWithCollection($restaurantCollection);
$bulkWrite->replaceOne(
    ['name' => 'Dandelion Bakery'],
    ['name' => 'Flower Patisserie', 'cuisine' => 'Bakery & Cafe'],
);

Operaciones de borrar

Para especificar una operación de eliminación en el primer documento coincidente, llame al método deleteOne() en su instancia ClientBulkWrite.

El siguiente ejemplo especifica la eliminación del primer documento de la colección sample_restaurants.restaurants que tiene un valor borough de 'Queens':

$restaurantCollection = $client->sample_restaurants->restaurants;
$bulkWrite = MongoDB\ClientBulkWrite::createWithCollection($restaurantCollection);
$bulkWrite->deleteOne(
    ['borough' => 'Queens'],
);

Para eliminar varios documentos, llame al deleteMany() método. Esta operación elimina todos los documentos que coinciden con el filtro de consulta.

El siguiente ejemplo especifica la eliminación de todos los documentos de la colección sample_restaurants.restaurants que tengan un valor name que contenga dos caracteres 'p' consecutivos:

$restaurantCollection = $client->sample_restaurants->restaurants;
$bulkWrite = MongoDB\ClientBulkWrite::createWithCollection($restaurantCollection);
$bulkWrite->deleteMany(
    ['name' => ['$regex' => 'p{2,}']],
);

Realizar la operación masiva

Después de construir la instancia ClientBulkWrite para especificar las operaciones de escritura, pásela al método MongoDB\Client::bulkWrite(). De forma predeterminada, estos métodos ejecutan las operaciones en el orden definido al construir ClientBulkWrite.

El siguiente código demuestra cómo utilizar el método bulkWrite() para realizar una operación de escritura masiva en múltiples namespaces:

$restaurantCollection = $client->sample_restaurants->restaurants;
$movieCollection = $client->sample_mflix->movies;
// Creates the bulk write command and sets the target namespace.
$bulkWrite = MongoDB\ClientBulkWrite::createWithCollection($restaurantCollection);
// Specifies insertion of one document.
$bulkWrite->insertOne(['name' => 'Mongo Deli', 'cuisine' => 'Sandwiches']);
// Specifies a `$set` update to one document with the upsert option
// enabled.
$bulkWrite->updateOne(
    ['name' => 'Dandelion Bakery'],
    ['$set' => ['grade' => 'B+']],
    ['upsert' => true],
);
// Changes the target namespace.
$bulkWrite = $bulkWrite->withCollection($movieCollection);
// Specifies insertion of one document.
$bulkWrite->insertOne(['title' => 'The Green Ray', 'year' => 1986]);
// Specifies deletion of documents in which `title` has two consective
// 'd' characters.
$bulkWrite->deleteMany(
    ['title' => ['$regex' => 'd{2,}']],
);
// Specifies replacement of one document.
$bulkWrite->replaceOne(
    ['runtime' => ['$gte' => 200]],
    ['title' => 'Seven Samurai', 'runtime' => 203],
);
// Performs the bulk write operation.
$result = $client->bulkWrite($bulkWrite);
// Prints a summary of results.
echo 'Inserted documents: ', $result->getInsertedCount(), PHP_EOL;
echo 'Modified documents: ', $result->getModifiedCount(), PHP_EOL;
echo 'Deleted documents: ', $result->getDeletedCount(), PHP_EOL;

Inserted documents: 2
Modified documents: 2
Deleted documents: 200

Personalizar escritura masiva

Puede modificar el comportamiento de la operación de escritura masiva del cliente pasando una matriz al constructor ClientBulkWrite que especifique valores de opción como parámetro. La siguiente tabla describe las opciones que puede configurar en la matriz:

El siguiente ejemplo crea una instancia ClientBulkWrite y establece la opción ordered en false:

$bulkWrite = MongoDB\ClientBulkWrite::createWithCollection(
    $restaurantCollection,
    ['ordered' => false],
);

$bulkWrite->insertOne(['_id' => 4045, 'title' => 'The Green Ray']);
$bulkWrite->deleteOne(['_id' => 4045]);

También puede pasar opciones al llamar al método bulkWrite() para especificar la sesión del cliente o la preocupación de escritura a utilizar para la operación.

Valor de retorno

El método MongoDB\Client::bulkWrite() devuelve un objeto MongoDB\BulkWriteCommandResult. Esta clase contiene los siguientes métodos:

Ejemplo

Este ejemplo ejecuta las siguientes operaciones de escritura en la colección restaurants:

• Operación de inserción para insertar un documento en el que el name valor es 'Mongo's Deli'

• Operación de actualización para actualizar el cuisine campo de un documento en el que el name valor es 'Mongo's Deli'

• Operación de eliminación para eliminar todos los documentos en los que el borough valor es 'Manhattan'

$restaurantCollection = $client->sample_restaurants->restaurants;
$result = $restaurantCollection->bulkWrite(
    [
        [
            'insertOne' => [
                ['name' => 'Mongo\'s Deli'],
                ['cuisine' => 'Sandwiches'],
                ['borough' => 'Manhattan'],
                ['restaurant_id' => '1234'],
            ],
        ],
        [
            'updateOne' => [
                ['name' => 'Mongo\'s Deli'],
                ['$set' => ['cuisine' => 'Sandwiches and Salads']],
            ],
        ],
        [
            'deleteMany' => [
                ['borough' => 'Manhattan'],
            ],
        ],
    ],
);

Personalizar la operación de escritura masiva

Puede modificar el comportamiento del método MongoDB\Collection::bulkWrite() al pasar un arreglo que especifique valores de opción como parámetro. La siguiente tabla describe las opciones que puedes establecer en el arreglo:

El siguiente ejemplo llama al método bulkWrite() para realizar una operación de inserción y eliminación y establece la opción ordered en false:

$result = $restaurantCollection->bulkWrite(
    [
        [
            'insertOne' => [
                ['name' => 'Mongo\'s Pizza'],
                ['cuisine' => 'Italian'],
                ['borough' => 'Queens'],
                ['restaurant_id' => '5678'],
            ],
        ],
        [
            'deleteOne' => [
                ['restaurant_id' => '5678'],
            ],
        ],
    ],
    ['ordered' => false],
);

Si la biblioteca ejecuta primero la operación de inserción, se elimina un documento. Si ejecuta primero la operación de eliminación, no se elimina ningún documento.

Valor de retorno

El método MongoDB\Collection::bulkWrite() devuelve un objeto MongoDB\BulkWriteResult. Esta clase contiene los siguientes métodos:

Documentación de la API

Para aprender más sobre cualquiera de los métodos o tipos analizados en esta guía, consulta la siguiente documentación de API:

• Escritura masiva del cliente

  • MongoDB\ClientBulkWrite

  • MongoDB\Client::bulkWrite()

  • MongoDB\BulkWriteCommandResult

• Colección Escritura masiva

  • MongoDB\Collection::bulkWrite()

  • MongoDB\BulkWriteResult