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 ejemplo de Atlas. Para aprender a crear un clúster gratuito de MongoDB Atlas y cargar los conjuntos de datos de ejemplo, consulte la guía de introducción a MongoDB.

Operaciones de inserción

Para realizar una operación de inserción, cree una instancia InsertOneModel<TDocument> y especifique el documento que desea insertar.

El siguiente ejemplo crea una instancia de la clase InsertOneModel<BsonDocument>. Esta instancia indica al controlador que inserte un documento cuyo campo "name" es "Mongo's Deli" en la colección restaurants.

var insertOneModel = new InsertOneModel<BsonDocument>(
    new BsonDocument{
        { "name", "Mongo's Deli" },
        { "cuisine", "Sandwiches" },
        { "borough", "Manhattan" },
        { "restaurant_id", "1234" }
    }
);

Para insertar varios documentos, cree una instancia de InsertOneModel<TDocument> para cada documento.

Operaciones de actualizar

Para actualizar un solo documento, cree un instancia de UpdateOneModel<TDocument> y pase los siguientes argumentos:

• Filtro de consulta que especifica los criterios utilizados para buscar documentos en su colección. Para obtener más información sobre cómo especificar una consulta, consulte "Operadores de consulta y proyección" en el manual de MongoDB Server.

• Documento de actualización que describe la actualización a realizar. Para obtener más información sobre cómo especificar una actualización, consulte "Operadores de actualización" en el manual de MongoDB Server.

Una UpdateOneModel<TDocument> instancia especifica una actualización para el primer documento que coincide con su filtro de consulta.

En el siguiente ejemplo de código, el objeto UpdateOneModel<BsonDocument> representa una operación de actualización en la colección restaurants. La operación busca el primer documento de la colección cuyo valor del campo name sea "Mongo's Deli". A continuación, actualiza el valor del campo cuisine del documento coincidente a "Sandwiches and Salads".

var updateOneModel = new UpdateOneModel<BsonDocument>(
    Builders<BsonDocument>.Filter.Eq("name", "Mongo's Deli"),
    Builders<BsonDocument>.Update.Set("cuisine", "Sandwiches and Salads")
);

Para actualizar varios documentos, cree una instancia de UpdateManyModel<TDocument> y pase los mismos argumentos que UpdateOneModel<TDocument> para. La UpdateManyModel<TDocument> clase especifica las actualizaciones para todos los documentos que coinciden con su filtro de consulta.

En el siguiente ejemplo de código, el objeto UpdateManyModel<BsonDocument> representa una operación de actualización en la colección restaurants. La operación busca todos los documentos de la colección cuyo valor del campo name sea "Mongo's Deli". A continuación, actualiza el valor del campo cuisine a "Sandwiches and Salads".

var updateManyModel = new UpdateManyModel<BsonDocument>(
    Builders<BsonDocument>.Filter.Eq("name", "Mongo's Deli"),
    Builders<BsonDocument>.Update.Set("cuisine", "Sandwiches and Salads")
);

Reemplazar operaciones

Una operación de reemplazo elimina todos los campos y valores de un documento específico y los reemplaza con los nuevos campos y valores que usted especifique. Para realizar una operación de reemplazo, cree una instancia de ReplaceOneModel<TDocument> y pase un filtro de consulta y los campos y valores con los que desea reemplazar el documento coincidente.

En el siguiente ejemplo, el objeto ReplaceOneModel<BsonDocument> representa una operación de reemplazo en la colección restaurants. La operación busca el documento de la colección cuyo valor del campo restaurant_id es "1234". A continuación, elimina todos los campos excepto _id de este documento y establece nuevos valores en los campos name, cuisine, borough y restaurant_id.

var replaceOneModel = new ReplaceOneModel<BsonDocument>(
    Builders<BsonDocument>.Filter.Eq("restaurant_id", "1234"),
    new BsonDocument{
        { "name", "Mongo's Pizza" },
        { "cuisine", "Pizza" },
        { "borough", "Brooklyn" },
        { "restaurant_id", "5678" }
    }
);

Para reemplazar varios documentos, debe crear una instancia de ReplaceOneModel<TDocument> para cada documento.

Operaciones de borrar

Para borrar un documento, crea una instancia de DeleteOneModel<TDocument> y pasa un filtro de query que especifique el documento que deseas borrar. Una instancia DeleteOneModel<TDocument> proporciona instrucciones para eliminar solo el primer documento que coincida con tu filtro de query.

