Completely expose the 'fields' argument to 'InsertAll' operation. #523

mikependon · Aug 23, 2020 · 4033b48 · 4033b48
1 parent 65fe812
commit 4033b48
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 3 deletions.
diff --git a/RepoDb.Core/RepoDb/Operations/BaseRepository/InsertAll.cs b/RepoDb.Core/RepoDb/Operations/BaseRepository/InsertAll.cs
@@ -17,16 +17,19 @@ public abstract partial class BaseRepository<TEntity, TDbConnection> : IDisposab
         /// </summary>
         /// <param name="entities">The data entity objects to be inserted.</param>
         /// <param name="batchSize">The batch size of the insertion.</param>
+        /// <param name="fields">The mapping list of <see cref="Field"/> objects to be used.</param>
         /// <param name="hints">The table hints to be used.</param>
 		/// <param name="transaction">The transaction to be used.</param>
         /// <returns>The number of inserted rows in the table.</returns>
         public int InsertAll(IEnumerable<TEntity> entities,
             int batchSize = Constant.DefaultBatchOperationSize,
+            IEnumerable<Field> fields = null,
             string hints = null,
             IDbTransaction transaction = null)
         {
             return DbRepository.InsertAll<TEntity>(entities: entities,
                 batchSize: batchSize,
+                fields: fields,
                 hints: hints,
                 transaction: transaction);
         }
