대량 작업
개요
이 가이드에서는 MongoDB Java 드라이버에서 대량 작업을 사용하는 방법에 대해 설명합니다.
만들기, 대체, 업데이트 또는 삭제 작업을 수행하려면 해당되는 메서드를 사용하세요. 예를 들어, 컬렉션에서 하나의 문서를 삽입하고, 여러 문서를 업데이트하고, 하나의 문서를 삭제하려면 insertOne(), updateMany() 및 deleteOne() 메서드를 사용하세요.
MongoClient는 데이터베이스에 대한 각 작업을 호출하여 이러한 작업을 수행합니다. 대량 작업을 사용하여 데이터베이스에 대한 호출 횟수를 한 번으로 줄일 수 있습니다.
대량 작업 수행
대량 작업은 다수의 쓰기 작업으로 구성됩니다. 대량 작업을 수행하려면 WriteModel 문서의 List를 bulkWrite() 메서드에 전달합니다. WriteModel은 모든 쓰기 작업을 나타내는 모델입니다.
다음 섹션에서는 각 WriteModel 문서를 만들고 사용하는 방법을 보여줍니다. 각 섹션의 예제에는 collection에 다음과 같은 문서가 포함되어 있습니다.
{ "_id": 1 } { "_id": 2 }
이 섹션에 언급된 메서드 및 클래스에 대한 자세한 내용은 다음 API 문서를 참조하세요.
삽입 작업
삽입 작업을 수행하려면 삽입하려는 문서를 지정하는 InsertOneModel을 만듭니다. 여러 문서를 삽입하려면 삽입하려는 각 문서에 대해 InsertOneModel을 만듭니다.
예시
다음 예에서는 _id 값이 '3'과 '4'인 두 문서에 대해 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={}}].
'3'의 _id 가 포함된 문서가 삽입되지 않은 이유를 확인하려면 실행 순서 섹션을 참조하세요.
이 섹션에 언급된 메서드 및 클래스에 대한 자세한 내용은 InsertOneModel API 설명서를 참조하세요.
대체 작업
대체 작업을 수행하려면 다른 문서로 대체하려는 문서에 대한 쿼리 필터를 지정하는 ReplaceOneModel을 만듭니다.
중요
bulkWrite()을 수행할 때 ReplaceOneModel은 컬렉션의 고유 인덱스 제약 조건을 위반하는 문서를 변경할 수 없으며, 쿼리 필터와 일치하는 항목이 없는 경우 이 모델은 문서를 대체하지 않습니다.
예시
다음 예에서는 _id 가 '1'인 문서를 추가 필드가 포함된 문서로 대체하기 위해 ReplaceOneModel 을 만듭니다.
ReplaceOneModel<Document> doc3 = new ReplaceOneModel<>( Filters.eq("_id", 1), new Document("name", "Celine Stork") .append("location", "San Diego, CA"));
이 섹션에 언급된 메서드 및 클래스에 대한 자세한 내용은 다음 API 리소스를 참조하세요.
ReplaceOneModel API 설명서
고유 인덱스 서버 매뉴얼 설명
업데이트 작업
업데이트 작업을 수행하려면 UpdateOneModel을 만들거나, 업데이트된 내용으로 업데이트하려는 문서에 대한 쿼리 필터를 지정하는 UpdateManyModel을 만듭니다.
UpdateOneModel은 쿼리 필터와 일치하는 첫 번째 문서를 업데이트하고, UpdateManyModel은 쿼리 필터와 일치하는 모든 문서를 업데이트합니다.
중요
bulkWrite()을 수행할 때 UpdateOneModel 및 UpdateManyModel은 컬렉션의 고유 인덱스 제약 조건을 위반하는 문서를 변경할 수 없으며, 쿼리 필터와 일치하는 문서가 없는 경우 이 모델은 문서를 업데이트하지 않습니다.
예시
다음 예에서는 _id 이 '2'인 문서를 추가 필드가 포함된 문서로 업데이트하기 위해 UpdateOneModel 을 만듭니다.
UpdateOneModel<Document> doc3 = new UpdateOneModel<>( Filters.eq("_id", 2), Updates.set("x", 8));
이 섹션에 언급된 메서드 및 클래스에 대한 자세한 내용은 다음 API 리소스를 참조하세요.
UpdateOneModel API 설명서
UpdateManyModel API 설명서
고유 인덱스 서버 매뉴얼 설명
삭제 작업
삭제 작업을 수행하려면 DeleteOneModel을 만들거나, 삭제하려는 문서에 대한 쿼리 필터를 지정하는 DeleteManyModel을 만듭니다.
DeleteOneModel은 쿼리 필터와 일치하는 첫 번째 문서를 삭제하고 DeleteManyModel은 쿼리 필터와 일치하는 모든 문서를 삭제합니다.
중요
bulkWrite()을 수행할 때 DeleteOneModel 및 DeleteManyModel은 쿼리 필터와 일치하는 항목이 없는 경우 문서를 삭제하지 않습니다.
예시
다음 예에서는 _id 이 '1'인 문서를 삭제하기 위해 DeleteOneModel 을 만듭니다.
DeleteOneModel<Document> doc3 = new DeleteOneModel<>(Filters.eq("_id", 1));
이 섹션에 언급된 메서드 및 클래스에 대한 자세한 내용은 다음 API 문서를 참조하세요.
실행 순서
bulkWrite() 메서드는 선택적 BulkWriteOptions 을 두 번째 매개 변수로 허용하여 대량 작업을 순서가 지정된 작업으로 실행할지, 순서가 지정되지 않은 상태로 실행할지 여부를 지정합니다.
순서 지정된 실행
기본적으로 bulkWrite() 메서드는 대량 작업을 순서대로 실행합니다. 즉, 오류가 발생할 때까지 목록에 추가된 순서대로 대량 작업이 실행됩니다.
예시
다음 예에서는 아래의 대량 작업을 수행합니다.
_id가 "3"인 문서에 대한 삽입 작업입니다._id가 "1"인 문서를 추가 필드가 포함된 문서로 대체하는 작업추가 필드가 포함된 문서에 대한
_id가 '3'인 문서에 대한 업데이트 작업입니다.값이 "2"인
x필드를 포함하는 모든 문서에 대한 삭제 작업입니다.
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(doc1); bulkOperations.add(doc2); bulkOperations.add(doc3); bulkOperations.add(doc4); // Runs a bulk write operation for the specified the insert, replace, update, and delete WriteModels in order collection.bulkWrite(bulkOperations);
이 예시가 실행된 후에는 컬렉션에 다음 문서가 포함됩니다.
{ "_id": 2 }
순서 지정되지 않은 실행
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": 2 } { "_id": 3 }
이 섹션에 언급된 메서드 및 클래스에 대한 자세한 내용은 다음 API 문서를 참조하세요.
요약
대량 작업을 수행하려면 WriteModel 문서 목록을 만들어 bulkWrite() 메서드에 전달합니다.
WriteModel 문서에는 InsertOneModel, ReplaceOneModel, UpdateOneModel, UpdateManyModel, DeleteOneModel, DeleteManyModel 6개가 있습니다.
bulkWrite() 메서드를 실행하는 방법에는 두 가지가 있습니다.
순서 지정됨 - 오류가 발생할 때까지 대량 작업을 순서대로 수행
순서 지정되지 않음 - 순서에 관계없이 모든 대량 작업을 수행하고 마지막에 오류를 보고