Add MultiThreadedUpdateTransactionIssue

Author: mythz

tests/ServiceStack.OrmLite.Tests/Issues/MultiThreadedUpdateTransactionIssue.cs

@@ -0,0 +1,54 @@
+using System.Threading;
+using NUnit.Framework;
+using ServiceStack.DataAnnotations;
+
+namespace ServiceStack.OrmLite.Tests.Issues
+{
+    [Explicit]
+    public class MultiThreadedUpdateTransactionIssue : OrmLiteTestBase
+    {
+        public class ModelWithIdAndName
+        {
+            [AutoIncrement]
+            public int Id { get; set; }
+            public string Name { get; set; }
+        }
+
+        [Test]
+        public void Can_Insert_Update_record_across_multiple_threads()
+        {
+            using (var db = OpenDbConnection())
+            {
+                db.DropAndCreateTable<ModelWithIdAndName>();
+            }
+
+            int count = 0;
+
+            20.Times(i =>
+            {
+                ThreadPool.QueueUserWorkItem(state =>
+                {
+                    40.Times(_ =>
+                    {
+                        using (var db = OpenDbConnection())
+                        {
+                            var objA = new ModelWithIdAndName { Name = "A" };
+                            var objB = new ModelWithIdAndName { Name = "B" };
+
+                            objA.Id = (int)db.Insert(objA, selectIdentity: true);
+
+                            objB.Id = (int)db.Insert(objB, selectIdentity: true);
+                            objB.Name = objA.Name;
+
+                            db.Update(objB);
+                            Interlocked.Increment(ref count);
+                        }
+                    });
+                });
+            });
+
+            Thread.Sleep(5000);
+            Assert.That(count, Is.EqualTo(20 * 40));
+        }
+    }
+}

tests/ServiceStack.OrmLite.Tests/ServiceStack.OrmLite.Tests.csproj

@@ -144,6 +144,7 @@
     <Compile Include="Issues\JsonUpdateOnlyIssue.cs" />
     <Compile Include="Issues\LoadReferencesNullReferenceIssue.cs" />
     <Compile Include="Issues\MergeParamsIssue.cs" />
+    <Compile Include="Issues\MultiThreadedUpdateTransactionIssue.cs" />
     <Compile Include="Issues\ParamNameIssues.cs" />
     <Compile Include="MultipleConnectionIdTests.cs" />
     <Compile Include="UseCase\CustomerOrdersUseCaseAsync.cs" />