En el siguiente ejemplo de código, el objeto DeleteOneModel<BsonDocument> representa una operación de eliminación en la colección restaurants. La operación busca y elimina el primer documento cuyo valor del campo restaurant_id sea "5678".

var deleteOneModel = new DeleteOneModel<BsonDocument>(
    Builders<BsonDocument>.Filter.Eq("restaurant_id", "5678")
);

Para eliminar varios documentos, cree una instancia de DeleteManyModel<TDocument> y utilice un filtro de consulta que especifique los documentos que desea eliminar. Una instancia de DeleteManyModel<TDocument> proporciona instrucciones para eliminar todos los documentos que coincidan con su filtro de consulta.

En el siguiente ejemplo de código, el objeto DeleteManyModel<BsonDocument> representa una operación de eliminación en la colección restaurants. La operación busca y elimina todos los documentos cuyo valor del campo name sea "Mongo's Deli".

var deleteManyModel = new DeleteManyModel<BsonDocument>(
    Builders<BsonDocument>.Filter.Eq("name", "Mongo's Deli")
);

Realizar la operación masiva

Después de definir una instancia WriteModel para cada operación que desee realizar, cree una instancia de una clase que implemente la interfaz IEnumerable. Añada sus objetos WriteModel a esta IEnumerable y, a continuación, pase el IEnumerable al método BulkWrite() o BulkWriteAsync(). De forma predeterminada, estos métodos ejecutan las operaciones en el orden en que se definen en la lista.

Selecciona de las siguientes pestañas para ver cómo usar el método sincrónico BulkWrite() y el método asincrónico BulkWriteAsync() para realizar una operación de escritura masiva en la colección restaurants:

var models = new List<WriteModel<BsonDocument>>
{
    new InsertOneModel<BsonDocument>(
        new BsonDocument{
            { "name", "Mongo's Deli" },
            { "cuisine", "Sandwiches" },
            { "borough", "Manhattan" },
            { "restaurant_id", "1234" }
        }
    ),
    new InsertOneModel<BsonDocument>(
        new BsonDocument{
            { "name", "Mongo's Deli" },
            { "cuisine", "Sandwiches" },
            { "borough", "Brooklyn" },
            { "restaurant_id", "5678" }
        }
    ),
    new UpdateManyModel<BsonDocument>(
        Builders<BsonDocument>.Filter.Eq("name", "Mongo's Deli"),
        Builders<BsonDocument>.Update.Set("cuisine", "Sandwiches and Salads")
    ),
    new DeleteOneModel<BsonDocument>(
        Builders<BsonDocument>.Filter.Eq("restaurant_id", "1234")
    )
};
var results = collection.BulkWrite(models);
Console.WriteLine(results);

var models = new List<WriteModel<BsonDocument>>
{
    new InsertOneModel<BsonDocument>(
        new BsonDocument{
            { "name", "Mongo's Deli" },
            { "cuisine", "Sandwiches" },
            { "borough", "Manhattan" },
            { "restaurant_id", "1234" }
        }
    ),
    new InsertOneModel<BsonDocument>(
        new BsonDocument{
            { "name", "Mongo's Deli" },
            { "cuisine", "Sandwiches" },
            { "borough", "Brooklyn" },
            { "restaurant_id", "5678" }
        }
    ),
    new UpdateManyModel<BsonDocument>(
        Builders<BsonDocument>.Filter.Eq("name", "Mongo's Deli"),
        Builders<BsonDocument>.Update.Set("cuisine", "Sandwiches and Salads")
    ),
    new DeleteOneModel<BsonDocument>(
        Builders<BsonDocument>.Filter.Eq("restaurant_id", "1234")
    )
};
var results = await collection.BulkWriteAsync(models);
Console.WriteLine(results);

Los ejemplos de código anteriores producen el siguiente resultado:

MongoDB.Driver.BulkWriteResult1+Acknowledged[MongoDB.Bson.BsonDocument]

Personalizar la operación de escritura masiva

Al llamar al método BulkWrite() o BulkWriteAsync(), se puede pasar una instancia de la clase BulkWriteOptions. La clase BulkWriteOptions contiene las siguientes propiedades, que representan opciones que se pueden usar para configurar la operación de escritura masiva:

Los siguientes ejemplos de código utilizan un objeto BulkWriteOptions para realizar una operación de escritura masiva desordenada:

