insert from query

Author: ahmad-moussawi

SqlKata.Execution/Query.Extensions.Async.cs

@@ -142,6 +142,17 @@ public static async Task<int> InsertAsync(this Query query, IReadOnlyDictionary<
             return await xQuery.Connection.ExecuteAsync(compiled.Sql, compiled.Bindings);
         }
 
+        public static async Task<int> InsertAsync(this Query query, IEnumerable<string> columns, Query fromQuery)
+        {
+
+            var xQuery = QueryHelper.CastToXQuery(query, nameof(InsertAsync));
+
+            var compiled = xQuery.Compiler.Compile(query.AsInsert(columns, fromQuery));
+
+            return await xQuery.Connection.ExecuteAsync(compiled.Sql, compiled.Bindings);
+
+        }
+
         public static async Task<int> UpdateAsync(this Query query, IReadOnlyDictionary<string, object> values)
         {
             var xQuery = QueryHelper.CastToXQuery(query, nameof(UpdateAsync));

SqlKata.Execution/Query.Extensions.cs

@@ -143,6 +143,17 @@ public static int Insert(this Query query, IReadOnlyDictionary<string, object> v
 
         }
 
+        public static int Insert(this Query query, IEnumerable<string> columns, Query fromQuery)
+        {
+
+            var xQuery = QueryHelper.CastToXQuery(query, nameof(Insert));
+
+            var compiled = xQuery.Compiler.Compile(query.AsInsert(columns, fromQuery));
+
+            return xQuery.Connection.Execute(compiled.Sql, compiled.Bindings);
+
+        }
+
         public static int Update(this Query query, IReadOnlyDictionary<string, object> values)
         {
             var xQuery = QueryHelper.CastToXQuery(query, nameof(Update));