Configurar las operaciones CRUD

Prioridad de configuración de lectura y guardado

Puedes establecer las opciones de nivel de confirmación de escritura (write concern), nivel de consistencia de lectura y preferencia de lectura en los siguientes niveles:

• transacción

• Database

• Colección

Esta lista también indica el orden creciente de prioridad de las configuraciones de opciones. Por ejemplo, si configuras un nivel de consistencia de lectura para una base de datos, esta sobrescribirá las configuraciones de nivel de consistencia de lectura heredadas de la transacción.

Configuración de transacciones

Las transacciones se ejecutan dentro de sesiones, que son agrupaciones de operaciones de lectura o escritura relacionadas que se pretende ejecutar de forma secuencial. Utilice el start_session() método para obtener una sesión para usar en las transacciones. Luego, pasa un objeto mongocxx::options::transaction al método with_transaction() de la sesión. Este ejemplo muestra cómo establecer la preferencia de lectura, el nivel de consistencia de lectura y el nivel de confirmación de escritura (write concern) de una transacción.

El ejemplo configura los siguientes ajustes:

• k_primary preferencia de lectura: Las operaciones de lectura recuperan los datos del miembro primario del set de réplicas.

• k_majority nivel de consistencia de lectura: Las operaciones de lectura devuelven los datos más recientes de la instancia que se han escrito en la mayoría de los miembros del set de réplicas.

• k_acknowledged nivel de confirmación de escritura (write concern): El miembro primario del conjunto de réplicas debe acuse de recibo de la operación de escritura.

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);

Configuración de la base de datos

Este ejemplo muestra cómo configurar los siguientes ajustes de lectura para tu base de datos:

• k_secondary preferencia de lectura: Las operaciones de lectura recuperan datos solo de los miembros secundarios del set de réplicas.

• k_majority nivel de consistencia de lectura: Las operaciones de lectura devuelven los datos más recientes de la instancia que se han escrito en la mayoría de los miembros del set 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);

Configuración de la colección

Este ejemplo muestra cómo especificar los siguientes ajustes de nivel de confirmación de escritura (write concern) y lectura para tu colección:

• k_local nivel de consistencia de lectura: las operaciones de lectura devuelven los datos más recientes de la instancia, sin garantía de que los datos hayan sido escritos en la mayoría de los miembros del set de réplicas.

• k_acknowledged nivel de confirmación de escritura (write concern): El miembro primario del conjunto de réplicas debe acuse de recibo de la operación de escritura.

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 etiquetas

En el MongoDB Server, puedes aplicar etiquetas clave-valor a los miembros del conjunto de réplicas según los criterios que elijas. Luego, puede usar esas etiquetas para dirigir una operación de lectura a uno o más nodos.

Por defecto, el driver de C++ ignora las etiquetas al elegir el nodo desde el cual leer. Para indicar al controlador de C++ que prefiera ciertas etiquetas, crea un objeto mongocxx::read_preference y llama a su función de nodo tags(). Pasa tus etiquetas preferidas como argumento de arreglo a tags().

En el siguiente ejemplo de código, el conjunto de etiquetas pasado a la función tags() instruye al driver de C++ para que prefiera las lecturas desde el centro de datos de Nueva York ("dc": "ny") y que, en caso de no estar disponible, recurra al centro de datos de San 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());

Umbral local

El controlador de C++ usa el valor de umbral local para calcular la ventana de latencia para la selección del servidor. Este valor determina los servidores que son elegibles para recibir solicitudes de lectura y guardado.

De forma predeterminada, el driver utiliza únicamente mongos instancias o miembros del set de réplicas cuyos tiempos de ping están dentro de 15 milisegundos del servidor más cercano. Para distribuir lecturas entre servidores con latencias más altas, establece el parámetro localThreshold en tu URI de conexión.

El siguiente ejemplo se conecta a un set de réplicas y especifica un umbral local de 35 milisegundos:

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

En el ejemplo anterior, el driver de C++ distribuye las lecturas entre los nodos que coinciden dentro de 35 milisegundos del tiempo de ping del nodo más cercano.

Ejemplo de intercalación

Considera una colección con los siguientes documentos:

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

El siguiente ejemplo crea una intercalación que especifica la localización francesa e ignora las diferencias entre variantes de mayúsculas, minúsculas y letras. Luego utiliza esta intercalación para encontrar documentos en los que el valor del campo category coincide con "cafe". Debido a la intercalación especificada, la query devuelve los tres 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" }