var models = new List<WriteModel<BsonDocument>>
{
new DeleteOneModel<BsonDocument>(
    Builders<BsonDocument>.Filter.Eq("restaurant_id", "5678")
)
};
var options = new BulkWriteOptions
{
    IsOrdered = false,
};
collection.BulkWrite(models, options);

var models = new List<WriteModel<BsonDocument>>
{
new DeleteOneModel<BsonDocument>(
    Builders<BsonDocument>.Filter.Eq("restaurant_id", "5678")
)
};
var options = new BulkWriteOptions
{
    IsOrdered = false,
};
await collection.BulkWriteAsync(models, options);

Valor de retorno

Los métodos BulkWrite() y BulkWriteAsync() devuelven un objeto BulkWriteResult que contiene las siguientes propiedades:

Manejo de excepciones

Si alguna de las operaciones en una operación de escritura masiva falla, el controlador .NET/C# lanza un BulkWriteError y no realiza ninguna operación adicional.

Un objeto BulkWriteError contiene la propiedad Index que describe el índice de la solicitud que resultó en un error.

Operaciones de inserción

Para realizar una operación de inserción, cree una instancia de la clase BulkWriteInsertOneModel<TDocument>. El constructor BulkWriteInsertOneModel<TDocument> acepta los siguientes parámetros:

El siguiente ejemplo crea instancias de la clase BulkWriteInsertOneModel<TDocument>. Estas instancias indican al controlador que inserte documentos en las colecciones sample_restaurants.restaurants y sample_mflix.movies.

var restaurantToInsert = new BulkWriteInsertOneModel<BsonDocument>(
    "sample_restaurants.restaurants",
    new BsonDocument{
        { "name", "Mongo's Deli" },
        { "cuisine", "Sandwiches" },
        { "borough", "Manhattan" },
        { "restaurant_id", "1234" }
    }
);
var movieToInsert = new BulkWriteInsertOneModel<BsonDocument>(
    "sample_mflix.movies",
    new BsonDocument{
        { "title", "Silly Days" },
        { "year", 2022 }
    }
);

Operaciones de actualizar

Para actualizar un solo documento, cree una instancia de la clase BulkWriteUpdateOneModel<TDocument>. El constructor BulkWriteUpdateOneModel<TDocument> acepta los siguientes parámetros:

En el siguiente ejemplo de código, los objetos BulkWriteUpdateOneModel<BsonDocument> representan operaciones de actualización en las colecciones sample_restaurants.restaurants y sample_mflix.movies.

var restaurantUpdate = new BulkWriteUpdateOneModel<BsonDocument>(
    "sample_restaurants.restaurants",
    Builders<BsonDocument>.Filter.Eq("name", "Mongo's Deli"),
    Builders<BsonDocument>.Update.Set("cuisine", "Sandwiches and Salads")
);
var movieUpdate = new BulkWriteUpdateOneModel<BsonDocument>(
    "sample_mflix.movies",
    Builders<BsonDocument>.Filter.Eq("title", "Carrie"),
    Builders<BsonDocument>.Update.Set("seen", True)
);

Para actualizar varios documentos, cree una instancia de la BulkWriteUpdateManyModel<TDocument> clase. El constructor de esta clase acepta los mismos parámetros que el BulkWriteUpdateOneModel<TDocument> constructor. La BulkWriteUpdateManyModel<TDocument> operación actualiza todos los documentos que coinciden con el filtro de consulta.

En el siguiente ejemplo de código, el objeto BulkWriteUpdateManyModel<BsonDocument> representa una operación de actualización en la colección sample_restaurants.restaurants. La operación busca todos los documentos de la colección cuyo valor del campo name sea "Starbucks". A continuación, actualiza el valor del campo cuisine a "Coffee (Chain)".

var updateManyModel = new BulkWriteUpdateManyModel<BsonDocument>(
    "sample_restaurants.restaurants",
    Builders<BsonDocument>.Filter.Eq("name", "Starbucks"),
    Builders<BsonDocument>.Update.Set("cuisine", "Coffee (Chain)")
);

Reemplazar operaciones

Para reemplazar los campos de un documento, cree una instancia de la clase BulkWriteReplaceOneModel<TDocument>. El constructor BulkWriteReplaceOneModel<TDocument> acepta los siguientes parámetros:

En el siguiente ejemplo, los objetos BulkWriteReplaceOneModel<BsonDocument> representan operaciones de reemplazo en las colecciones sample_restaurants.restaurants y sample_mflix.movies.

