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 {
532
532
ordered << [true , false ]
533
533
}
534
534
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
+
535
552
def ' should throw correct BulkWriteException when the number of writes is larger than the match write batch size ' (boolean ordered) {
536
553
given :
537
554
def operation = initializeBulkOperation(ordered)
You can’t perform that action at this time.
0 commit comments