@@ -40,16 +43,19 @@ public int InsertAll(IEnumerable<TEntity> entities,
         /// </summary>
         /// <param name="entities">The data entity objects to be inserted.</param>
         /// <param name="batchSize">The batch size of the insertion.</param>
+        /// <param name="fields">The mapping list of <see cref="Field"/> objects to be used.</param>
         /// <param name="hints">The table hints to be used.</param>
 		/// <param name="transaction">The transaction to be used.</param>
         /// <returns>The number of inserted rows in the table.</returns>
         public Task<int> InsertAllAsync(IEnumerable<TEntity> entities,
             int batchSize = Constant.DefaultBatchOperationSize,
+            IEnumerable<Field> fields = null,
             string hints = null,
             IDbTransaction transaction = null)
         {
             return DbRepository.InsertAllAsync<TEntity>(entities: entities,
                 batchSize: batchSize,
+                fields: fields,
                 hints: hints,
                 transaction: transaction);
         }

diff --git a/RepoDb.Core/RepoDb/Operations/DbConnection/InsertAll.cs b/RepoDb.Core/RepoDb/Operations/DbConnection/InsertAll.cs
@@ -65,6 +65,7 @@ public static int InsertAll<TEntity>(this IDbConnection connection,
         /// <param name="connection">The connection object to be used.</param>
         /// <param name="entities">The list of data entity objects to be inserted.</param>
         /// <param name="batchSize">The batch size of the insertion.</param>
+        /// <param name="fields">The mapping list of <see cref="Field"/> objects to be used.</param>
         /// <param name="hints">The table hints to be used.</param>
         /// <param name="commandTimeout">The command timeout in seconds to be used.</param>
         /// <param name="transaction">The transaction to be used.</param>
@@ -74,6 +75,7 @@ public static int InsertAll<TEntity>(this IDbConnection connection,
         public static int InsertAll<TEntity>(this IDbConnection connection,
             IEnumerable<TEntity> entities,
             int batchSize = Constant.DefaultBatchOperationSize,
+            IEnumerable<Field> fields = null,
             string hints = null,
             int? commandTimeout = null,
             IDbTransaction transaction = null,
@@ -85,6 +87,7 @@ public static int InsertAll<TEntity>(this IDbConnection connection,
                 tableName: ClassMappedNameCache.Get<TEntity>(),
                 entities: entities,
                 batchSize: batchSize,
+                fields: fields,
                 hints: hints,
                 commandTimeout: commandTimeout,
                 transaction: transaction,
@@ -166,7 +169,7 @@ public static Task<int> InsertAllAsync<TEntity>(this IDbConnection connection,
                 tableName: tableName,
                 entities: entities,
                 batchSize: batchSize,
-                fields: GetQualifiedFields<TEntity>(fields, entities?.FirstOrDefault()),
+                fields: fields,
                 hints: hints,
                 commandTimeout: commandTimeout,
                 transaction: transaction,
@@ -181,6 +184,7 @@ public static Task<int> InsertAllAsync<TEntity>(this IDbConnection connection,
         /// <param name="connection">The connection object to be used.</param>
         /// <param name="entities">The list of data entity objects to be inserted.</param>
         /// <param name="batchSize">The batch size of the insertion.</param>
+        /// <param name="fields">The mapping list of <see cref="Field"/> objects to be used.</param>
         /// <param name="hints">The table hints to be used.</param>
         /// <param name="commandTimeout">The command timeout in seconds to be used.</param>
         /// <param name="transaction">The transaction to be used.</param>
@@ -190,6 +194,7 @@ public static Task<int> InsertAllAsync<TEntity>(this IDbConnection connection,
         public static Task<int> InsertAllAsync<TEntity>(this IDbConnection connection,
             IEnumerable<TEntity> entities,
             int batchSize = Constant.DefaultBatchOperationSize,
+            IEnumerable<Field> fields = null,
             string hints = null,
             int? commandTimeout = null,
             IDbTransaction transaction = null,
@@ -201,6 +206,7 @@ public static Task<int> InsertAllAsync<TEntity>(this IDbConnection connection,
                 tableName: ClassMappedNameCache.Get<TEntity>(),
                 entities: entities,
                 batchSize: batchSize,
+                fields: fields,
                 hints: hints,
                 commandTimeout: commandTimeout,
                 transaction: transaction,
@@ -276,7 +282,7 @@ public static int InsertAll(this IDbConnection connection,
             ITrace trace = null,
             IStatementBuilder statementBuilder = null)
         {
-            return InsertAllInternal(connection: connection,
+            return InsertAllInternal<object>(connection: connection,
                 tableName: tableName,
                 entities: entities,
                 batchSize: batchSize,
@@ -317,7 +323,7 @@ public static Task<int> InsertAllAsync(this IDbConnection connection,
             ITrace trace = null,
             IStatementBuilder statementBuilder = null)
         {
-            return InsertAllAsyncInternal(connection: connection,
+            return InsertAllAsyncInternal<object>(connection: connection,
                 tableName: tableName,
                 entities: entities,
                 batchSize: batchSize,

diff --git a/RepoDb.Core/RepoDb/Operations/DbRepository/InsertAll.cs b/RepoDb.Core/RepoDb/Operations/DbRepository/InsertAll.cs
@@ -67,11 +67,13 @@ public int InsertAll<TEntity>(string tableName,
         /// <typeparam name="TEntity">The type of the data entity.</typeparam>
         /// <param name="entities">The data entity objects to be inserted.</param>
         /// <param name="batchSize">The batch size of the insertion.</param>
+        /// <param name="fields">The mapping list of <see cref="Field"/> objects to be used.</param>
         /// <param name="hints">The table hints to be used.</param>
 		/// <param name="transaction">The transaction to be used.</param>
         /// <returns>The number of inserted rows in the table.</returns>
         public int InsertAll<TEntity>(IEnumerable<TEntity> entities,
             int batchSize = Constant.DefaultBatchOperationSize,
+            IEnumerable<Field> fields = null,
             string hints = null,
             IDbTransaction transaction = null)
             where TEntity : class
@@ -84,6 +86,7 @@ public int InsertAll<TEntity>(IEnumerable<TEntity> entities,
                 // Call the method
                 return connection.InsertAll<TEntity>(entities: entities,
                     batchSize: batchSize,
+                    fields: fields,
                     hints: hints,
                     commandTimeout: CommandTimeout,
                     transaction: transaction,
@@ -159,11 +162,13 @@ public async Task<int> InsertAllAsync<TEntity>(string tableName,
         /// <typeparam name="TEntity">The type of the data entity.</typeparam>
         /// <param name="entities">The data entity objects to be inserted.</param>
         /// <param name="batchSize">The batch size of the insertion.</param>
+        /// <param name="fields">The mapping list of <see cref="Field"/> objects to be used.</param>
         /// <param name="hints">The table hints to be used.</param>
 		/// <param name="transaction">The transaction to be used.</param>
         /// <returns>The number of inserted rows in the table.</returns>
         public async Task<int> InsertAllAsync<TEntity>(IEnumerable<TEntity> entities,
             int batchSize = Constant.DefaultBatchOperationSize,
+            IEnumerable<Field> fields = null,
             string hints = null,
             IDbTransaction transaction = null)
             where TEntity : class
@@ -176,6 +181,7 @@ public async Task<int> InsertAllAsync<TEntity>(IEnumerable<TEntity> entities,
                 // Call the method
                 return await connection.InsertAllAsync<TEntity>(entities: entities,
                     batchSize: batchSize,
+                    fields: fields,
                     hints: hints,
                     commandTimeout: CommandTimeout,
                     transaction: transaction,