Docs Menu
Docs Home
/ / /
C 드라이버
/

대량 쓰기 작업

이 페이지의 내용

  • 개요
  • 샘플 데이터
  • 대량 쓰기 작업 시작
  • 쓰기 작업 정의
  • 삽입 작업
  • 업데이트 작업
  • 대체 작업
  • 삭제 작업
  • 대량 작업 실행
  • 대량 쓰기 작업 사용자 지정
  • 추가 정보
  • API 문서

이 가이드 에서는 대량 쓰기 (write) 작업 을 사용하여 단일 데이터베이스 호출에서 여러 쓰기 (write) 작업을 수행하는 방법에 학습 설명합니다.

컬렉션 에 문서 를 삽입하고 다른 여러 문서를 업데이트 한 다음 문서 를 삭제 하려는 시나리오를 가정해 보겠습니다. 개별 함수를 사용하는 경우 각 작업에는 자체 데이터베이스 호출이 필요합니다. 대신 대량 작업을 사용하여 데이터베이스 에 대한 호출 수를 줄일 수 있습니다.

이 가이드 의 예제에서는 Atlas 샘플 데이터 세트sample_restaurants 데이터베이스 에 있는 restaurants 컬렉션 을 사용합니다. 무료 MongoDB Atlas cluster 를 생성하고 샘플 데이터 세트를 로드하는 방법을 학습 보려면 Atlas 시작하기 가이드 를 참조하세요.

대량 쓰기 (write) 작업을 실행 하기 전에 mongoc_collection_create_bulk_operation_with_opts() 함수를 호출합니다. 이 함수는 수행할 대량 쓰기에 대한 지침을 저장 하는 데 사용할 수 있는 mongoc_bulk_operation_t 유형의 값을 반환합니다.

mongoc_collection_create_bulk_operation_with_opts() 함수는 다음 매개변수를 허용합니다.

  • Collection: 수정할 컬렉션 을 지정합니다.

  • 옵션 문서: 작업을 사용자 지정하는 옵션을 지정하거나 NULL

다음 예시 에서는 mongoc_collection_create_bulk_operation_with_opts() 함수를 호출하고 restaurants 컬렉션 을 매개 변수로 전달합니다.

mongoc_bulk_operation_t *bulk =
mongoc_collection_create_bulk_operation_with_opts (collection, NULL);

그런 다음 대량 작업에 쓰기 (write) 지침을 추가할 수 있습니다.자세한 내용은 다음 쓰기 작업 정의 섹션을 참조하세요.

다음 메서드를 호출하여 쓰기 (write) 작업을 정의하고 대량 쓰기 (write) 에 추가할 수 있습니다.

  • 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()

다음 섹션에서는 이러한 메서드를 사용하여 해당 쓰기 (write) 작업을 지정하는 방법을 보여 줍니다.

삽입 작업을 수행하려면 대량 쓰기 (write) 의 일부로 작업을 대기열에 추가하는 mongoc_bulk_operation_t 에 삽입 지침을 추가합니다.

다음 예시 에서는 mongoc_bulk_operation_insert_with_opts() 함수를 호출하여 삽입할 문서 와 mongoc_bulk_operation_t 값을 매개변수로 전달합니다.

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

여러 문서를 삽입하려면 각 문서 에 대해 mongoc_bulk_operation_insert_with_opts() 를 호출합니다.

업데이트 작업을 수행하려면 대량 쓰기 (write) 의 일부로 작업을 대기열에 추가하는 mongoc_bulk_operation_t 에 업데이트 지침을 추가합니다.

다음 예시 에서는 mongoc_bulk_operation_update_one_with_opts() 함수를 호출하여 쿼리 필터하다, 문서 업데이트 및 mongoc_bulk_operation_t 값을 매개변수로 전달합니다.

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

여러 문서를 업데이트 하려면 를 호출하고 mongoc_bulk_operation_update_many_with_opts() 동일한 매개변수를 전달합니다. 이렇게 하면 운전자 가 쿼리 필터하다 와 일치하는 모든 문서를 업데이트 하도록 지시합니다.

다음 예시 에서는 대량 쓰기 (write) 작업에 대한 업데이트 작업을 대기열에 추가합니다.

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

