File tree Expand file tree Collapse file tree 1 file changed +17
-0
lines changed Expand file tree Collapse file tree 1 file changed +17
-0
lines changed Original file line number Diff line number Diff line change @@ -532,6 +532,23 @@ class BulkWriteOperationSpecification extends FunctionalSpecification {
532532 ordered << [true , false ]
533533 }
534534
535+ def ' should insert all documents when the number of inserts is larger than the match write batch size ' (boolean ordered) {
536+ given :
537+ def operation = initializeBulkOperation(ordered)
538+ (0 .. 1001 ). each {
539+ operation. insert(new BasicDBObject (' _id' , it))
540+ }
541+
542+ when :
543+ operation. execute()
544+
545+ then :
546+ collection. count == 1002
547+
548+ where :
549+ ordered << [true , false ]
550+ }
551+
535552 def ' should throw correct BulkWriteException when the number of writes is larger than the match write batch size ' (boolean ordered) {
536553 given :
537554 def operation = initializeBulkOperation(ordered)
You can’t perform that action at this time.
0 commit comments