diff --git a/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteNonQueryItemsAsync/InsertHandlerAsync.cs b/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteNonQueryItemsAsync/InsertHandlerAsync.cs index f6483f4b7..b91b91964 100644 --- a/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteNonQueryItemsAsync/InsertHandlerAsync.cs +++ b/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteNonQueryItemsAsync/InsertHandlerAsync.cs @@ -15,7 +15,7 @@ namespace MongoDb.Ado.data public async Task HandleAsync(IMongoCollection collection, string json) { var doc = BsonDocument.Parse(json); - await collection.InsertOneAsync(doc); + await collection.InsertOneAsync(doc,null,token); return 1; } } diff --git a/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteNonQueryItemsAsync/InsertManyHandlerAsync.cs b/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteNonQueryItemsAsync/InsertManyHandlerAsync.cs index 18058dd23..67f647a3b 100644 --- a/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteNonQueryItemsAsync/InsertManyHandlerAsync.cs +++ b/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteNonQueryItemsAsync/InsertManyHandlerAsync.cs @@ -16,7 +16,7 @@ namespace MongoDb.Ado.data public async Task HandleAsync(IMongoCollection collection, string json) { var documents = ParseJsonArray(json); - await collection.InsertManyAsync(documents); + await collection.InsertManyAsync(documents,null,token); return documents.Count; } diff --git a/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteNonQueryItemsAsync/UpdateManyHandler.cs b/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteNonQueryItemsAsync/UpdateManyHandler.cs index 9731ddf36..5d6c271d7 100644 --- a/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteNonQueryItemsAsync/UpdateManyHandler.cs +++ b/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteNonQueryItemsAsync/UpdateManyHandler.cs @@ -21,7 +21,7 @@ namespace MongoDb.Ado.data { var filter = doc["filter"].AsBsonDocument; var update = doc["update"].AsBsonDocument; - var result =await collection.UpdateManyAsync(filter, update); + var result =await collection.UpdateManyAsync(filter, update,null,token); total += (int)result.ModifiedCount; } return total;