대량 작업

이 페이지의 내용

개요

컬렉션 대량 쓰기
삽입 작업
대체 작업
업데이트 작업
삭제 작업
실행 순서
클라이언트 대량 쓰기
예제 삽입
바꾸기 예시
대량 쓰기 옵션
요약
MongoCollection.bulkWrite()
MongoClient.bulkWrite()

개요

이 가이드에서는 MongoDB Java 드라이버에서 대량 작업을 사용하는 방법에 대해 설명합니다.

단일 생성, 교체, 업데이트 또는 삭제 작업을 수행하려면 해당 메서드를 사용할 수 있습니다. 예시 들어, 문서 하나를 삽입하고 문서 하나를 바꾸려면 insertOne() 및 replaceOne() 메서드를 사용할 수 있습니다. 이러한 메서드를 사용하면 MongoClient 는 각 작업에 대해 데이터베이스 를 한 번 호출합니다.

대량 쓰기 (write) 작업을 사용하면 더 적은 수의 데이터베이스 호출로 여러 쓰기 (write) 작업을 수행할 수 있습니다. 다음 수준에서 대량 쓰기 (write) 작업을 수행할 수 있습니다.

컬렉션:MongoCollection.bulkWrite() 메서드를 사용하여 단일 컬렉션 에 대해 대량 쓰기 (write) 작업을 수행할 수 있습니다. 이 메서드에서는 각 종류의 쓰기 (write) 작업에 하나 이상의 데이터베이스 호출이 필요합니다. 예시 를 들어 는MongoCollection.bulkWrite() 여러 업데이트 작업을 한 번의 호출에 처리하지만 삽입 작업과 바꾸기 작업에 대해 데이터베이스 두 번 개별적으로 호출합니다.
클라이언트: 애플리케이션 MongoDB Server 버전 이상에 연결되는 8.0 경우 메서드를 사용하여 MongoClient.bulkWrite() 동일한 클러스터 의 여러 컬렉션 및 데이터베이스에서 대량 쓰기 (write) 작업을 수행할 수 있습니다. 이 메서드는 한 번의 데이터베이스 호출로 모든 쓰기 (write) 작업을 수행합니다.

컬렉션 대량 쓰기

대량 쓰기 (write) 작업에는 하나 이상의 쓰기 (write) 작업이 포함됩니다. 컬렉션 수준에서 대량 쓰기 (write) 작업을 수행하려면 WriteModel 문서의 List 를 MongoCollection.bulkWrite() 메서드에 전달합니다. WriteModel 는 쓰기 (write) 작업을 나타내는 모델입니다.

MongoCollection.bulkWrite() 메서드는 별도의 데이터베이스 호출에서 각 종류의 쓰기 (write) 작업을 수행합니다. 예시 를 들어 DeleteOneModel, DeleteManyModel 및 ReplaceOneModel 객체를 메서드에 전달하면 삭제 작업에 대한 호출과 바꾸기 작업에 대한 호출이라는 두 가지 호출을 수행합니다.

참고

클라이언트 작업을 별도의 데이터베이스 호출로 분할할 때 대량 쓰기 (write) 작업의 순서가 지정되지 않은 경우 효율성 위해 작업 순서를 변경할 수 있습니다. 작업 실행 순서에 대해 자세히 학습 실행 순서 섹션을 참조하세요.

다음 섹션에서는 각 WriteModel 문서를 만들고 사용하는 방법을 보여 줍니다. 각 섹션의 예에서는 people 컬렉션의 다음 문서를 사용합니다.

{ "_id": 1, "name": "Karen Sandoval", "age": 31 }
{ "_id": 2, "name": "William Chin", "age": 54 }
{ "_id": 8, "name": "Shayla Ray", "age": 20 }

이 섹션에 언급된 메서드 및 클래스에 대한 자세한 내용은 다음 API 문서를 참조하세요.

삽입 작업

삽입 작업을 수행하려면 삽입하려는 문서를 지정하는 InsertOneModel을 만듭니다. 여러 문서를 삽입하려면 삽입하려는 각 문서에 대해 InsertOneModel을 만듭니다.

예시

