Skip to content

Commit f99cde9

Browse files
christophstroblchristophstrobl
committed
Rename BulkOperationResult -> BulkWriteResult
1 parent 78b6cb8 commit f99cde9

File tree

8 files changed

+43
-47
lines changed

8 files changed

+43
-47
lines changed

‎spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/BulkWriter.java‎

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -35,15 +35,14 @@
3535
import org.springframework.data.mongodb.core.bulk.BulkOperation.Update;
3636
import org.springframework.data.mongodb.core.bulk.BulkOperation.UpdateFirst;
3737
import org.springframework.data.mongodb.core.bulk.BulkOperationContext.TypedNamespace;
38-
import org.springframework.data.mongodb.core.bulk.BulkOperationResult;
38+
import org.springframework.data.mongodb.core.bulk.BulkWriteResult;
3939
import org.springframework.data.mongodb.core.bulk.BulkWriteOptions;
4040
import org.springframework.data.mongodb.core.mapping.MongoPersistentEntity;
4141
import org.springframework.data.mongodb.core.mapping.event.AfterSaveEvent;
4242
import org.springframework.util.StringUtils;
4343

4444
import com.mongodb.MongoBulkWriteException;
4545
import com.mongodb.MongoNamespace;
46-
import com.mongodb.bulk.BulkWriteResult;
4746
import com.mongodb.client.model.DeleteOptions;
4847
import com.mongodb.client.model.InsertOneModel;
4948
import com.mongodb.client.model.UpdateOptions;
@@ -66,7 +65,7 @@ class BulkWriter {
6665
this.template = template;
6766
}
6867

