Skip to content

Commit 0f503f7

Browse files
committed
Add async overload for columns+values insert
1 parent 8173d4f commit 0f503f7

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

SqlKata.Execution/Query.Extensions.cs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -168,6 +168,11 @@ public static int Insert(this Query query, IEnumerable<string> columns, IEnumera
168168
return CreateQueryFactory(query).Execute(query.AsInsert(columns, valuesCollection), transaction, timeout);
169169
}
170170

171+
public static async Task<int> InsertAsync(this Query query, IEnumerable<string> columns, IEnumerable<IEnumerable<object>> valuesCollection, IDbTransaction transaction = null, int? timeout = null)
172+
{
173+
return await CreateQueryFactory(query).ExecuteAsync(query.AsInsert(columns, valuesCollection), transaction, timeout);
174+
}
175+
171176
public static int Insert(this Query query, IEnumerable<string> columns, Query fromQuery, IDbTransaction transaction = null, int? timeout = null)
172177
{
173178
return CreateQueryFactory(query).Execute(query.AsInsert(columns, fromQuery), transaction, timeout);

0 commit comments

Comments
 (0)