대량 쓰기 작업

샘플 데이터

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

삽입 작업

삽입 작업을 수행하려면 InsertOneModel 인스턴스 를 만들고 삽입하려는 문서 를 전달합니다.

다음 예에서는 InsertOneModel 인스턴스를 만듭니다.

InsertOneModel<Document> operation = new InsertOneModel<>(
        new Document("name", "Mongo's Deli")
                .append("cuisine", "Sandwiches"));

여러 문서를 삽입하려면 각 문서 에 대해 InsertOneModel 인스턴스 를 만듭니다.

업데이트 작업

문서를 업데이트하려면 UpdateOneModel 인스턴스를 만들고 다음 인수를 전달합니다.

• 컬렉션 의 문서를 일치시키는 데 사용되는 기준을 지정하는 쿼리 필터하다 입니다.

• 수행하려는 업데이트 작업 입니다. 업데이트 작업에 대한 자세한 내용은 MongoDB Server 매뉴얼의 필드 업데이트 연산자 가이드 를 참조하세요.

다음 예에서는 UpdateOneModel 인스턴스를 만듭니다.

UpdateOneModel<Document> operation = new UpdateOneModel<>(
        eq("name", "Mongo's Deli"),
        set("cuisine", "Sandwiches and Salads"));

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

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

여러 문서를 업데이트 하려면 UpdateManyModel 인스턴스 를 만들고 동일한 인수를 전달합니다. UpdateManyModel 은 쿼리 필터하다 와 일치하는 모든 문서를 업데이트합니다.

다음 예에서는 UpdateManyModel 인스턴스를 만듭니다.

UpdateManyModel<Document> operation = new UpdateManyModel<>(
        eq("name", "Mongo's Deli"),
        set("cuisine", "Sandwiches and Salads"));

대체 작업

바꾸기 작업은 _id 필드 를 제외하고 지정된 문서 의 모든 필드와 값을 제거하고 새 항목으로 바꿉니다. 바꾸기 작업을 수행하려면 ReplaceOneModel 인스턴스 를 만들고 쿼리 필터하다 와 일치하는 문서 에 저장 하려는 필드 및 값을 전달합니다.

다음 예에서는 ReplaceOneModel 인스턴스를 만듭니다.

ReplaceOneModel<Document> operation = new ReplaceOneModel<>(
        eq("name", "Original Pizza"),
        new Document("name", "Mongo's Pizza")
                .append("borough", "Manhattan"));

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

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

삭제 작업

문서 를 삭제 하려면 DeleteOneModel 인스턴스 를 만들고 삭제 하려는 문서 를 지정하는 쿼리 필터하다 를 전달합니다. DeleteOneModel 은 쿼리 필터하다 와 일치 하는 첫 번째 문서 만 제거합니다.

다음 예에서는 DeleteOneModel 인스턴스를 만듭니다.

DeleteOneModel<Document> operation = new DeleteOneModel<>(
        eq("restaurant_id", "5678"));

여러 문서를 삭제 하려면 DeleteManyModel 인스턴스 를 만들고 삭제 하려는 문서를 지정하는 쿼리 필터하다 를 전달합니다. DeleteManyModel 은 쿼리 필터하다 와 일치하는 모든 문서를 제거합니다.

다음 예에서는 DeleteManyModel 인스턴스를 만듭니다.

DeleteManyModel<Document> operation = new DeleteManyModel<>(
        eq("name", "Mongo's Deli"));

대량 작업 수행

수행하려는 각 작업에 대해 WriteModel 인스턴스 정의한 후 이러한 인스턴스 목록을 bulkWrite() 메서드에 전달합니다. 기본값 으로 이 메서드는 목록에 정의된 순서대로 작업을 실행합니다.

다음 예시 에서는 bulkWrite() 메서드를 사용하여 여러 쓰기 (write) 작업을 수행합니다.

