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 funções individuais, cada operação exigirá sua própria chamada de banco de dados de dados. Em vez disso, você pode usar uma operação em massa para reduzir o número de chamadas para o banco de dados de dados.

Iniciar a operação de gravação em massa

Antes de executar uma operação de gravação em massa, chame a função mongoc_collection_create_bulk_operation_with_opts(). Esta função retorna um valor do tipo mongoc_bulk_operation_t que você pode usar para armazenar instruções sobre quais gravações em massa devem ser executadas.

A função mongoc_collection_create_bulk_operation_with_opts() aceita os seguintes parâmetros:

• Collection: especifica a collection a ser modificada

• documento de opções : especifica opções para personalizar a operação ou NULL

O exemplo a seguir chama a função mongoc_collection_create_bulk_operation_with_opts() e passa a coleção restaurants como um parâmetro:

mongoc_bulk_operation_t *bulk =
   mongoc_collection_create_bulk_operation_with_opts (collection, NULL);

Em seguida, você pode adicionar instruções de escrita à operação em massa. Para obter mais informações, consulte a seguinte seção Definir as operações de gravação .

Definir as operações de gravação

Você pode definir uma operação de gravação e adicioná-la à gravação em massa ligando para os seguintes métodos:

• mongoc_bulk_operation_insert_with_opts()

• mongoc_bulk_operation_update_one_with_opts()

• mongoc_bulk_operation_update_many_with_opts()

• mongoc_bulk_operation_replace_one_with_opts()

• mongoc_bulk_operation_remove_one_with_opts()

• mongoc_bulk_operation_remove_many_with_opts()

As seções a seguir mostram como usar esses métodos para especificar suas operações de gravação correspondentes.

bson_t *insert_doc = BCON_NEW (
    "name", BCON_UTF8 ("Mongo's Deli"),
    "cuisine", BCON_UTF8 ("Sandwiches"),
    "borough", BCON_UTF8 ("Manhattan"),
    "restaurant_id", BCON_UTF8 ("1234")
);
bson_error_t error;
if (!mongoc_bulk_operation_insert_with_opts (bulk, insert_doc, NULL, &error)) {
    fprintf (stderr, "Failed to add insert operation: %s\n", error.message);
}
bson_destroy (insert_doc);

bson_t *filter_doc = BCON_NEW ("name", BCON_UTF8 ("Mongo's Deli"));
bson_t *update_doc = BCON_NEW ("$set", "{", "cuisine", BCON_UTF8 ("Sandwiches and Salads"), "}");
bson_error_t error;
if (!mongoc_bulk_operation_update_one_with_opts (bulk, filter_doc, update_doc, NULL, &error)) {
    fprintf (stderr, "Failed to add update operation: %s\n", error.message);
}
bson_destroy (filter_doc);
bson_destroy (update_doc);

bson_t *filter_doc = BCON_NEW ("name", BCON_UTF8 ("Mongo's Deli"));
bson_t *update_doc = BCON_NEW ("$set", "{", "cuisine", BCON_UTF8 ("Sandwiches and Salads"), "}");
bson_error_t error;
if (!mongoc_bulk_operation_update_many_with_opts (bulk, filter_doc, update_doc, NULL, &error)) {
    fprintf (stderr, "Failed to add update operation: %s\n", error.message);
}
bson_destroy (filter_doc);
bson_destroy (update_doc);

bson_t *filter_doc = BCON_NEW ("restaurant_id", BCON_UTF8 ("1234"));
bson_t *replace_doc = BCON_NEW (
    "name", BCON_UTF8 ("Mongo's Deli"),
    "cuisine", BCON_UTF8 ("Sandwiches and Salads"),
    "borough", BCON_UTF8 ("Brooklyn"),
    "restaurant_id", BCON_UTF8 ("5678")
);
bson_error_t error;
if (!mongoc_bulk_operation_replace_one_with_opts (bulk, filter_doc, replace_doc, NULL, &error)) {
    fprintf (stderr, "Failed to add replace operation: %s\n", error.message);
}
bson_destroy (filter_doc);
bson_destroy (replace_doc);

bson_t *filter_doc = BCON_NEW ("restaurant_id", BCON_UTF8 ("5678"));
bson_error_t error;
if (!mongoc_bulk_operation_remove_one_with_opts (bulk, filter_doc, NULL, &error)) {
    fprintf (stderr, "Failed to add delete operation: %s\n", error.message);
}
bson_destroy (filter_doc);

bson_t *filter_doc = BCON_NEW ("borough", BCON_UTF8 ("Manhattan"));
bson_error_t error;
if (!mongoc_bulk_operation_remove_many_with_opts (bulk, filter_doc, NULL, &error)) {
    fprintf (stderr, "Failed to add delete operation: %s\n", error.message);
}
bson_destroy (filter_doc);

Executar a operação em massa

Para executar cada operação de gravação enfileirada na gravação em massa, chame a função mongoc_bulk_operation_execute(). Esta função aceita os seguintes parâmetros:

• valor mongoc_bulk_operation_t: contém as instruções para cada operação de gravação

• Localização dos resultados: especifica um ponteiro para o armazenamento substituível que conterá os resultados da operação ou NULL

• Local do erro: especifica um local para um valor de erro ou NULL

O exemplo a seguir executa as operações de inserção, atualização, substituição e exclusão especificadas nas seções anteriores deste guia chamando a mongoc_bulk_operation_execute() função:

bson_error_t error;
bool result = mongoc_bulk_operation_execute (bulk, NULL, &error);
if (!result) {
    printf ("Bulk operation error: %s\n", error.message);
}
mongoc_bulk_operation_destroy (bulk);

Se qualquer uma das operações de gravação falhar, o driver C definirá o erro de saída e não executará mais nenhuma operação.

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

Você pode modificar o comportamento da função mongoc_collection_create_bulk_operation_with_opts() passando um documento BSON que especifica os valores das opções. A tabela a seguir descreve as opções que você pode definir no documento:

O exemplo a seguir chama a função mongoc_collection_create_bulk_operation_with_opts() e define a opção ordered como false:

bson_t opts;
BSON_APPEND_BOOL (&opts, "ordered", false);
bulk = mongoc_collection_create_bulk_operation_with_opts (collection, &opts);
// Perform bulk operation
bson_destroy (&opts);
mongoc_bulk_operation_destroy (bulk);

Se qualquer uma das operações de gravação em uma gravação em massa não ordenada falhar, o driver C 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

• Exclua documentos

• Substituir documentos