Configurar operações CRUD

Precedência de configurações de leitura e gravação

É possível definir as opções de preocupação de gravação, preocupação de leitura e preferência de leitura nos seguintes níveis:

• transação

• Database

• collection

Esta lista também indica a ordem crescente de precedência das configurações de opção. Por exemplo, se você definir um preocupação de leitura para um banco de dados, ele substituirá as configurações de preocupação de leitura herdadas da transação.

Configuração da transação

As transações são executadas dentro de sessões, que são agrupamentos de operações de leitura ou escrita relacionadas que você pretende executar sequencialmente. Use o start_session() método para obter uma sessão a ser usada para as transações. Em seguida, passe um mongocxx::options::transaction objeto para o with_transaction() método da sessão. Este exemplo mostra como definir a preferência de leitura, preocupação de leitura e preocupação de gravação de uma transação.

O exemplo define as seguintes configurações:

• k_primary preferência de leitura: as operações de leitura recuperam dados do membro primário do conjunto de réplicas.

• k_majority preocupação de leitura: as operações de leitura retornam os dados mais recentes da instância que foram gravados para a maioria dos membros do conjunto de réplicas.

• k_acknowledged preocupação de gravação: o membro primário do conjunto de réplicas deve confirmar a operação de gravação.

auto session = client.start_session();
mongocxx::options::transaction txn_opts;
{
    mongocxx::read_preference rp;
    mongocxx::read_concern rc;
    mongocxx::write_concern wc;
    rp.mode(mongocxx::read_preference::read_mode::k_primary);
    rc.acknowledge_level(mongocxx::read_concern::level::k_majority);
    wc.acknowledge_level(mongocxx::write_concern::level::k_acknowledged);
    txn_opts.read_preference(rp);
    txn_opts.read_concern(rc);
    txn_opts.write_concern(wc);
}
session.with_transaction([&](mongocxx::client_session*) {
    // Specify transaction operations here
}, txn_opts);

Configuração do Banco de Dados

Este exemplo mostra como definir as seguintes configurações de leitura para seu banco de dados:

• k_secondary preferência de leitura: as operações de leitura recuperam dados somente de nós secundários do conjunto de réplicas.

• k_majority preocupação de leitura: as operações de leitura retornam os dados mais recentes da instância que foram gravados para a maioria dos membros do conjunto de réplicas.

auto db = client["test_database"];
mongocxx::read_preference rp;
mongocxx::read_concern rc;
rp.mode(mongocxx::read_preference::read_mode::k_secondary);
rc.acknowledge_level(mongocxx::read_concern::level::k_majority);
db.read_preference(rp);
db.read_concern(rc);

Configuração da Coleção

Este exemplo mostra como especificar as seguintes configurações de read e preocupação de gravação para sua collection:

• k_local preocupação de leitura: as operações de leitura retornam os dados mais recentes da instância, sem garantia de que os dados tenham sido gravados na maioria dos membros do conjunto de réplicas.

• k_acknowledged preocupação de gravação: o membro primário do conjunto de réplicas deve confirmar a operação de gravação.

auto coll = client["test_database"]["test_collection"];
mongocxx::read_concern rc;
mongocxx::write_concern wc;
rc.acknowledge_level(mongocxx::read_concern::level::k_local);
wc.acknowledge_level(mongocxx::write_concern::level::k_acknowledged);
coll.read_concern(rc);
coll.write_concern(wc);

Conjuntos de tags

No MongoDB Server, você pode aplicar marcações de valor-chave a membros do conjunto de réplicas de acordo com qualquer critério de sua escolha. Você pode então usar essas tags para direcionar um ou mais nós para uma operação de leitura.

Por padrão, o driver C++ ignora as marcações ao escolher um membro para ler. Para instruir o driver C++ a preferir determinadas tags, crie um objeto mongocxx::read_preference e chame sua função de membro tags(). Passe suas tags preferidas como argumento de array para tags().

No exemplo de código a seguir, o conjunto de tags passado para a função tags() instrui o driver C++ a preferir leituras do centro de dados de Nova York ("dc": "ny") e a voltar para o centro de dados de São Francisco ("dc": "sf"):

auto tag_set_ny = make_document(kvp("dc", "ny"));
auto tag_set_sf = make_document(kvp("dc", "sf"));
mongocxx::read_preference rp;
rp.mode(mongocxx::read_preference::read_mode::k_secondary);
rp.tags(make_array(tag_set_ny, tag_set_sf).view());

LocalThreshold

O driver C++ usa o valor limite local para calcular a janela de latência para seleção do servidor . Este valor determina os servidores elegíveis para receber solicitações de leitura e gravação.

Por padrão, o driver usa apenas mongos instâncias ou membros do conjunto de réplicas cujos tempos de ping estão dentro de 15 milissegundos do servidor mais próximo. Para distribuir leituras entre servidores com latências mais altas, configure o parâmetro localThreshold em seu URI de conexão.

O exemplo a seguir se conecta a um conjunto de réplicas e especifica um limite local de 35 milissegundos:

mongocxx::uri uri{"mongodb://localhost:27017/?replicaSet=repl0&localThresholdMS=35"};
mongocxx::client client{uri};

No exemplo anterior, o driver C++ distribui leituras entre membros correspondentes dentro de 35 milissegundos do tempo de ping do membro mais próximo.

Exemplo de agrupamento

Considere uma coleção com os seguintes documentos:

{ _id: 1, category: "café" },
{ _id: 2, category: "cafe" },
{ _id: 3, category: "cafE" }

O exemplo a seguir cria um agrupamento que especifica a locale francês e ignora as diferenças entre variantes de maiúsculas e minúsculas. Em seguida, ele usa esse agrupamento para encontrar documentos nos quais o valor de campo category corresponde a "cafe". Devido ao agrupamento especificado, a query retorna todos os três documentos.

mongocxx::options::find opts{};
opts.collation(bsoncxx::from_json(R"({"locale": "fr", "strength": 1})"));
auto cursor = collection.find(make_document(kvp("category", "cafe")), opts);
for(auto&& doc : cursor) {
    std::cout << bsoncxx::to_json(doc) << std::endl;
}

{ "_id": { "$oid" : "1" }, "category": "café" }
{ "_id": { "$oid" : "2" }, "category": "cafe" }
{ "_id": { "$oid" : "3" }, "category": "cafE" }