var restaurantReplacement = new BulkWriteReplaceOneModel<BsonDocument>(
    "sample_restaurants.restaurants",
    Builders<BsonDocument>.Filter.Eq("restaurant_id", "1234"),
    new BsonDocument{
        { "name", "Mongo's Pizza" },
        { "cuisine", "Pizza" },
        { "borough", "Brooklyn" },
        { "restaurant_id", "5678" }
    }
);
var movieReplacement = new BulkWriteReplaceOneModel<BsonDocument>(
    "sample_mflix.movies",
    Builders<BsonDocument>.Filter.Eq("title", "Insomnia"),
    new BsonDocument{
        { "name", "Loving Sylvie" },
        { "year", 1999 }
    }
);

Operaciones de borrar

Para eliminar un documento, cree una instancia de la clase BulkWriteDeleteOneModel<TDocument>. El constructor BulkWriteDeleteOneModel<TDocument> acepta los siguientes parámetros:

En el siguiente ejemplo de código, los objetos BulkWriteDeleteOneModel<BsonDocument> representan operaciones de eliminación en las colecciones sample_restaurants.restaurants y sample_mflix.movies.

var restaurantToDelete = new BulkWriteDeleteOneModel<BsonDocument>(
    "sample_restaurants.restaurants",
    Builders<BsonDocument>.Filter.Eq("restaurant_id", "5678")
);
var movieToDelete = new BulkWriteDeleteOneModel<BsonDocument>(
    "sample_mflix.movies",
    Builders<BsonDocument>.Filter.Eq("title", "Mr. Nobody")
);

Para eliminar múltiples documentos, crea una instancia de la clase BulkWriteDeleteManyModel<TDocument> y pasa un filtro de query que especifique el documento que deseas eliminar. La DeleteMany remueve todos los documentos que coinciden con el filtro de query.

En el siguiente ejemplo de código, el objeto BulkWriteDeleteManyModel<BsonDocument> representa una operación de eliminación en la colección sample_restaurants.restaurants. La operación busca y elimina todos los documentos cuyo valor del campo name sea "Mongo's Deli".

var deleteManyModel = new BulkWriteDeleteManyModel<BsonDocument>(
    "sample_restaurants.restaurants",
    Builders<BsonDocument>.Filter.Eq("name", "Mongo's Deli")
);

Realizar la operación masiva

Después de definir una instancia BulkWriteModel para cada operación que desee realizar, cree una instancia de una clase que implemente la interfaz IReadOnlyList. Añada sus objetos BulkWriteModel a esta IReadOnlyList y, a continuación, pase el IReadOnlyList al método BulkWrite() o BulkWriteAsync(). De forma predeterminada, estos métodos ejecutan las operaciones en el orden en que se definen en la colección.

Seleccione una de las siguientes pestañas para ver cómo utilizar el método sincrónico BulkWrite() y el método asincrónico BulkWriteAsync() para realizar una operación de escritura masiva en múltiples espacios de nombres.

var client = new MongoClient("mongodb://localhost:27017");
var restaurantNamespace = "sample_restaurants.restaurants";
var movieNamespace = "sample_mflix.movies";
var bulkWriteModels = new[]
{
    new BulkWriteInsertOneModel<BsonDocument>(
        restaurantNamespace,
        new BsonDocument{
            { "name", "Mongo's Deli" },
            { "cuisine", "Sandwiches" },
            { "borough", "Manhattan" },
            { "restaurant_id", "1234" }
        }
    ),
    new BulkWriteInsertOneModel<BsonDocument>(
        movieNamespace,
        new BsonDocument{
            { "name", "Sarah's Secret" },
            { "year", 1988 }
        }
    ),
    new BulkWriteUpdateManyModel<BsonDocument>(
        restaurantNamespace,
        Builders<BsonDocument>.Filter.Eq("name", "Mongo's Deli"),
        Builders<BsonDocument>.Update.Set("cuisine", "Sandwiches and Salads")
    ),
    new BulkWriteDeleteOneModel<BsonDocument>(
        movieNamespace,
        Builders<BsonDocument>.Filter.Eq("title", "House")
    )
};
var result = client.BulkWrite(bulkWriteModels);
Console.WriteLine(result);

