* Reafactory

Author: Cesar Romero Silva

Diff for: BulkOperation.cs

@@ -12,17 +12,15 @@ public static void Run()
         {
             var stopwatch = new Stopwatch();
             stopwatch.Start();
-
             ConsoleLog.Write("Início processamento");
 
-            BulkOperation.InsertAsync().Wait();
+            InsertAsync().Wait();
 
             stopwatch.Stop();
-
             ConsoleLog.Write($"Processamento concluído em {stopwatch.ElapsedTimeFmt()}");
         }
 
-        public static async Task InsertAsync(CancellationToken cancellationToken = default(CancellationToken))
+        public static async Task InsertAsync(CancellationToken cancellationToken = default(CancellationToken), SqlTransaction transaction = null)
         {
             using (var connection = new SqlConnection())
             {
@@ -34,7 +32,7 @@ public static void Run()
                 var customers = Customer.Generate(recordsToGenerate);
 
                 ConsoleLog.Write("Inserindo registros no banco de dados");
-                using (var insertBulk = new SqlBulkCopy(connection, SqlBulkCopyOptions.Default, null))
+                using (var insertBulk = new SqlBulkCopy(connection, SqlBulkCopyOptions.Default, transaction))
                 {
                     using (var customerReader = new ObjectDataReader<Customer>(customers.GetEnumerator()))
                     {
@@ -92,8 +90,8 @@ 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)

Diff for: Customer.cs

@@ -31,9 +31,9 @@ public static IEnumerable<Customer> Generate(int count)
             {
                 yield return new Customer
                 {
-                    Id = Guid.NewGuid(),
-                    FirstName = "FirstName" + i,
-                    LastName = "LastName" + i,
+                    Id          = Guid.NewGuid(),
+                    FirstName   = "First Name " + i,
+                    LastName    = "Last Name "  + i,
                     DateOfBirth = DateTime.Now
                 };
             }

Diff for: ObjectDataReader.cs

@@ -15,14 +15,14 @@ namespace BulkOperations
     /// </summary>
     public class ObjectDataReader<T> : DbDataReader
     {
-        private readonly IEnumerator<T> _iterator;
+        private readonly IEnumerator<T> _items;
         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)
         {
-            _iterator = items ?? throw new ArgumentNullException(nameof(items));
+            _items = items ?? throw new ArgumentNullException(nameof(items));
             Initialize();
         }
 
@@ -52,10 +52,9 @@ private void Initialize()
             }
         }
 
-        // required
         public override bool Read()
         {
-            return _iterator.MoveNext();
+            return _items.MoveNext();
         }
 
         public override int GetOrdinal(string name)
@@ -71,7 +70,7 @@ public override bool IsDBNull(int ordinal)
         public override object GetValue(int ordinal)
         {
             var func = _getPropValueFunc[ordinal];
-            return func(_iterator.Current);
+            return func(_items.Current);
         }
 
         public override int GetValues(object[] values)
@@ -95,7 +94,7 @@ public override int GetValues(object[] values)
 
         public override bool HasRows => true;
 
-        public override bool IsClosed => _iterator != null;
+        public override bool IsClosed => _items != null;
 
 
         public override bool GetBoolean(int ordinal)

Diff for: StateMachineBug.cs

@@ -58,7 +58,8 @@ public StateMachineBug(string title)
             _machine = new StateMachine<State, Trigger>(State.Open);
 
             // Instantiate a new trigger with a parameter. 
-            _assignTrigger = _machine.SetTriggerParameters<string>(Trigger.Assign);
+            _assignTrigger = _machine
+                .SetTriggerParameters<string>(Trigger.Assign);
 
             // Configure the Open state
             _machine.Configure(State.Open)

Diff for: StateMachinePhoneCall.cs

@@ -92,7 +92,7 @@ public StateMachinePhoneCall(string caller)
                 .OnExit(t => StopCallTimer())
                 .InternalTransition(Trigger.MuteMicrophone, t => OnMute())
                 .InternalTransition(Trigger.UnmuteMicrophone, t => OnUnmute())
-                .InternalTransition<int>(_setVolumeTrigger, (volume, t) => OnSetVolume(volume))
+                .InternalTransition(_setVolumeTrigger, (volume, t) => OnSetVolume(volume))
                 .Permit(Trigger.LeftMessage, State.OffHook)
                 .Permit(Trigger.PlacedOnHold, State.OnHold);