바꾸기 작업은 지정된 문서 의 모든 필드와 값을 제거하고 새 항목으로 바꿉니다. 교체 작업을 수행하려면 대량 쓰기 (write) 의 일부로 작업을 대기열에 추가하는 mongoc_bulk_operation_t 에 교체 지침을 추가합니다.

다음 예시 에서는 mongoc_bulk_operation_replace_one_with_opts() 함수를 호출하여 쿼리 필터하다, 대체 문서 및 mongoc_bulk_operation_t 값을 매개변수로 전달합니다.

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

여러 문서를 바꾸려면 각 문서 에 대해 mongoc_bulk_operation_replace_one_with_opts() 를 호출합니다.

삭제 작업을 수행하려면 대량 쓰기 (write) 의 일부로 작업을 대기열에 추가하는 mongoc_bulk_operation_t 에 삭제 지침을 추가합니다.

다음 예시 에서는 mongoc_bulk_operation_remove_one_with_opts() 함수를 호출하여 쿼리 필터하다 와 mongoc_bulk_operation_t 값을 매개변수로 전달합니다.

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

여러 문서를 삭제 하려면 mongoc_bulk_operation_remove_many_with_opts() 함수를 호출하고 동일한 매개변수를 전달합니다. 이렇게 하면 운전자 가 쿼리 필터하다 와 일치하는 모든 문서를 삭제 하도록 지시합니다.

다음 예시 에서는 대량 쓰기 (write) 작업에 대한 삭제 작업을 대기열에 추가합니다.

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

대량 쓰기 (write) 에 대기 중인 각 쓰기 (write) 작업을 실행 하려면 mongoc_bulk_operation_execute() 함수를 호출합니다. 이 함수는 다음 매개변수를 허용합니다.

  • mongoc_bulk_operation_t value: 각 쓰기 (write) 작업에 대한 지침을 포함합니다.

  • 결과 위치: 작업 결과를 포함할 덮어쓸 수 있는 저장 에 대한 포인터 또는 NULL

  • 오류 위치: 오류 값의 위치 를 지정하거나 NULL

다음 예시 에서는 mongoc_bulk_operation_execute() 함수를 호출하여 이 가이드 의 이전 섹션에 지정된 삽입 , 업데이트 , 바꾸기 및 삭제 작업을 수행합니다.

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

쓰기 (write) 작업 중 하나라도 실패하면 C 운전자 는 출력 오류를 설정하고 더 이상의 작업을 수행하지 않습니다.

옵션 값을 지정하는 BSON 문서 를 전달하여 mongoc_collection_create_bulk_operation_with_opts() 함수의 동작을 수정할 수 있습니다. 다음 표에서는 문서 에서 설정하다 수 있는 옵션에 대해 설명합니다.

옵션
설명

ordered

If true, the driver performs the write operations in the order provided. If an error occurs, the remaining operations are not attempted.

If false, the driver performs the operations in an arbitrary order and attempts to perform all operations.
Defaults to true.

writeConcern

Specifies the write concern for the bulk operation. For more information, see Write Concern in the MongoDB Server manual.

sessionId

Runs the bulk operations within the specified session. For more information, see Server Sessions in the MongoDB Server manual.

comment

Attaches a comment to the operation. For more information, see the delete command fields guide in the MongoDB Server manual.

let

Specifies a document with a list of values to improve operation readability. Values must be constant or closed expressions that don't reference document fields. For more information, see the let statement in the MongoDB Server manual.

다음 예시 에서는 mongoc_collection_create_bulk_operation_with_opts() 함수를 호출하고 ordered 옵션을 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);

순서가 지정되지 않은 대량 쓰기 (write) 의 쓰기 (write) 작업 중 하나라도 실패하면 C 운전자 는 모든 작업을 시도한 후에만 오류를 보고합니다.

참고

순서가 지정되지 않은 대량 작업은 실행 순서가 보장되지 않습니다. 이 순서는 런타임을 최적화하기 위해 나열한 방식과 다를 수 있습니다.

개별 쓰기 작업을 수행하는 방법을 알아보려면 다음 가이드를 참조하세요.

  • 문서 삽입

  • 문서 업데이트

  • 문서 삭제

  • 문서 교체

이 가이드 에 설명된 함수 또는 유형에 학습 보려면 다음 API 문서를 참조하세요.

돌아가기

삭제