* Refactory

Author: Cesar Romero Silva

BulkOperation.cs

@@ -15,10 +15,10 @@ public static class BulkOperation
                 await connection.OpenAsync(cancellationToken).ConfigureAwait(true);
 
                 const int recordsToGenerate = 100_000;
-                Log.Write($"Gerando {recordsToGenerate:n0} registros clientes");
+                ConsoleLog.Write($"Gerando {recordsToGenerate:n0} registros clientes");
                 var customers = Customer.Generate(recordsToGenerate);
 
-                Log.Write("Inserindo registros no banco de dados");
+                ConsoleLog.Write("Inserindo registros no banco de dados");
                 using (var insertBulk = new SqlBulkCopy(connection, SqlBulkCopyOptions.Default, null))
                 {
                     using (var customerReader = new ObjectDataReader<Customer>(customers.GetEnumerator()))
@@ -33,26 +33,26 @@ public static class BulkOperation
                 {
                     try
                     {
-                        Log.Write("Criando tabela temporária e copiando registros");
+                        ConsoleLog.Write("Criando tabela temporária e copiando registros");
                         command.CommandText = BulkUpdate.CreateTempTable;
                         command.ExecuteNonQuery();
                         try
                         {
-                            Log.Write("Atualizando registros: Tabela temporária -> Customers");
+                            ConsoleLog.Write("Atualizando registros: Tabela temporária -> Customers");
                             command.CommandTimeout = 300;
                             command.CommandText = BulkUpdate.UpdateTable;
                             command.ExecuteNonQuery();
                         }
                         finally
                         {
-                            Log.Write("Excluindo tabela temporária");
+                            ConsoleLog.Write("Excluindo tabela temporária");
                             command.CommandText = BulkUpdate.DropTempTable;
                             command.ExecuteNonQuery();
                         }
                     }
                     catch (Exception e)
                     {
-                        Log.Write(e.Message);
+                        ConsoleLog.Write(e.Message);
                     }
                 }
             }
@@ -77,13 +77,13 @@ private static void MapEntity(this SqlBulkCopy bulk, string tableName)
         private static void ConfigureOptions(this SqlBulkCopy bulk)
         {
             bulk.EnableStreaming = true;
-            bulk.BatchSize = 10_000;
-            bulk.NotifyAfter = 1_000;
+            bulk.BatchSize   = 10_000;
+            bulk.NotifyAfter =  1_000;
         }
 
         private static void ConfigureLog(this SqlBulkCopy bulk)
         {
-            bulk.SqlRowsCopied += (sender, e) => Log.Write($"{DateTime.Now} RowsCopied: {e.RowsCopied:n0}");
+            bulk.SqlRowsCopied += (sender, e) => ConsoleLog.Write($"{DateTime.Now} RowsCopied: {e.RowsCopied:n0}");
         }
     }
 }

Log.cs renamed to ConsoleLog.cs