Publisher<BulkWriteResult> bulkWritePublisher = restaurants.bulkWrite(
        Arrays.asList(new InsertOneModel<>(
                        new Document("name", "Mongo's Deli")
                                .append("cuisine", "Sandwiches")
                                .append("borough", "Manhattan")
                                .append("restaurant_id", "1234")),
                new InsertOneModel<>(new Document("name", "Mongo's Deli")
                                .append("cuisine", "Sandwiches")
                                .append("borough", "Brooklyn")
                                .append("restaurant_id", "5678")),
                new UpdateManyModel<>(eq("name", "Mongo's Deli"),
                        set("cuisine", "Sandwiches and Salads")),
                new DeleteOneModel<>(eq("restaurant_id", "1234"))));
BulkWriteResult bulkResult = Mono.from(bulkWritePublisher).block();
System.out.println(bulkResult.toString());

AcknowledgedBulkWriteResult{insertedCount=2, matchedCount=2, removedCount=1, modifiedCount=2, upserts=[], inserts=[BulkWriteInsert{index=0, id=BsonObjectId{value=66a7e0a6c08025218b657208}}, BulkWriteInsert{index=1, id=BsonObjectId{value=66a7e0a6c08025218b657209}}]}

쓰기 (write) 작업 중 하나라도 실패하면 Java Reactive Streams 운전자 는 MongoBulkWriteException 신호를 보내고 더 이상 개별 작업을 수행하지 않습니다. MongoBulkWriteException 에는 개별 장애에 대한 세부 정보를 제공하는 MongoBulkWriteException.getWriteErrors() 메서드를 사용하여 액세스할 수 있는 BulkWriteError 가 포함되어 있습니다.

대량 쓰기 사용자 지정

BulkWriteOptions 클래스에는 bulkWrite() 메서드의 동작을 수정하는 메서드가 포함되어 있습니다. BulkWriteOptions 클래스를 사용하려면 클래스의 새 인스턴스 를 구성한 다음 해당 메서드 중 하나 이상을 호출하여 쓰기 (write) 작업을 수정합니다. 이러한 메서드 호출을 함께 연결할 수 있습니다. 쓰기 (write) 작업의 동작을 수정하려면 클래스 인스턴스 를 bulkWrite() 메서드의 마지막 인수로 전달합니다.

BulkWriteOptions 클래스에서 다음 메서드를 사용하여 쓰기 (write) 메서드를 수정할 수 있습니다. 모든 메서드는 선택 사항입니다.

다음 예시 에서는 앞의 예시 에서 bulkWrite() 메서드를 호출하지만 ordered 옵션을 False 로 설정합니다.

Publisher<BulkWriteResult> bulkWritePublisher = restaurants.bulkWrite(
        Arrays.asList(new InsertOneModel<>(
                        new Document("name", "Mongo's Deli")
                                .append("cuisine", "Sandwiches")
                                .append("borough", "Manhattan")
                                .append("restaurant_id", "1234")),
                new InsertOneModel<>(new Document("name", "Mongo's Deli")
                                .append("cuisine", "Sandwiches")
                                .append("borough", "Brooklyn")
                                .append("restaurant_id", "5678")),
                new UpdateManyModel<>(eq("name", "Mongo's Deli"),
                        set("cuisine", "Sandwiches and Salads")),
                new DeleteOneModel<>(eq("restaurant_id", "1234"))), 
                new BulkWriteOptions().ordered(false));
BulkWriteResult bulkResult = Mono.from(bulkWritePublisher).block();
System.out.println(bulkResult.toString());

AcknowledgedBulkWriteResult{insertedCount=2, matchedCount=2, removedCount=1, modifiedCount=2, upserts=[], inserts=[BulkWriteInsert{index=0, id=BsonObjectId{value=66a7e03cce430c5854b6caf9}}, BulkWriteInsert{index=1, id=BsonObjectId{value=66a7e03cce430c5854b6cafa}}]}

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

삽입 작업

