CRUD 작업 구성

읽기 및 쓰기 설정 우선 순위

다음 수준에서 쓰기 고려, 읽기 고려, 읽기 설정 옵션을 설정할 수 있습니다.

• 트랜잭션

• Database

• 컬렉션

이 목록은 옵션 설정의 우선 순위가 높아지는 순서도 나타냅니다. 예시 를 들어, 데이터베이스 에 대해 읽기 고려 (read concern) 설정하다 하면 트랜잭션 에서 상속된 읽기 고려 (read concern) 설정이 재정의됩니다.

트랜잭션 구성

트랜잭션은 세션 내에서 순차적으로 실행 하려는 관련 읽기 또는 쓰기 (write) 작업의 그룹인 세션 내에서 실행 . start_session() 메서드를 사용하여 트랜잭션에 사용할 세션을 가져옵니다. 그런 다음 mongocxx::options::transaction 객체 세션의 with_transaction() 메서드에 전달합니다. 이 예시 트랜잭션 의 읽기 설정 (read preference), 읽기 고려 (read concern)) 및 쓰기 고려 (write concern) 설정하다 방법을 보여줍니다.

이 예시 다음 설정을 구성합니다.

• k_primary 읽기 설정 (read preference) : 읽기 작업은 프라이머리 복제본 세트 멤버에서 데이터를 조회 .

• k_majority 읽기 고려 (read concern): 읽기 작업은 대부분의 복제본 세트 멤버에 기록된 인스턴스의 가장 최근 데이터를 반환합니다.

• k_acknowledged 쓰기 고려 (write concern): 프라이머리 복제본 세트 멤버는 쓰기 (write) 작업을 확인해야 합니다.

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

데이터베이스 구성

이 예시 데이터베이스 에 대해 다음 읽기 설정을 구성하는 방법을 보여 줍니다.

• k_secondary 읽기 설정 (read preference) : 읽기 작업은 세컨더리 복제본 세트 멤버에서만 데이터를 조회 .

• k_majority 읽기 고려 (read concern): 읽기 작업은 대부분의 복제본 세트 멤버에 기록된 인스턴스의 가장 최근 데이터를 반환합니다.

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

collection 구성

이 예시 컬렉션 에 대해 다음과 같은 읽기 및 쓰기 고려 (write concern) 설정을 지정하는 방법을 보여 줍니다.

• k_local 읽기 고려 (read concern): 읽기 작업은 인스턴스의 가장 최근 데이터를 반환하며, 데이터가 대부분의 복제본 세트 멤버에 기록되었다는 보장은 없습니다.

• k_acknowledged 쓰기 고려 (write concern): 프라이머리 복제본 세트 멤버는 쓰기 (write) 작업을 확인해야 합니다.

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

태그 세트

MongoDB Server 에서는 선택한 기준에 따라 복제본 세트 멤버에 키-값 태그를 적용 할 수 있습니다. 그런 다음 해당 태그를 사용하여 읽기 작업의 멤버를 한 명 이상 대상으로 지정할 수 있습니다.

기본값 으로 C++ 운전자 읽을 멤버를 선택할 때 태그를 무시합니다. C++ 운전자 특정 태그를 선호하도록 하려면 mongocxx::read_preference 객체 만들고 해당 tags() 멤버 함수를 호출합니다. 원하는 태그를 배열 인수로 tags()에 전달합니다.

다음 코드 예시 에서 tags() 함수에 전달된 태그 세트 C++ 운전자 뉴욕 데이터 센터 ("dc": "ny")에서 읽기를 선호하고 샌프란시스코 데이터 센터 ("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

C++ 운전자 로컬 임계값을 사용하여 서버 선택에 대한 지연 시간 창 계산합니다. 이 값은 읽기 및 쓰기 (write) 요청을 수신할 수 있는 서버를 결정합니다.

기본값 으로 운전자 핑 시간이 가장 가까운 서버 에서 15 밀리초 이내인 mongos 인스턴스 또는 복제본 세트 멤버만 사용합니다. 지연 시간이 더 긴 서버에 읽기를 분산하려면 연결 URI에서 localThreshold 매개 변수를 설정하다 .

다음 예시 에서는 복제본 세트 에 연결하고 로컬 임계값을 35 밀리초로 지정합니다.

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

앞의 예시 에서 C++ 드라이버 가장 가까운 노드의 핑 시간 35 밀리초 이내에 일치하는 노드에게 읽기를 분산합니다.

데이터 정렬 예시

다음 문서가 포함된 컬렉션 생각해 보세요.

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

다음 예시 프랑스어 국가 및 언어 설정 설정을 지정하고 대소문자와 문자 변형 간의 차이를 무시하는 데이터 정렬을 만듭니다. 그런 다음 이 데이터 정렬을 사용하여 category 필드 값이 "cafe"와 일치하는 문서를 찾습니다. 지정된 데이터 정렬로 인해 쿼리 세 개의 문서를 모두 반환합니다.

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" }