69-
public BulkOperationResult write(String defaultDatabase, Bulk bulk, BulkWriteOptions options) {
68+
public BulkWriteResult write(String defaultDatabase, Bulk bulk, BulkWriteOptions options) {
7069

7170
Set<TypedNamespace> namespaces = bulk.operations().stream().map(it -> it.context().namespace())
7271
.collect(Collectors.toSet());
@@ -76,7 +75,7 @@ public BulkOperationResult write(String defaultDatabase, Bulk bulk, BulkWriteOpt
7675
return writeToMultipleCollections(defaultDatabase, bulk, options);
7776
}
7877

79-
private BulkOperationResult writeToSingleCollection(String defaultDatabase, Bulk bulk,
78+
private BulkWriteResult writeToSingleCollection(String defaultDatabase, Bulk bulk,
8079
BulkWriteOptions options, TypedNamespace namespace) {
8180

8281
MongoNamespace mongoNamespace = new MongoNamespace(defaultDatabase,
@@ -87,7 +86,7 @@ private BulkOperationResult writeToSingleCollection(String defaultDatabase, Bulk
8786
buildWriteModels(bulk, collector);
8887

8988
try {
90-
BulkWriteResult bulkWriteResult = template.execute(collector.getNamespace().getCollectionName(),
89+
com.mongodb.bulk.BulkWriteResult bulkWriteResult = template.execute(collector.getNamespace().getCollectionName(),
9190
collection -> collection.bulkWrite(collector.getWriteModels(), new com.mongodb.client.model.BulkWriteOptions()
9291
.ordered(options.getOrder().equals(BulkWriteOptions.Order.ORDERED))));
9392

@@ -96,7 +95,7 @@ private BulkOperationResult writeToSingleCollection(String defaultDatabase, Bulk
9695
.maybeEmitEvent(new AfterSaveEvent<>(callable.source(), callable.document(), callable.collectionName()));
9796
template.maybeCallAfterSave(callable.source(), callable.document(), callable.collectionName());
9897
});
99-
return BulkOperationResult.from(bulkWriteResult);
98+
return BulkWriteResult.from(bulkWriteResult);
10099
} catch (MongoBulkWriteException e) {
101100
DataAccessException dataAccessException = template.getExceptionTranslator().translateExceptionIfPossible(e);
102101
if (dataAccessException != null) {
@@ -106,7 +105,7 @@ private BulkOperationResult writeToSingleCollection(String defaultDatabase, Bulk
106105
}
107106
}
108107

109-
private BulkOperationResult writeToMultipleCollections(String defaultDatabase, Bulk bulk,
108+
private BulkWriteResult writeToMultipleCollections(String defaultDatabase, Bulk bulk,
110109
BulkWriteOptions options) {
111110

112111
MultiCollectionCollector collector = new MultiCollectionCollector(defaultDatabase);
@@ -123,7 +122,7 @@ private BulkOperationResult writeToMultipleCollections(String defaultDatabase, B
123122
.maybeEmitEvent(new AfterSaveEvent<>(callable.source(), callable.document(), callable.collectionName()));
124123
template.maybeCallAfterSave(callable.source(), callable.document(), callable.collectionName());
125124
});
126-
return BulkOperationResult.from(clientBulkWriteResult);
125+
return BulkWriteResult.from(clientBulkWriteResult);
127126
} catch (MongoBulkWriteException e) {
128127
DataAccessException dataAccessException = template.getExceptionTranslator().translateExceptionIfPossible(e);
129128
if (dataAccessException != null) {

‎spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoOperations.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@
3939
import org.springframework.data.mongodb.core.aggregation.AggregationUpdate;
4040
import org.springframework.data.mongodb.core.aggregation.TypedAggregation;
4141
import org.springframework.data.mongodb.core.bulk.Bulk;
42-
import org.springframework.data.mongodb.core.bulk.BulkOperationResult;
42+
import org.springframework.data.mongodb.core.bulk.BulkWriteResult;
4343
import org.springframework.data.mongodb.core.bulk.BulkWriteOptions;
4444
import org.springframework.data.mongodb.core.convert.MappingMongoConverter;
4545
import org.springframework.data.mongodb.core.convert.MongoConverter;
@@ -179,7 +179,7 @@ public interface MongoOperations extends FluentMongoOperations {
179179
* @param options additional options applied to the execution.
180180
* @return never {@literal null}.
181181
*/
182-
BulkOperationResult bulkWrite(Bulk bulk, BulkWriteOptions options);
182+
BulkWriteResult bulkWrite(Bulk bulk, BulkWriteOptions options);
183183

184184
/**
185185
* Obtain a {@link ClientSession session} bound instance of {@link SessionScoped} binding a new {@link ClientSession}

‎spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoTemplate.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@
8989
import org.springframework.data.mongodb.core.aggregation.AggregationResults;
9090
import org.springframework.data.mongodb.core.aggregation.TypedAggregation;
9191
import org.springframework.data.mongodb.core.bulk.Bulk;
92-
import org.springframework.data.mongodb.core.bulk.BulkOperationResult;
92+
import org.springframework.data.mongodb.core.bulk.BulkWriteResult;
9393
import org.springframework.data.mongodb.core.bulk.BulkWriteOptions;
9494
import org.springframework.data.mongodb.core.convert.DbRefResolver;
9595
import org.springframework.data.mongodb.core.convert.DefaultDbRefResolver;
@@ -686,7 +686,7 @@ protected void executeQuery(Query query, String collectionName, DocumentCallback
686686
}
687687

688688
@Override
689-
public BulkOperationResult bulkWrite(Bulk bulk, BulkWriteOptions options) {
689+
public BulkWriteResult bulkWrite(Bulk bulk, BulkWriteOptions options) {
690690
return new BulkWriter(this).write(getDb().getName(), bulk, options);
691691
}
692692

‎spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ReactiveBulkWriter.java‎

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -37,20 +37,18 @@
3737
import org.springframework.data.mongodb.core.bulk.BulkOperation.Update;
3838
import org.springframework.data.mongodb.core.bulk.BulkOperation.UpdateFirst;
3939
import org.springframework.data.mongodb.core.bulk.BulkOperationContext.TypedNamespace;
40-
import org.springframework.data.mongodb.core.bulk.BulkOperationResult;
40+
import org.springframework.data.mongodb.core.bulk.BulkWriteResult;
4141
import org.springframework.data.mongodb.core.bulk.BulkWriteOptions;
4242
import org.springframework.data.mongodb.core.mapping.MongoPersistentEntity;
4343
import org.springframework.data.mongodb.core.mapping.event.AfterSaveEvent;
4444
import org.springframework.util.StringUtils;
4545

4646
import com.mongodb.MongoNamespace;
47-
import com.mongodb.bulk.BulkWriteResult;
4847
import com.mongodb.client.model.DeleteOptions;
4948
import com.mongodb.client.model.InsertOneModel;
5049
import com.mongodb.client.model.UpdateOptions;
5150
import com.mongodb.client.model.WriteModel;
5251
import com.mongodb.client.model.bulk.ClientBulkWriteOptions;
53-
import com.mongodb.client.model.bulk.ClientBulkWriteResult;
5452
import com.mongodb.client.model.bulk.ClientNamespacedWriteModel;
5553

5654
/**
@@ -67,7 +65,7 @@ class ReactiveBulkWriter {
6765
this.template = template;
6866
}
6967

70-
public Mono<BulkOperationResult> write(String defaultDatabase, Bulk bulk, BulkWriteOptions options) {
68+
public Mono<BulkWriteResult> write(String defaultDatabase, Bulk bulk, BulkWriteOptions options) {
7169

7270
Set<TypedNamespace> namespaces = bulk.operations().stream().map(it -> it.context().namespace())
7371
.collect(Collectors.toSet());
@@ -77,7 +75,7 @@ public Mono<BulkOperationResult> write(String defaultDatabase, Bulk bulk, BulkWr
7775
return writeToMultipleCollections(defaultDatabase, bulk, options);
7876
}
7977

80-
private Mono<BulkOperationResult> writeToSingleCollection(String defaultDatabase, Bulk bulk,
78+
private Mono<BulkWriteResult> writeToSingleCollection(String defaultDatabase, Bulk bulk,
8179
BulkWriteOptions options, TypedNamespace namespace) {
8280

8381
MongoNamespace mongoNamespace = new MongoNamespace(defaultDatabase,
@@ -96,7 +94,7 @@ private Mono<BulkOperationResult> writeToSingleCollection(String defaultDatabase
9694
new com.mongodb.client.model.BulkWriteOptions()
9795
.ordered(options.getOrder().equals(BulkWriteOptions.Order.ORDERED))))
9896
.map(
99-
BulkOperationResult::from)
97+
BulkWriteResult::from)
10098
.doOnSuccess(
10199
v -> afterSaveCallables
102100
.forEach(callable -> template.maybeEmitEvent(new AfterSaveEvent<>(callable.source(),
@@ -107,7 +105,7 @@ private Mono<BulkOperationResult> writeToSingleCollection(String defaultDatabase
107105
}));
108106
}
109107

110-
private Mono<BulkOperationResult> writeToMultipleCollections(String defaultDatabase, Bulk bulk,
108+
private Mono<BulkWriteResult> writeToMultipleCollections(String defaultDatabase, Bulk bulk,
111109
BulkWriteOptions options) {
112110

113111
MultiCollectionCollector collector = new MultiCollectionCollector(defaultDatabase);
@@ -121,7 +119,7 @@ private Mono<BulkOperationResult> writeToMultipleCollections(String defaultDatab
121119
ClientBulkWriteOptions
122120
.clientBulkWriteOptions().ordered(options.getOrder().equals(BulkWriteOptions.Order.ORDERED))))
123121
.map(
124-
BulkOperationResult::from)
122+
BulkWriteResult::from)
125123
.doOnSuccess(
126124
v -> afterSaveCallables
127125
.forEach(callable -> template.maybeEmitEvent(new AfterSaveEvent<>(callable.source(),

‎spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ReactiveMongoOperations.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@
4141
import org.springframework.data.mongodb.core.aggregation.AggregationUpdate;
4242
import org.springframework.data.mongodb.core.aggregation.TypedAggregation;
4343
import org.springframework.data.mongodb.core.bulk.Bulk;
44-
import org.springframework.data.mongodb.core.bulk.BulkOperationResult;
44+
import org.springframework.data.mongodb.core.bulk.BulkWriteResult;
4545
import org.springframework.data.mongodb.core.convert.MappingMongoConverter;
4646
import org.springframework.data.mongodb.core.convert.MongoConverter;
4747
import org.springframework.data.mongodb.core.index.ReactiveIndexOperations;
@@ -170,7 +170,7 @@ public interface ReactiveMongoOperations extends ReactiveFluentMongoOperations {
170170
* @param options additional options applied to the execution.
171171
* @return never {@literal null}.
172172
*/
173-
Mono<BulkOperationResult> bulkWrite(Bulk bulk, BulkWriteOptions options);
173+
Mono<BulkWriteResult> bulkWrite(Bulk bulk, BulkWriteOptions options);
174174

175175
/**
176176
* Obtain a {@link ClientSession session} bound instance of {@link SessionScoped} binding the {@link ClientSession}

‎spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ReactiveMongoTemplate.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@
8282
import org.springframework.data.mongodb.core.EntityOperations.AdaptibleEntity;
8383
import org.springframework.data.mongodb.core.EntityOperations.Entity;
8484
import org.springframework.data.mongodb.core.bulk.Bulk;
85-
import org.springframework.data.mongodb.core.bulk.BulkOperationResult;
85+
import org.springframework.data.mongodb.core.bulk.BulkWriteResult;
8686
import org.springframework.data.mongodb.core.QueryOperations.AggregationDefinition;
8787
import org.springframework.data.mongodb.core.QueryOperations.CountContext;
8888
import org.springframework.data.mongodb.core.QueryOperations.DeleteContext;
@@ -840,7 +840,7 @@ <T> Mono<T> doWithClient(Function<MongoCluster, Publisher<T>> callback) {
840840
}
841841

842842
@Override
843-
public Mono<BulkOperationResult> bulkWrite(Bulk bulk, BulkWriteOptions options) {
843+
public Mono<BulkWriteResult> bulkWrite(Bulk bulk, BulkWriteOptions options) {
844844

845845
return doGetDatabase().flatMap(db -> new ReactiveBulkWriter(this).write(db.getName(), bulk, options));
846846
}

spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/bulk/BulkOperationResult.java renamed to spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/bulk/BulkWriteResult.java

Lines changed: 10 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -15,28 +15,27 @@
1515
*/
1616
package org.springframework.data.mongodb.core.bulk;
1717

18-
import com.mongodb.bulk.BulkWriteResult;
1918
import com.mongodb.client.model.bulk.ClientBulkWriteResult;
2019

2120
/**
2221
* Result of a {@link Bulk} write execution. Exposes counts for inserted, modified, deleted, and upserted documents, and
2322
* whether the operation was acknowledged by the server. Abstracts over both single-collection
24-
* ({@link BulkWriteResult}) and multi-collection ({@link ClientBulkWriteResult}) driver results.
23+
* ({@link com.mongodb.bulk.BulkWriteResult}) and multi-collection ({@link ClientBulkWriteResult}) driver results.
2524
*
2625
* @author Christoph Strobl
2726
* @since 5.1
2827
*/
29-
public interface BulkOperationResult {
28+
public interface BulkWriteResult {
3029

3130
/**
32-
* Creates a {@link BulkOperationResult} from a MongoDB driver {@link ClientBulkWriteResult}.
31+
* Creates a {@link BulkWriteResult} from a MongoDB driver {@link ClientBulkWriteResult}.
3332
*
3433
* @param result the driver result; must not be {@literal null}.
35-
* @return a new {@link BulkOperationResult} wrapping the given result; never {@literal null}.
34+
* @return a new {@link BulkWriteResult} wrapping the given result; never {@literal null}.
3635
*/
37-
static BulkOperationResult from(ClientBulkWriteResult result) {
36+
static BulkWriteResult from(ClientBulkWriteResult result) {
3837

39-
return new BulkOperationResult() {
38+
return new BulkWriteResult() {
4039
@Override
4140
public long insertCount() {
4241
return result.getInsertedCount();
@@ -70,13 +69,13 @@ public long matchedCount() {
7069
}
7170

7271
/**
73-
* Creates a {@link BulkOperationResult} from a MongoDB driver {@link BulkWriteResult}.
72+
* Creates a {@link BulkWriteResult} from a MongoDB driver {@link com.mongodb.bulk.BulkWriteResult}.
7473
*
7574
* @param result the driver result; must not be {@literal null}.
76-
* @return a new {@link BulkOperationResult} wrapping the given result; never {@literal null}.
75+
* @return a new {@link BulkWriteResult} wrapping the given result; never {@literal null}.
7776
*/
78-
static BulkOperationResult from(BulkWriteResult result) {
79-
return new BulkOperationResult() {
77+
static BulkWriteResult from(com.mongodb.bulk.BulkWriteResult result) {
78+
return new BulkWriteResult() {
8079
@Override
8180
public long insertCount() {
8281
return result.getInsertedCount();

‎spring-data-mongodb/src/test/java/org/springframework/data/mongodb/core/MongoTemplateBulkTests.java‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626
import org.junit.jupiter.api.BeforeEach;
2727
import org.junit.jupiter.api.Test;
2828
import org.springframework.data.mongodb.core.bulk.Bulk;
29-
import org.springframework.data.mongodb.core.bulk.BulkOperationResult;
29+
import org.springframework.data.mongodb.core.bulk.BulkWriteResult;
3030
import org.springframework.data.mongodb.core.bulk.BulkWriteOptions;
3131
import org.springframework.data.mongodb.core.query.Query;
3232
import org.springframework.data.mongodb.core.query.Update;
@@ -98,7 +98,7 @@ void insertOrderedAcrossCollections() {
9898

9999
Bulk bulk = Bulk.builder().inCollection(BaseDoc.class, ops -> ops.insert(doc1).insert(doc2))
100100
.inCollection(SpecialDoc.class).insert(specialDoc).build();
101-
BulkOperationResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
101+
BulkWriteResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
102102

103103
assertThat(result.insertCount()).isEqualTo(3);
104104

@@ -142,7 +142,7 @@ void insertUnOrderedAcrossCollections() {
142142

143143
Bulk bulk = Bulk.builder().inCollection(BaseDoc.class, ops -> ops.insert(doc1).insert(doc2))
144144
.inCollection(SpecialDoc.class).insert(specialDoc).build();
145-
BulkOperationResult result = operations.bulkWrite(bulk, BulkWriteOptions.unordered());
145+
BulkWriteResult result = operations.bulkWrite(bulk, BulkWriteOptions.unordered());
146146

147147
assertThat(result.insertCount()).isEqualTo(3);
148148
Long baseCount = operations.execute(BaseDoc.class, MongoCollection::countDocuments);
@@ -190,7 +190,7 @@ void updateOneAcrossCollections() {
190190
.inCollection(BaseDoc.class, ops -> updatesBase.forEach(p -> ops.updateOne(p.getFirst(), p.getSecond())))
191191
.inCollection(SpecialDoc.class, ops -> updatesSpecial.forEach(p -> ops.updateOne(p.getFirst(), p.getSecond())))
192192
.build();
193-
BulkOperationResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
193+
BulkWriteResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
194194

195195
assertThat(result.modifiedCount()).isEqualTo(2);
196196

@@ -219,7 +219,7 @@ void updateMultiAcrossCollections() {
219219
.inCollection(SpecialDoc.class,
220220
ops -> updatesSpecial.forEach(p -> ops.updateMulti(p.getFirst(), p.getSecond())))
221221
.build();
222-
BulkOperationResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
222+
BulkWriteResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
223223

224224
assertThat(result.modifiedCount()).isEqualTo(8);
225225

@@ -245,7 +245,7 @@ void upsertDoesUpdateInEachCollection() {
245245
.inCollection(BaseDoc.class, ops -> ops.upsert(queryWhere("value", "value1"), set("value", "value2")))
246246
.inCollection(SpecialDoc.class, ops -> ops.upsert(queryWhere("value", "value1"), set("value", "value2")))
247247
.build();
248-
BulkOperationResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
248+
BulkWriteResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
249249

250250
assertThat(result.matchedCount()).isEqualTo(4);
251251
assertThat(result.modifiedCount()).isEqualTo(4);
@@ -260,7 +260,7 @@ void upsertDoesInsertInEachCollection() {
260260
.inCollection(BaseDoc.class, ops -> ops.upsert(queryWhere("_id", "new-id-1"), set("value", "upserted1")))
261261
.inCollection(SpecialDoc.class, ops -> ops.upsert(queryWhere("_id", "new-id-2"), set("value", "upserted2")))
262262
.build();
263-
BulkOperationResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
263+
BulkWriteResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
264264

265265
assertThat(result.matchedCount()).isZero();
266266
assertThat(result.modifiedCount()).isZero();
@@ -281,7 +281,7 @@ void removeAcrossCollections() {
281281

282282
Bulk bulk = Bulk.builder().inCollection(BaseDoc.class, ops -> removesBase.forEach(ops::remove))
283283
.inCollection(SpecialDoc.class, ops -> removesSpecial.forEach(ops::remove)).build();
284-
BulkOperationResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
284+
BulkWriteResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
285285

286286
assertThat(result.deleteCount()).isEqualTo(6);
287287

@@ -304,7 +304,7 @@ void replaceOneAcrossCollections() {
304304
Bulk bulk = Bulk.builder()
305305
.inCollection(BaseDoc.class, ops -> ops.replaceOne(queryWhere("_id", "1"), replacementBase))
306306
.inCollection(SpecialDoc.class, ops -> ops.replaceOne(queryWhere("_id", "1"), replacementSpecial)).build();
307-
BulkOperationResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
307+
BulkWriteResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
308308

309309
assertThat(result.matchedCount()).isEqualTo(2);
310310
assertThat(result.modifiedCount()).isEqualTo(2);
@@ -322,7 +322,7 @@ void replaceOneWithUpsertInCollection() {
322322

323323
Bulk bulk = Bulk.builder()
324324
.inCollection(BaseDoc.class, ops -> ops.replaceOne(queryWhere("_id", "new-id"), replacement)).build();
325-
BulkOperationResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
325+
BulkWriteResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
326326

327327
assertThat(result.matchedCount()).isZero();
328328
assertThat(result.modifiedCount()).isZero();
@@ -342,7 +342,7 @@ void mixedBulkOrderedAcrossCollections() {
342342
Bulk bulk = Bulk.builder().inCollection(BaseDoc.class,
343343
ops -> ops.insert(doc1).updateOne(queryWhere("_id", "1"), set("value", "v2")).remove(queryWhere("value", "v2")))
344344
.inCollection(SpecialDoc.class).insert(doc2).build();
345-
BulkOperationResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
345+
BulkWriteResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
346346

347347
assertThat(result.insertCount()).isEqualTo(2);
348348
assertThat(result.modifiedCount()).isOne();
@@ -371,7 +371,7 @@ void mixedBulkOrderedWithListAcrossCollections() {
371371
updatesBase.forEach(p -> ops.updateMulti(p.getFirst(), p.getSecond()));
372372
removesBase.forEach(ops::remove);
373373
}).inCollection(SpecialDoc.class).insert(specialDoc).build();
374-
BulkOperationResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
374+
BulkWriteResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
375375

376376
assertThat(result.insertCount()).isEqualTo(4);
377377
assertThat(result.modifiedCount()).isEqualTo(2);

0 commit comments

Comments
 (0)