이 예시 두 개의 문서를 삽입하기 위한 지침이 포함된 모델을 만드는 방법을 보여 줍니다. 한 문서 db.people 컬렉션 에 삽입되고 다른 문서 db.things 컬렉션 에 삽입됩니다. MongoNamespace 인스턴스 각 쓰기 (write) 작업이 적용되는 대상 데이터베이스 및 컬렉션 정의합니다.

ClientNamespacedInsertOneModel personToInsert = ClientNamespacedWriteModel
        .insertOne(
                new MongoNamespace("db", "people"),
                new Document("name", "Julia Smith")
);
ClientNamespacedInsertOneModel thingToInsert = ClientNamespacedWriteModel
        .insertOne(
                new MongoNamespace("db", "things"),
                new Document("object", "washing machine")
);

대체 작업

다음 예시 db.people 및 db.things 컬렉션의 기존 문서를 대체하는 모델을 만드는 방법을 보여 줍니다.

ClientNamespacedReplaceOneModel personReplacement = ClientNamespacedWriteModel
        .replaceOne(
                new MongoNamespace("db", "people"),
                Filters.eq("_id", 1),
                new Document("name", "Frederic Hilbert")
        );
ClientNamespacedReplaceOneModel thingReplacement = ClientNamespacedWriteModel
        .replaceOne(
                new MongoNamespace("db", "things"),
                Filters.eq("_id", 1),
                new Document("object", "potato")
        );

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

대량 작업 수행

수행하려는 각 작업에 대해 ClientNamespacedWriteModel 인스턴스 정의한 후 이러한 인스턴스 목록을 클라이언트 bulkWrite() 메서드에 전달합니다. 기본값 으로 이 메서드는 지정된 순서대로 작업을 실행합니다.

다음 예시 에서는 bulkWrite() 메서드를 사용하여 여러 쓰기 (write) 작업을 수행합니다.

MongoNamespace peopleNamespace = new MongoNamespace("db", "people");
MongoNamespace thingsNamespace = new MongoNamespace("db", "things");
List<ClientNamespacedWriteModel> bulkOperations = Arrays.asList(
        ClientNamespacedWriteModel
                .insertOne(
                        peopleNamespace,
                        new Document("name", "Corey Kopper")
                ),
        ClientNamespacedWriteModel
                .replaceOne(
                        thingsNamespace,
                        Filters.eq("_id", 1),
                        new Document("object", "potato")
                )
);
Publisher<ClientBulkWriteResult> bulkWritePublisher = mongoClient
        .bulkWrite(bulkOperations);
ClientBulkWriteResult clientBulkResult = Mono
        .from(bulkWritePublisher)
        .block();
System.out.println(clientBulkResult.toString());

AcknowledgedSummaryClientBulkWriteResult{insertedCount=1, matchedCount=1, ...}

쓰기 (write) 작업 중 하나라도 실패하면 운전자 ClientBulkWriteException 를 발생시키고 더 이상 개별 작업을 수행하지 않습니다. ClientBulkWriteException 에는 개별 장애에 대한 세부 정보를 제공하는 ClientBulkWriteException.getWriteErrors() 메서드를 사용하여 액세스할 수 있는 BulkWriteError 가 포함되어 있습니다.

대량 쓰기 사용자 지정

ClientBulkWriteOptions 인스턴스 bulkWrite() 메서드에 전달하여 운전자 대량 쓰기 (write) 작업을 수행하는 방식을 사용자 지정할 수 있습니다.

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

API 문서

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

• 컬렉션 대량 쓰기

  • bulkWrite()를 호출합니다.

  • InsertOneModel

  • UpdateOneModel

  • UpdateManyModel

  • ReplaceOneModel

  • DeleteOneModel

  • DeleteManyModel

  • BulkWriteResult

  • BulkWriteError

  • MongoBulkWriteException

• 클라이언트 대량 쓰기

  • bulkWrite()를 호출합니다.

  • ClientNamespacedWriteModel

  • MongoNamespace

  • ClientBulkWriteOptions

  • ClientBulkWriteResult