Added test for transactions

Dapper.Contrib.Tests NET45/Dapper.Contrib.Tests NET45.csproj

@@ -35,6 +35,7 @@
     <Reference Include="System" />
     <Reference Include="System.Core" />
     <Reference Include="System.Data.SqlServerCe, Version=4.0.0.0, Culture=neutral, PublicKeyToken=89845dcd8080cc91, processorArchitecture=MSIL" />
+    <Reference Include="System.Transactions" />
     <Reference Include="System.Xml.Linq" />
     <Reference Include="System.Data.DataSetExtensions" />
     <Reference Include="Microsoft.CSharp" />

Dapper.Contrib.Tests/Dapper.Contrib.Tests.csproj

@@ -45,6 +45,7 @@
     <Reference Include="System" />
     <Reference Include="System.Core" />
     <Reference Include="System.Data.SqlServerCe, Version=4.0.0.0, Culture=neutral, PublicKeyToken=89845dcd8080cc91, processorArchitecture=MSIL" />
+    <Reference Include="System.Transactions" />
     <Reference Include="System.Xml.Linq" />
     <Reference Include="System.Data.DataSetExtensions" />
     <Reference Include="Microsoft.CSharp" />

Dapper.Contrib.Tests/Tests.cs

@@ -3,6 +3,7 @@
 using System.IO;
 using System.Linq;
 using System.Reflection;
+using System.Transactions;
 using Dapper.Contrib.Extensions;
 using System.Collections.Generic;
 using System;
@@ -54,6 +55,15 @@ private IDbConnection GetOpenConnection()
             return connection;
         }
 
+        private IDbConnection GetConnection()
+        {
+            var projLoc = Assembly.GetAssembly(GetType()).Location;
+            var projFolder = Path.GetDirectoryName(projLoc);
+
+            var connection = new SqlCeConnection("Data Source = " + projFolder + "\\Test.sdf;");
+            return connection;
+        }
+
         public void TableName()
         {
             using (var connection = GetOpenConnection())
@@ -116,6 +126,41 @@ public void InsertGetUpdate()
             }
         }
 
+        public void Transactions()
+        {
+            using (var connection = GetOpenConnection())
+            {
+                var id = connection.Insert(new Car { Name = "one car" });   //insert outside transaction
+
+                var tran = connection.BeginTransaction();
+                var car = connection.Get<Car>(id, tran);
+                var orgName = car.Name;
+                car.Name = "Another car";
+                connection.Update(car, tran);
+                tran.Rollback();
+
+                car = connection.Get<Car>(id);  //updates should have been rolled back
+                car.Name.IsEqualTo(orgName);
+            }
+        }
+
+        public void TransactionScope()
+        {
+            using (var connection = GetConnection())
+            {
+                using (var txscope = new TransactionScope())
+                {
+                    connection.Open();  //connection MUST be opened inside the transactionscope
+
+                    var id = connection.Insert(new Car { Name = "one car" });   //inser car within transaction
+
+                    txscope.Dispose();  //rollback
+
+                    connection.Get<Car>(id).IsNull();   //returns null - car with that id should not exist
+                }
+            }
+        }
+
         public void InsertCheckKey()
         {
             using (var connection = GetOpenConnection())