Bulk update honours Transaction (fix issue ThatRendle#203)

ThatRendle · ThatRendle · commit bf472b9c5fb5 · 2012-07-12T16:03:51.000+01:00
diff --git a/Simple.Data.Ado/BulkUpdater.cs b/Simple.Data.Ado/BulkUpdater.cs
@@ -37,6 +37,10 @@ public int Update(AdoAdapter adapter, string tableName, IList<IDictionary<string
             using (connection.MaybeDisposable())
             using (var command = commandBuilder.GetRepeatableCommand(connection))
             {
+                if (transaction != null)
+                {
+                    command.Transaction = transaction;
+                }
                 connection.OpenIfClosed();
                 var propertyToParameterMap = CreatePropertyToParameterMap(data, table, command);
 
diff --git a/Simple.Data.BehaviourTest/TransactionTest.cs b/Simple.Data.BehaviourTest/TransactionTest.cs
@@ -152,6 +152,31 @@ public void TestUpdateWithStaticObject()
             Assert.AreEqual(1, mockDatabase.Parameters[3]);
             Assert.IsTrue(MockDbTransaction.CommitCalled);
         }
+        
+        [Test]
+        public void TestBulkUpdateWithStaticObject()
+        {
+            var mockDatabase = new MockDatabase();
+            dynamic database = CreateDatabase(mockDatabase);
+            var user = new User
+                           {
+                               Id = 1,
+                               Name = "Steve",
+                               Age = 50
+                           };
+            var users = new[] {user};
+            using (var transaction = database.BeginTransaction())
+            {
+                transaction.Users.Update(users);
+                transaction.Commit();
+            }
+            Assert.AreEqual("update [dbo].[Users] set [Name] = @p1, [Password] = @p2, [Age] = @p3 where [dbo].[Users].[Id] = @p4".ToLowerInvariant(), mockDatabase.Sql.ToLowerInvariant());
+            Assert.AreEqual("Steve", mockDatabase.Parameters[0]);
+            Assert.AreEqual(DBNull.Value, mockDatabase.Parameters[1]);
+            Assert.AreEqual(50, mockDatabase.Parameters[2]);
+            Assert.AreEqual(1, mockDatabase.Parameters[3]);
+            Assert.IsTrue(MockDbTransaction.CommitCalled);
+        }
 
         [Test]
         public void TestUpdateByWithStaticObject()
