Docs Menu
Docs Home
/ / /
PHP 라이브러리 매뉴얼
/

대량 쓰기 작업

이 페이지의 내용

  • 개요
  • 샘플 데이터
  • 대량 작업
  • 예시
  • 대량 쓰기 동작 수정
  • 반환 값
  • 추가 정보
  • API 문서

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

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

이 가이드 의 예제에서는 Atlas 샘플 데이터 세트sample_restaurants 데이터베이스 에 있는 restaurants 컬렉션 을 사용합니다. PHP 애플리케이션 에서 이 컬렉션 에 액세스 하려면 Atlas cluster 에 연결하는 MongoDB\Client 를 인스턴스화하고 $collection 변수에 다음 값을 할당합니다.

$collection = $client->sample_restaurants->restaurants;

무료 MongoDB Atlas cluster 를 생성하고 샘플 데이터 세트를 로드하는 방법을 학습 보려면 Atlas 시작하기 가이드 를 참조하세요.

대량 쓰기 (write) 작업을 실행 하려면 쓰기 (write) 작업 배열 을 MongoDB\Collection::bulkWrite() 메서드에 전달합니다. 쓰기 (write) 작업을 지정하려면 다음 구문을 사용합니다.

[
[ 'deleteMany' => [ $filter ] ],
[ 'deleteOne' => [ $filter ] ],
[ 'insertOne' => [ $document ] ],
[ 'replaceOne' => [ $filter, $replacement, $options ] ],
[ 'updateMany' => [ $filter, $update, $options ] ],
[ 'updateOne' => [ $filter, $update, $options ] ],
]

삭제, 삽입, 바꾸기 및 업데이트 작업에 대한 자세한 내용은 쓰기 작업 가이드를 참조하세요.

bulkWrite() 메서드를 호출하면 라이브러리는 배열 에 지정된 순서대로 쓰기 (write) 작업을 자동으로 실행합니다. 쓰기 (write) 작업을 임의의 순서로 실행 하도록 bulkWrite() 에 지시하는 방법을 학습 보려면 대량 쓰기 동작 수정 섹션을 참조하세요.

이 예시 에서는 restaurants 컬렉션 에서 다음 쓰기 (write) 작업을 실행합니다.

  • name 값이 'Mongo's Deli'인 문서 를 삽입하는 삽입 작업

  • name 값이 'Mongo's Deli'인 문서 의 cuisine 필드 를 업데이트 하는 업데이트 작업 입니다.

  • borough 값이 'Manhattan'인 모든 문서를 삭제 하는 삭제 작업 입니다.

$result = $collection->bulkWrite(
[
[
'insertOne' => [
['name' => 'Mongo\'s Deli'],
['cuisine' => 'Sandwiches'],
['borough' => 'Manhattan'],
['restaurant_id' => '1234'],
],
],
[
'updateOne' => [
['name' => 'Mongo\'s Deli'],
['$set' => ['cuisine' => 'Sandwiches and Salads']],
],
],
[
'deleteMany' => [
['borough' => 'Manhattan'],
],
],
]
);

옵션 값을 매개 변수로 지정하는 배열 을 전달하여 MongoDB\Collection::bulkWrite() 메서드의 동작을 수정할 수 있습니다. 다음 표에서는 배열 에서 설정하다 수 있는 옵션에 대해 설명합니다.

옵션
설명

bypassDocumentValidation

Specifies whether the operation bypasses document validation. This lets you modify documents that don't meet the schema validation requirements, if any exist. For more information about schema validation, see Schema Validation in the MongoDB Server manual.
Defaults to false.

codec

Sets the codec to use for encoding or decoding documents. Bulk writes use the codec for insertOne() and replaceOne() operations. For more information, see the Codecs guide.

writeConcern

Sets the write concern for the operation. For more information, see Write Concern 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.

ordered

If set to true: when a single write fails, the operation stops without performing the remaining writes and throws an exception.
If set to false: when a single write fails, the operation continues to attempt the remaining write operations, if any, then throws an exception.
Defaults to true.

comment

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

session

Specifies the client session to associate with the operation.

다음 예시 에서는 bulkWrite() 메서드를 호출하여 삽입 및 삭제 작업을 수행하고 ordered 옵션을 false 로 설정합니다.

$result = $collection->bulkWrite(
[
[
'insertOne' => [
['name' => 'Mongo\'s Pizza'],
['cuisine' => 'Italian'],
['borough' => 'Queens'],
['restaurant_id' => '5678'],
],
],
[
'deleteOne' => [
['restaurant_id' => '5678'],
],
],
],
['ordered' => false]
);

라이브러리가 삽입 작업을 먼저 실행하면 문서 하나가 삭제됩니다. 삭제 작업을 먼저 실행하면 문서가 삭제되지 않습니다.

참고

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

MongoDB\Collection::bulkWrite() 메서드는 MongoDB\BulkWriteResult 객체 를 반환합니다. 이 클래스에는 다음과 같은 멤버 함수가 포함되어 있습니다.

기능
설명

getDeletedCount()

Returns the number of documents deleted, if any.

getInsertedCount()

Returns the number of documents inserted, if any.

getInsertedIds()

Returns a map of _id field values for inserted documents, if any.

getMatchedCount()

Returns the number of documents matched during update and replace operations, if applicable.

getModifiedCount()

Returns the number of documents modified, if any.

getUpsertedCount()

Returns the number of documents upserted, if any.

getUpsertedIds()

Returns a map of _id field values for upserted documents, if any.

isAcknowledged()

Returns a boolean indicating whether the bulk operation was acknowledged.

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

이 가이드에서 사용되는 메서드 또는 유형에 대해 자세히 알아보려면 다음 API 설명서를 참조하세요.

돌아가기

바꾸기