add cancelation token for InsertAsync IEnumerable overload

ahmad-moussawi · ahmad-moussawi · commit e35774ba2b3e · 2021-05-31T23:59:23.000+03:00
diff --git a/SqlKata.Execution/Query.Extensions.cs b/SqlKata.Execution/Query.Extensions.cs
@@ -169,9 +169,9 @@ public static int Insert(this Query query, IEnumerable<string> columns, IEnumera
             return CreateQueryFactory(query).Execute(query.AsInsert(columns, valuesCollection), transaction, timeout);
         }
 
-        public static async Task<int> InsertAsync(this Query query, IEnumerable<string> columns, IEnumerable<IEnumerable<object>> valuesCollection, IDbTransaction transaction = null, int? timeout = null)
+        public static async Task<int> InsertAsync(this Query query, IEnumerable<string> columns, IEnumerable<IEnumerable<object>> valuesCollection, IDbTransaction transaction = null, int? timeout = null, CancellationToken cancellationToken = default)
         {
-            return await CreateQueryFactory(query).ExecuteAsync(query.AsInsert(columns, valuesCollection), transaction, timeout);
+            return await CreateQueryFactory(query).ExecuteAsync(query.AsInsert(columns, valuesCollection), transaction, timeout, cancellationToken);
         }
 
         public static int Insert(this Query query, IEnumerable<string> columns, Query fromQuery, IDbTransaction transaction = null, int? timeout = null)

Original file line number	Diff line number	Diff line change
`@@ -169,9 +169,9 @@ public static int Insert(this Query query, IEnumerable<string> columns, IEnumera`
`169`	`169`	`return CreateQueryFactory(query).Execute(query.AsInsert(columns, valuesCollection), transaction, timeout);`
`170`	`170`	`}`
`171`	`171`
`172`		`- public static async Task<int> InsertAsync(this Query query, IEnumerable<string> columns, IEnumerable<IEnumerable<object>> valuesCollection, IDbTransaction transaction = null, int? timeout = null)`
	`172`	`+ public static async Task<int> InsertAsync(this Query query, IEnumerable<string> columns, IEnumerable<IEnumerable<object>> valuesCollection, IDbTransaction transaction = null, int? timeout = null, CancellationToken cancellationToken = default)`
`173`	`173`	`{`
`174`		`- return await CreateQueryFactory(query).ExecuteAsync(query.AsInsert(columns, valuesCollection), transaction, timeout);`
	`174`	`+ return await CreateQueryFactory(query).ExecuteAsync(query.AsInsert(columns, valuesCollection), transaction, timeout, cancellationToken);`
`175`	`175`	`}`
`176`	`176`
`177`	`177`	`public static int Insert(this Query query, IEnumerable<string> columns, Query fromQuery, IDbTransaction transaction = null, int? timeout = null)`