var client = new MongoClient("mongodb://localhost:27017");
var restaurantNamespace = "sample_restaurants.restaurants";
var movieNamespace = "sample_mflix.movies";
var bulkWriteModels = new[]
{
    new BulkWriteInsertOneModel<BsonDocument>(
        restaurantNamespace,
        new BsonDocument{
            { "name", "Mongo's Deli" },
            { "cuisine", "Sandwiches" },
            { "borough", "Manhattan" },
            { "restaurant_id", "1234" }
        }
    ),
    new BulkWriteInsertOneModel<BsonDocument>(
        movieNamespace,
        new BsonDocument{
            { "name", "Sarah's Secret" },
            { "year", 1988 }
        }
    ),
    new BulkWriteUpdateManyModel<BsonDocument>(
        restaurantNamespace,
        Builders<BsonDocument>.Filter.Eq("name", "Mongo's Deli"),
        Builders<BsonDocument>.Update.Set("cuisine", "Sandwiches and Salads")
    ),
    new BulkWriteDeleteOneModel<BsonDocument>(
        movieNamespace,
        Builders<BsonDocument>.Filter.Eq("title", "House")
    )
};
var result = await client.BulkWriteAsync(bulkWriteModels);
Console.WriteLine(result);

Los ejemplos de código anteriores producen el siguiente resultado:

BulkWriteResult({'writeErrors': [], 'writeConcernErrors': [], 'nInserted': 2, 'nUpserted': 0, 'nMatched': 2, 'nModified': 2, 'nRemoved': 1, 'upserted': []}, acknowledged=True)

Personalizar escritura masiva

Al llamar al método BulkWrite() o BulkWriteAsync(), se puede pasar una instancia de la clase ClientBulkWriteOptions. La clase ClientBulkWriteOptions contiene las siguientes propiedades, que representan opciones que se pueden usar para configurar la operación de escritura masiva:

Los siguientes ejemplos de código utilizan un objeto ClientBulkWriteOptions para personalizar la operación de escritura masiva:

var client = new MongoClient("mongodb://localhost:27017");
var deleteOneModel = new BulkWriteDeleteOneModel<BsonDocument>(
    "sample_restaurants.restaurants",
    Builders<BsonDocument>.Filter.Eq("restaurant_id", "5678")
);
var clientBulkWriteOptions = new ClientBulkWriteOptions
{
    IsOrdered = false,
    WriteConcern = WriteConcern.Unacknowledged,
    VerboseResult = true
};
var result = client.BulkWrite(deleteOneModel, clientBulkWriteOptions);

var client = new MongoClient("mongodb://localhost:27017");
var deleteOneModel = new BulkWriteDeleteOneModel<BsonDocument>(
    "sample_restaurants.restaurants",
    Builders<BsonDocument>.Filter.Eq("restaurant_id", "5678")
);
var clientBulkWriteOptions = new ClientBulkWriteOptions
{
    IsOrdered = false,
    WriteConcern = WriteConcern.Unacknowledged,
    VerboseResult = true
};
var result = await client.BulkWriteAsync(deleteOneModel, clientBulkWriteOptions);

Valor de retorno

Los métodos BulkWrite() y BulkWriteAsync() devuelven un objeto ClientBulkWriteResult que contiene las siguientes propiedades:

Manejo de excepciones

Si alguna de las operaciones en una operación de escritura masiva falla, el controlador .NET/C# lanza un ClientBulkWriteException y no realiza ninguna operación adicional.

Un objeto ClientBulkWriteException contiene las siguientes propiedades:

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:

• Colección Escritura masiva

  • Escritura masiva()

  • BulkWriteAsync()

  • Opciones de escritura masiva

  • BulkWriteResult

  • InsertOneModel

  • UpdateOneModel

  • ActualizarMuchosModelos

  • ReemplazarUnModelo

  • Eliminar un modelo

  • EliminarMuchosModelos

  • Error de escritura masiva

• Escritura masiva del cliente

  • Escritura masiva()

  • BulkWriteAsync()

  • ClientBulkWriteOptions

  • Resultado de escritura masiva del cliente

  • Escritura masivaInsertarUnModelo

  • BulkWriteUpdateOneModel

  • Escritura masivaActualizarMuchos modelos

  • Escritura masivaReemplazarUnModelo

  • Escritura masiva para eliminar un modelo

  • Escritura masivaEliminarMuchosModelos

  • Escritura masivaInsertarUnResultado

  • BulkWriteUpdateResult

  • Resultado de eliminación de escritura masiva

  • Excepción de escritura masiva del cliente