다음 예에서는 사람을 설명하는 두 문서에 대해 InsertOneModel을 만듭니다.

InsertOneModel<Document> juneDoc = new InsertOneModel<>(new Document("name", "June Carrie")
                                                            .append("age", 17));
                                                  
InsertOneModel<Document> kevinDoc = new InsertOneModel<>(new Document("name", "Kevin Moss")
                                                            .append("age", 22));

중요

bulkWrite()을 수행할 때 InsertOneModel은 컬렉션에 이미 존재하는 _id가 포함된 문서를 삽입할 수 없습니다. 대신, 이 메서드가 MongoBulkWriteException을 반환합니다.

다음 예에서는 _id가 1 및 3인 두 문서를 삽입하려고 합니다.

try {
    List<WriteModel<Document>> bulkOperations = new ArrayList<>();
    // Creates instructions to insert documents
    InsertOneModel<Document> doc1 = new InsertOneModel<>(new Document("_id", 1));
    InsertOneModel<Document> doc3 = new InsertOneModel<>(new Document("_id", 3));
    
    bulkOperations.add(doc1);
    bulkOperations.add(doc3);
    
    // Runs a bulk write operation for the specified insert WriteModels
    collection.bulkWrite(bulkOperations); 
// Prints a message if any exceptions occur during the bulk write operation
} catch (MongoBulkWriteException e){
    System.out.println("A MongoBulkWriteException occurred with the following message: " + e.getMessage());
}

다음은 앞에 설명한 코드의 출력입니다.

