Configurable batchsize

Author: MikaelEliasson

EntityFramework.Utilities/EntityFramework.Utilities/EFBatchOperation.cs

@@ -20,7 +20,8 @@ public interface IEFBatchOperationBase<TContext, T> where T : class
         /// </summary>
         /// <param name="items">The items to insert</param>
         /// <param name="connection">The DbConnection to use for the insert. Only needed when for example a profiler wraps the connection. Then you need to provide a connection of the type the provider use.</param>
-        void InsertAll(IEnumerable<T> items, DbConnection connection = null);
+        /// <param name="batchSize">The size of each batch. Default depends on the provider. SqlProvider uses 15000 as default</param>        
+        void InsertAll(IEnumerable<T> items, DbConnection connection = null, int? batchSize = null);
         IEFBatchOperationFiltered<TContext, T> Where(Expression<Func<T, bool>> predicate);
     }
 
@@ -66,7 +67,8 @@ public static IEFBatchOperationBase<TContext, T> For<TContext, T>(TContext conte
         /// </summary>
         /// <param name="items">The items to insert</param>
         /// <param name="connection">The DbConnection to use for the insert. Only needed when for example a profiler wraps the connection. Then you need to provide a connection of the type the provider use.</param>
-        public void InsertAll(IEnumerable<T> items, DbConnection connection = null)
+        /// <param name="batchSize">The size of each batch. Default depends on the provider. SqlProvider uses 15000 as default</param>
+        public void InsertAll(IEnumerable<T> items, DbConnection connection = null, int? batchSize = null)
         {
             var con = context.Connection as EntityConnection;
             if (con == null)
@@ -87,7 +89,7 @@ public void InsertAll(IEnumerable<T> items, DbConnection connection = null)
 
                 var properties = tableMapping.PropertyMappings.Select(p => new ColumnMapping { NameInDatabase = p.ColumnName, NameOnObject = p.PropertyName }).ToList();
 
-                provider.InsertItems(items, tableMapping.Schema, tableMapping.TableName, properties, connectionToUse);
+                provider.InsertItems(items, tableMapping.Schema, tableMapping.TableName, properties, connectionToUse, batchSize);
             }
             else
             {

EntityFramework.Utilities/EntityFramework.Utilities/IQueryProvider.cs

@@ -14,7 +14,7 @@ public interface IQueryProvider
 
         string GetDeleteQuery(QueryInformation queryInformation);
         string GetUpdateQuery(QueryInformation predicateQueryInfo, QueryInformation modificationQueryInfo);
-        void InsertItems<T>(IEnumerable<T> items, string schema, string tableName, IList<ColumnMapping> properties, DbConnection storeConnection);
+        void InsertItems<T>(IEnumerable<T> items, string schema, string tableName, IList<ColumnMapping> properties, DbConnection storeConnection, int? batchSize);
 
         bool CanHandle(DbConnection storeConnection);
 

EntityFramework.Utilities/EntityFramework.Utilities/Properties/AssemblyInfo.cs

@@ -32,5 +32,5 @@
 // You can specify all the values or you can default the Build and Revision Numbers 
 // by using the '*' as shown below:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("0.4.2.0")]
-[assembly: AssemblyFileVersion("0.4.2.0")]
+[assembly: AssemblyVersion("0.5.0.0")]
+[assembly: AssemblyFileVersion("0.5.0.0")]

EntityFramework.Utilities/EntityFramework.Utilities/SqlQueryProvider.cs

@@ -46,7 +46,7 @@ public string GetUpdateQuery(QueryInformation predicateQueryInfo, QueryInformati
             return string.Format("UPDATE [{0}].[{1}] SET {2} {3}", predicateQueryInfo.Schema, predicateQueryInfo.Table, updateSql, predicateQueryInfo.WhereSql);
         }
 
-        public void InsertItems<T>(IEnumerable<T> items, string schema, string tableName, IList<ColumnMapping> properties, DbConnection storeConnection)
+        public void InsertItems<T>(IEnumerable<T> items, string schema, string tableName, IList<ColumnMapping> properties, DbConnection storeConnection, int? batchSize)
         {
             using (var reader = new EFDataReader<T>(items, properties))
             {
@@ -57,7 +57,7 @@ public void InsertItems<T>(IEnumerable<T> items, string schema, string tableName
                 }
                 using (SqlBulkCopy copy = new SqlBulkCopy(con))
                 {
-                    copy.BatchSize = Math.Min(reader.RecordsAffected, 15000); //default batch size
+                    copy.BatchSize = Math.Min(reader.RecordsAffected, batchSize ?? 15000); //default batch size
                     if (!string.IsNullOrWhiteSpace(schema))
                     {
                         copy.DestinationTableName = string.Format("[{0}].[{1}]", schema, tableName);