Skip to content

Commit dfe1a76

Browse files
szankniemeyer
authored andcommitted
Fix crash on bulk update and delete returned error.
1 parent 5088382 commit dfe1a76

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

bulk.go

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -312,15 +312,19 @@ func (b *Bulk) runInsert(action *bulkAction, result *BulkResult, berr *BulkError
312312

313313
func (b *Bulk) runUpdate(action *bulkAction, result *BulkResult, berr *BulkError) bool {
314314
lerr, err := b.c.writeOp(bulkUpdateOp(action.docs), b.ordered)
315-
result.Matched += lerr.N
316-
result.Modified += lerr.modified
315+
if lerr != nil {
316+
result.Matched += lerr.N
317+
result.Modified += lerr.modified
318+
}
317319
return b.checkSuccess(action, berr, lerr, err)
318320
}
319321

320322
func (b *Bulk) runRemove(action *bulkAction, result *BulkResult, berr *BulkError) bool {
321323
lerr, err := b.c.writeOp(bulkDeleteOp(action.docs), b.ordered)
322-
result.Matched += lerr.N
323-
result.Modified += lerr.modified
324+
if lerr != nil {
325+
result.Matched += lerr.N
326+
result.Modified += lerr.modified
327+
}
324328
return b.checkSuccess(action, berr, lerr, err)
325329
}
326330

0 commit comments

Comments
 (0)