A MongoBulkWriteException occurred with the following message:
Bulk write operation error on server sample-shard-00-02.pw0q4.mongodb.net:27017.
Write errors: [BulkWriteError{index=0, code=11000, message='E11000 duplicate key
error collection: crudOps.bulkWrite index: _id_ dup key: { _id: 1 }', details={}}].

_id가 3인 문서가 삽입되지 않은 이유를 확인하려면 실행 순서 섹션을 참조하세요.

이 섹션에 언급된 메서드 및 클래스에 대한 자세한 내용은 InsertOneModel API 설명서를 참조하세요.

대체 작업

대체 작업을 수행하려면 다른 문서로 대체하려는 문서에 대한 쿼리 필터를 지정하는 ReplaceOneModel을 만듭니다.

중요

bulkWrite()을 수행할 때 ReplaceOneModel은 컬렉션의 고유 인덱스 제약 조건을 위반하는 문서를 변경할 수 없으며, 쿼리 필터와 일치하는 항목이 없는 경우 이 모델은 문서를 대체하지 않습니다.

예시

다음 예에서는 _id가 1인 문서를 location 필드가 추가된 문서로 대체하기 위해 ReplaceOneModel을 만듭니다.

ReplaceOneModel<Document> celineDoc = new ReplaceOneModel<>(
                                    Filters.eq("_id", 1), 
                                    new Document("name", "Celine Stork")
                                        .append("location", "San Diego, CA"));

여러 문서가 ReplaceOneModel 인스턴스 에 지정된 쿼리 필터하다 와 일치하는 경우 작업은 첫 번째 결과를 대체합니다. 다음 코드와 같이 ReplaceOptions 인스턴스 에서 정렬을 지정하여 운전자 바꾸기 작업을 수행하기 전에 일치하는 문서에 순서를 적용 할 수 있습니다.

ReplaceOptions options = ReplaceOptions.sort(Sorts.ascending("_id"));

이 섹션에 언급된 메서드 및 클래스에 대한 자세한 내용은 다음 API 리소스를 참조하세요.

ReplaceOneModel API 문서
ReplaceOptions API 문서
고유 인덱스 서버 매뉴얼 설명

업데이트 작업

업데이트 작업을 수행하려면 UpdateOneModel을 만들거나, 업데이트된 내용으로 업데이트하려는 문서에 대한 쿼리 필터를 지정하는 UpdateManyModel을 만듭니다.

UpdateOneModel은 쿼리 필터와 일치하는 첫 번째 문서를 업데이트하고, UpdateManyModel은 쿼리 필터와 일치하는 모든 문서를 업데이트합니다.

중요

bulkWrite()을 수행할 때 UpdateOneModel 및 UpdateManyModel은 컬렉션의 고유 인덱스 제약 조건을 위반하는 문서를 변경할 수 없으며, 쿼리 필터와 일치하는 문서가 없는 경우 이 모델은 문서를 업데이트하지 않습니다.

예시

다음 예에서는 _id가 2인 문서에서 age 필드를 업데이트하기 위해 UpdateOneModel을 만듭니다.

UpdateOneModel<Document> updateDoc = new UpdateOneModel<>(
                                    Filters.eq("_id", 2), 
                                    Updates.set("age", 31));

여러 문서가 UpdateOneModel 인스턴스 에 지정된 쿼리 필터하다 와 일치하는 경우 작업은 첫 번째 결과를 업데이트합니다. 다음 코드와 같이 UpdateOptions 인스턴스 에서 정렬을 지정하여 운전자 업데이트 작업을 수행하기 전에 일치하는 문서에 순서를 적용 수 있습니다.

UpdateOptions options = UpdateOptions.sort(Sorts.ascending("_id"));

이 섹션에 언급된 메서드 및 클래스에 대한 자세한 내용은 다음 API 리소스를 참조하세요.

UpdateOneModel API documentation
UpdateManyModel API 문서
UpdateOptions API documentation
고유 인덱스 서버 매뉴얼 설명

삭제 작업

삭제 작업을 수행하려면 DeleteOneModel을 만들거나, 삭제하려는 문서에 대한 쿼리 필터를 지정하는 DeleteManyModel을 만듭니다.

DeleteOneModel은 쿼리 필터와 일치하는 첫 번째 문서를 삭제하고 DeleteManyModel은 쿼리 필터와 일치하는 모든 문서를 삭제합니다.

중요

bulkWrite()을 수행할 때 DeleteOneModel 및 DeleteManyModel은 쿼리 필터와 일치하는 항목이 없는 경우 문서를 삭제하지 않습니다.

예시

다음 예에서는 _id가 1인 문서를 삭제하기 위해 DeleteOneModel을 만듭니다.

DeleteOneModel<Document> deleteDoc = new DeleteOneModel<>(Filters.eq("_id", 1));

이 섹션에 언급된 메서드 및 클래스에 대한 자세한 내용은 다음 API 문서를 참조하세요.

실행 순서

bulkWrite() 메서드는 선택적으로 BulkWriteOptions를 두 번째 매개 변수로 사용하여 대량 작업의 실행 순서를 지정할지 여부를 나타냅니다.

기본적으로 bulkWrite() 메서드는 대량 작업을 순서대로 실행합니다. 즉, 오류가 발생할 때까지 목록에 추가된 순서대로 대량 작업이 실행됩니다.

예시

다음 예에서는 아래의 대량 작업을 수행합니다.

name 값이 "Zaynab Omar"이고 age 값이 37인 문서를 삽입하는 작업
_id가 1인 문서를 location 필드가 포함된 새 문서로 대체하는 작업
name 값이 "Zaynab Omar"인 문서를 업데이트하여 name을 "Zaynab Hassan"으로 변경하는 작업
age 값이 50보다 큰 모든 문서를 삭제하는 작업

List<WriteModel<Document>> bulkOperations = new ArrayList<>();
// Creates instructions to insert a document
InsertOneModel<Document> insertDoc = new InsertOneModel<>(new Document("_id", 6)
                                                        .append("name", "Zaynab Omar")
                                                        .append("age", 37));
// Creates instructions to replace the first document matched by the query                                       
ReplaceOneModel<Document> replaceDoc = new ReplaceOneModel<>(Filters.eq("_id", 1), 
                                        new Document("name", "Sandy Kane")
                                            .append("location", "Helena, MT")); 
// Creates instructions to update the first document matched by the query                                                                 
UpdateOneModel<Document> updateDoc = new UpdateOneModel<>(Filters.eq("name", "Zaynab Omar"), 
                                        Updates.set("name", "Zaynab Hassan"));
// Creates instructions to delete all documents matched by the query                                
DeleteManyModel<Document> deleteDoc = new DeleteManyModel<>(Filters.gt("age", 50));
bulkOperations.add(insertDoc);
bulkOperations.add(replaceDoc);
bulkOperations.add(updateDoc);
bulkOperations.add(deleteDoc);
// Runs a bulk write operation for the specified the insert, replace, update, and delete WriteModels in order
collection.bulkWrite(bulkOperations);

이 예시가 실행된 후에는 컬렉션에 다음 문서가 포함됩니다.

{ "_id": 1, "name": "Sandy Kane", "location": "Helena, MT" }
{ "_id": 8, "name": "Shayla Ray", "age": 20 }
{ "_id": 6, "name": "Zaynab Hassan", "age": 37 }

순서 지정되지 않은 실행

BulkWriteOptions의 order() 메서드에 'false'를 지정하여 순서에 상관없이 대량 작업을 실행할 수도 있습니다. 즉, 오류와 관계없이 모든 쓰기 작업이 실행되고 오류가 발생하면 대량 작업이 마지막에 오류를 보고합니다.

다음을 포함하여 앞에 설명한 예시에 추가하면 임의의 순서로 실행할 대량 작업이 지정됩니다.

BulkWriteOptions options = new BulkWriteOptions().ordered(false);
// Runs a bulk write operation for the specified insert, replace, update, and delete WriteModels in any order
collection.bulkWrite(bulkOperations, options);

참고

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

앞에 설명한 예에서 bulkWrite() 메서드가 업데이트 작업 후에 삽입 작업을 수행하기로 결정한 경우 해당 시점에 문서가 존재하지 않으므로 업데이트 작업으로 변경되는 사항은 없습니다. 그러면 컬렉션에 다음 문서가 포함됩니다.

{ "_id": 1, "name": "Sandy Kane", "location": "Helena, MT" }
{ "_id": 8, "name": "Shayla Ray", "age": 20 }
{ "_id": 6, "name": "Zaynab Omar", "age": 37 }

이 섹션에 언급된 메서드 및 클래스에 대한 자세한 내용은 다음 API 문서를 참조하세요.

클라이언트 대량 쓰기

MongoDB Server 8.0 이상을 실행 배포서버 에 연결할 때 MongoClient.bulkWrite() 메서드를 사용하여 동일한 클러스터 의 여러 데이터베이스 및 컬렉션에 쓰기 (write) 수 있습니다. MongoClient.bulkWrite() 메서드는 한 번의 호출로 모든 쓰기 (write) 작업을 수행합니다.

MongoClient.bulkWrite() 메서드는 ClientNamespacedWriteModel 인스턴스 목록을 사용하여 다양한 쓰기 (write) 작업을 나타냅니다. 인스턴스 메서드를 사용하여 ClientNamespacedWriteModel 인터페이스의 인스턴스를 구성할 수 있습니다. 예시 를 들어 ClientNamespacedInsertOneModel 의 인스턴스 하나의 문서 삽입하는 작업을 나타내며 ClientNamespacedWriteModel.insertOne() 메서드를 사용하여 이 모델을 만들 수 있습니다.

모델과 해당 인스턴스 메서드는 아래 표에 설명되어 있습니다.

모델	인스턴스 메서드	설명	매개변수
`ClientNamespacedInsertOneModel`	`insertOne()`	`namespace`에 문서 삽입할 모델을 만듭니다.	`namespace`: 쓰기 (write) 데이터베이스 및 컬렉션 `document`: 삽입할 문서
`ClientNamespacedUpdateOneModel`	`updateOne()`	`filter`와 일치하는 `namespace` 의 첫 번째 문서 업데이트 모델을 만듭니다.	`namespace`: 쓰기 (write) 데이터베이스 및 컬렉션 `filter`: 업데이트 할 문서 선택하는 필터 `update`: 일치하는 문서 에 적용 업데이트 `updatePipeline`: 일치하는 문서 에 적용 파이프라인 업데이트 `options`: (선택 사항) 문서 업데이트 시 적용 옵션 `update` 또는 `updatePipeline` 매개변수 값을 전달해야 합니다.
`ClientNamespacedUpdateManyModel`	`updateMany()`	`filter`와 일치하는 `namespace` 의 모든 문서를 업데이트 모델을 만듭니다.	`namespace`: 쓰기 (write) 데이터베이스 및 컬렉션 `filter`: 업데이트 할 문서를 선택하는 필터 `update`: 일치하는 문서에 적용 업데이트 `updatePipeline`: 일치하는 문서에 적용 파이프라인 업데이트 `options`: (선택 사항) 문서 업데이트 시 적용 옵션 `update` 또는 `updatePipeline` 매개변수 값을 전달해야 합니다.
`ClientNamespacedReplaceOneModel`	`replaceOne()`	`filter`와 일치하는 `namespace` 의 첫 번째 문서 대체할 모델을 만듭니다.	`namespace`: 쓰기 (write) 데이터베이스 및 컬렉션 `filter`: 대체할 문서 선택하는 필터 `replacement`: 대체 문서 `options`: (선택 사항) 문서를 교체할 때 적용 옵션
`ClientNamespacedDeleteOneModel`	`deleteOne()`	`namespace` 에서 `filter`과 일치하는 첫 번째 문서 삭제 하는 모델을 생성합니다.	`namespace`: 쓰기 (write) 데이터베이스 및 컬렉션 `filter`: 삭제 문서 선택하는 필터 `option`: (선택 사항) 문서 삭제할 때 적용 할 옵션
`ClientNamespacedDeleteManyModel`	`deleteMany()`	`filter`와(과) 일치하는 `namespace` 의 모든 문서를 삭제 하는 모델을 생성합니다.	`namespace`: 쓰기 (write) 데이터베이스 및 컬렉션 `filter`: 삭제 문서를 선택하는 필터 `option`: (선택 사항) 문서를 삭제할 때 적용 할 옵션

다음 섹션에서는 클라이언트 bulkWrite() 메서드를 사용하는 방법의 예를 제공합니다.

예제 삽입

이 예시 bulkWrite() 메서드를 사용하여 두 개의 문서를 삽입하는 방법을 보여 줍니다. 한 문서 db.people 컬렉션 에 삽입되고 다른 문서 db.things 컬렉션 에 삽입됩니다. MongoNamespace 인스턴스 각 쓰기 (write) 작업이 적용되는 데이터베이스와 컬렉션을 정의합니다.

MongoNamespace peopleNamespace = new MongoNamespace("db", "people");
MongoNamespace thingsNamespace = new MongoNamespace("db", "things");
List<ClientNamespacedWriteModel> bulkOperations = new ArrayList<>();
ClientNamespacedInsertOneModel insertDocument1 = new ClientNamespacedWriteModel
   .insertOne(
      peopleNamespace,
      new Document("name", "Julia Smith")
   );
ClientNamespacedInsertOneModel insertDocument2 = new ClientNamespacedWriteModel
   .insertOne(
      thingsNamespace,
      new Document("object", "washing machine")
   );
bulkOperations.add(insertDocument1);
bulkOperations.add(insertDocument2);
ClientBulkWriteResult result = mongoClient.bulkWrite(bulkOperations);

바꾸기 예시

다음 예시 bulkWrite() 메서드를 사용하여 db.people 및 db.things 컬렉션의 기존 문서를 바꾸는 방법을 보여 줍니다.

MongoNamespace peopleNamespace = new MongoNamespace("db", "people");
MongoNamespace thingsNamespace = new MongoNamespace("db", "things");
List<ClientNamespacedWriteModel> bulkOperations = new ArrayList<>();
bulkOperations.add(ClientNamespacedWriteModel.replaceOne(
      peopleNamespace,
      Filters.eq("_id", 1),
      new Document("name", "Frederic Hilbert")
   )
);
bulkOperations.add(ClientNamespacedWriteModel.replaceOne(
      thingsNamespace,
      Filters.eq("_id", 1),
      new Document("object", "potato")
   )
);
ClientBulkWriteResult result = mongoClient.bulkWrite(bulkOperations);

이 예시 성공적으로 실행되면 people 컬렉션 에서 _id 값이 1 인 문서 새 문서 로 대체됩니다. things 컬렉션 의 _id 값이 1 인 문서 새 문서 로 대체됩니다.

대량 쓰기 옵션

ClientBulkWriteOptions 의 인스턴스 bulkWrite() 메서드에 전달하여 대량 쓰기 (write) 작업을 실행 때 옵션을 지정할 수 있습니다.

실행 순서 예시

기본값 으로 대량 작업의 개별 작업은 오류가 발생하거나 성공적으로 실행될 때까지 지정한 순서대로 실행됩니다. 그러나 ClientBulkWriteOptions 인터페이스의 ordered() 메서드에 false 을 전달하여 순서가 지정되지 않은 방식으로 쓰기 (write) 작업을 수행할 수 있습니다. 순서가 지정되지 않은 옵션을 사용하는 경우 오류가 발생하는 작업은 bulkWrite() 메서드 호출에서 다른 쓰기 (write) 작업의 실행을 방해하지 않습니다.

다음 코드는 ClientBulkWriteOptions 인스턴스 에 ordered() 메서드를 설정하고 대량 쓰기 (write) 작업을 수행하여 여러 문서를 삽입합니다.

MongoNamespace namespace = new MongoNamespace("db", "people");
ClientBulkWriteOptions options = new ClientBulkWriteOptions().ordered(false);
List<ClientNamespacedWriteModel> bulkOperations = new ArrayList<>();
bulkOperations.add(
   ClientNamespacedWriteModel.insertOne(
      namespace,
      new Document("_id", 1).append("name", "Rudra Suraj")
   )
);
// Causes a duplicate key error
bulkOperations.add(
   ClientNamespacedWriteModel.insertOne(
      namespace,
      new Document("_id", 1).append("name", "Mario Bianchi")
   )
);
bulkOperations.add(
   ClientNamespacedWriteModel.insertOne(
      namespace,
      new Document("name", "Wendy Zhang")
   )
);
ClientBulkWriteResult result = mongoClient.bulkWrite(bulkOperations, options);

중복 키가 있는 문서 삽입하는 쓰기 (write) 작업으로 인해 오류가 발생하더라도 쓰기 (write) 작업이 순서가 지정되지 않았으므로 다른 작업은 실행됩니다.

요약

`MongoCollection.bulkWrite()`

대량 작업을 수행하려면 WriteModel 인스턴스 목록을 만들어 bulkWrite() 메서드에 전달합니다.

InsertOneModel, ReplaceOneModel, UpdateOneModel, UpdateManyModel, DeleteOneModel, DeleteManyModel 등 6 개의 다양한 WriteModel 하위 유형이 있습니다.

bulkWrite() 메서드를 실행하는 방법에는 두 가지가 있습니다.

순서 지정됨 - 오류가 발생할 때까지 대량 작업을 순서대로 수행
순서 지정되지 않음 - 순서에 관계없이 모든 대량 작업을 수행하고 마지막에 오류를 보고

`MongoClient.bulkWrite()`

MongoDB Server 버전 8.0 이상을 실행 배포서버 에 연결할 때 MongoClient.bulkWrite() 메서드를 사용하여 여러 데이터베이스 및 컬렉션에서 한 번에 대량 작업을 수행할 수 있습니다.

클라이언트 일괄 작업을 수행하려면 이 메서드에 전달할 ClientNamespacedWriteModel 인스턴스 목록을 만듭니다.

쓰기 (write) 작업을 나타내는 데 사용되는 ClientNamespacedWriteModel 의 6가지 하위 유형이 있습니다. 이러한 쓰기 (write) 모델을 구성하려면 해당 ClientNamespacedWriteModel 메서드 insertOne(), updateOne(), updateMany(), replaceOne(), deleteOne() 및 deleteMany()를 사용할 수 있습니다. 이 메서드는 쓰기 (write) 데이터베이스 와 컬렉션 정의하는 MongoNamespace 객체 사용합니다.

MongoClient.bulkWrite() 메서드는 ClientBulkWriteOptions 객체 사용하여 명령이 실행되는 방식에 대한 다양한 옵션을 지정할 수도 있습니다.

클라이언트 bulkWrite 명령에 대해 자세히 학습 MongoDB Server 매뉴얼에서 bulkWrite() 메서드 참조를 참조하세요.

돌아가기

업서트

쿼리