@@ -2,7 +2,7 @@
 
 namespace BulkOperations
 {
-    public static class Log
+    public static class ConsoleLog
     {
         public static void Write(string value)
         {

ObjectDataReader.cs

@@ -16,9 +16,9 @@ namespace BulkOperations
     public class ObjectDataReader<T> : DbDataReader
     {
         private readonly IEnumerator<T> _iterator;
-        private readonly IDictionary<string, int> _propertyNameToOrdinal = new Dictionary<string, int>();
-        private readonly IDictionary<int, string> _ordinalToPropertyName = new Dictionary<int, string>();
-        private Func<T, object>[] _getPropertyValueFuncs;
+        private readonly IDictionary<string, int> _propToOrdinalTable = new Dictionary<string, int>();
+        private readonly IDictionary<int, string> _ordinalToPropTable = new Dictionary<int, string>();
+        private Func<T, object>[] _getPropValueFunc;
 
         public ObjectDataReader(IEnumerator<T> items)
         {
@@ -29,14 +29,14 @@ public ObjectDataReader(IEnumerator<T> items)
         private void Initialize()
         {
             var properties = typeof(T).GetProperties();
-            _getPropertyValueFuncs = new Func<T, object>[properties.Length];
+            _getPropValueFunc = new Func<T, object>[properties.Length];
 
             var ordinal = 0;
             foreach (var property in properties)
             {
                 var propertyName = property.Name;
-                _propertyNameToOrdinal.Add(propertyName, ordinal);
-                _ordinalToPropertyName.Add(ordinal, propertyName);
+                _propToOrdinalTable.Add(propertyName, ordinal);
+                _ordinalToPropTable.Add(ordinal, propertyName);
 
                 var parameterExpression = Expression.Parameter(typeof(T), "x");
                 var func = (Func<T, object>)Expression.Lambda(
@@ -46,7 +46,7 @@ private void Initialize()
                         parameterExpression)
                     .Compile();
 
-                _getPropertyValueFuncs[ordinal] = func;
+                _getPropValueFunc[ordinal] = func;
 
                 ordinal++;
             }
@@ -60,7 +60,7 @@ public override bool Read()
 
         public override int GetOrdinal(string name)
         {
-            return (_propertyNameToOrdinal.TryGetValue(name, out var ordinal)) ? ordinal : -1;
+            return (_propToOrdinalTable.TryGetValue(name, out var ordinal)) ? ordinal : -1;
         }
 
         public override bool IsDBNull(int ordinal)
@@ -70,11 +70,10 @@ public override bool IsDBNull(int ordinal)
 
         public override object GetValue(int ordinal)
         {
-            var func = _getPropertyValueFuncs[ordinal];
+            var func = _getPropValueFunc[ordinal];
             return func(_iterator.Current);
         }
 
-        // optional
         public override int GetValues(object[] values)
         {
             var max = Math.Min(values.Length, FieldCount);
@@ -92,13 +91,12 @@ public override int GetValues(object[] values)
 
         public override int Depth => 0;
 
-        public override int FieldCount => _ordinalToPropertyName.Count;
+        public override int FieldCount => _ordinalToPropTable.Count;
 
         public override bool HasRows => true;
 
         public override bool IsClosed => _iterator != null;
 
-        public override int RecordsAffected => throw new NotImplementedException();
 
         public override bool GetBoolean(int ordinal)
         {
@@ -110,26 +108,11 @@ public override byte GetByte(int ordinal)
             return (byte)GetValue(ordinal);
         }
 
-        public override long GetBytes(int ordinal, long dataOffset, byte[] buffer, int bufferOffset, int length)
-        {
-            throw new NotImplementedException();
-        }
-
         public override char GetChar(int ordinal)
         {
             return (char)GetValue(ordinal);
         }
 
-        public override long GetChars(int ordinal, long dataOffset, char[] buffer, int bufferOffset, int length)
-        {
-            throw new NotImplementedException();
-        }
-
-        public override string GetDataTypeName(int ordinal)
-        {
-            throw new NotImplementedException();
-        }
-
         public override DateTime GetDateTime(int ordinal)
         {
             return (DateTime)GetValue(ordinal);
@@ -145,11 +128,6 @@ public override double GetDouble(int ordinal)
             return (double)GetValue(ordinal);
         }
 
-        public override IEnumerator GetEnumerator()
-        {
-            throw new NotImplementedException();
-        }
-
         public override Type GetFieldType(int ordinal)
         {
             var value = GetValue(ordinal);
@@ -183,7 +161,7 @@ public override long GetInt64(int ordinal)
 
         public override string GetName(int ordinal)
         {
-            return _ordinalToPropertyName.TryGetValue(ordinal, out var name) ? name : null;
+            return _ordinalToPropTable.TryGetValue(ordinal, out var name) ? name : null;
         }
 
         public override string GetString(int ordinal)
@@ -195,5 +173,30 @@ public override bool NextResult()
         {
             return false;
         }
+
+        #region NotImplemented
+        public override int RecordsAffected => 
+            throw new NotImplementedException();
+
+        public override long GetBytes(int ordinal, long dataOffset, byte[] buffer, int bufferOffset, int length)
+        {
+            throw new NotImplementedException();
+        }
+
+        public override long GetChars(int ordinal, long dataOffset, char[] buffer, int bufferOffset, int length)
+        {
+            throw new NotImplementedException();
+        }
+
+        public override string GetDataTypeName(int ordinal)
+        {
+            throw new NotImplementedException();
+        }
+
+        public override IEnumerator GetEnumerator()
+        {
+            throw new NotImplementedException();
+        }
+        #endregion
     }
 }

Program.cs

@@ -10,14 +10,14 @@ private static void Main(string[] args)
             var stopwatch = new Stopwatch();
             stopwatch.Start();
 
-            Log.Write("Início processamento");
+            ConsoleLog.Write("Início processamento");
 
             BulkOperation.InsertAsync().Wait();
 
             stopwatch.Stop();
 
 
-            Log.Write($"Processamento concluído em {stopwatch.ElapsedTimeFmt()}");
+            ConsoleLog.Write($"Processamento concluído em {stopwatch.ElapsedTimeFmt()}");
 
             Console.WriteLine("");
             Console.WriteLine("Tecle <ENTER> para finalizar...");