NH-2176 - Add test case for consecutive transaction scopes.

Author: griffitd

src/NHibernate.Test/Async/NHSpecificTest/NH2176/Fixture.cs

@@ -0,0 +1,87 @@
+//------------------------------------------------------------------------------
+// <auto-generated>
+//     This code was generated by AsyncGenerator.
+//
+//     Changes to this file may cause incorrect behavior and will be lost if
+//     the code is regenerated.
+// </auto-generated>
+//------------------------------------------------------------------------------
+
+
+using System;
+using System.Transactions;
+using NUnit.Framework;
+
+namespace NHibernate.Test.NHSpecificTest.NH2176
+{
+	using System.Threading.Tasks;
+	[TestFixture]
+	public class FixtureAsync : BugTestCase
+	{
+		protected override void OnSetUp()
+		{
+			base.OnSetUp();
+			using (var s = OpenSession())
+			using (var tx = s.BeginTransaction())
+			{
+				var steve = new Person {Name = "Steve"};
+				var peter = new Person {Name = "Peter"};
+				var simon = new Person {Name = "Simon"};
+				var paul = new Person {Name = "Paul"};
+				var john = new Person {Name = "John"};
+				var eric = new Person {Name = "Eric"};
+
+				s.Save(steve);
+				s.Save(peter);
+				s.Save(simon);
+				s.Save(paul);
+				s.Save(john);
+				s.Save(eric);
+
+				tx.Commit();
+			}
+		}
+
+		protected override void OnTearDown()
+		{
+			base.OnTearDown();
+			using (var s = OpenSession())
+			using (var tx = s.BeginTransaction())
+			{
+				s.Delete("from Person");
+				tx.Commit();
+			}
+		}
+
+		// Whilst this bug seems specific to Oracle I think it is valid to run the
+		// test against all database types.
+		[Test]
+		public async Task MultipleConsecutiveTransactionScopesCanBeUsedInsideASingleSessionAsync()
+		{
+			using (var s = OpenSession())
+			{
+				// usually fails after just a few loops in oracle
+				// this can be run for 10000 loops in sql server without problem
+				for (var i = 0; i < 100; ++i)
+				{
+					Console.WriteLine(i.ToString());
+
+					using (var scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
+					{
+						var criteria = s.CreateCriteria<Person>();
+						var people = await (criteria.ListAsync<Person>());
+
+						Assert.That(people.Count, Is.EqualTo(6));
+
+						scope.Complete();
+					}
+
+					// The exeption is caused by a race condition between two threads.
+					// This can be demonstracted by uncommenting the following line which
+					// causes the test to run without an exception.
+					//System.Threading.Thread.Sleep(1000);
+				}
+			}
+		}
+	}
+}

src/NHibernate.Test/NHSpecificTest/NH2176/Fixture.cs

@@ -0,0 +1,76 @@
+using System;
+using System.Transactions;
+using NUnit.Framework;
+
+namespace NHibernate.Test.NHSpecificTest.NH2176
+{
+	[TestFixture]
+	public class Fixture : BugTestCase
+	{
+		protected override void OnSetUp()
+		{
+			base.OnSetUp();
+			using (var s = OpenSession())
+			using (var tx = s.BeginTransaction())
+			{
+				var steve = new Person {Name = "Steve"};
+				var peter = new Person {Name = "Peter"};
+				var simon = new Person {Name = "Simon"};
+				var paul = new Person {Name = "Paul"};
+				var john = new Person {Name = "John"};
+				var eric = new Person {Name = "Eric"};
+
+				s.Save(steve);
+				s.Save(peter);
+				s.Save(simon);
+				s.Save(paul);
+				s.Save(john);
+				s.Save(eric);
+
+				tx.Commit();
+			}
+		}
+
+		protected override void OnTearDown()
+		{
+			base.OnTearDown();
+			using (var s = OpenSession())
+			using (var tx = s.BeginTransaction())
+			{
+				s.Delete("from Person");
+				tx.Commit();
+			}
+		}
+
+		// Whilst this bug seems specific to Oracle I think it is valid to run the
+		// test against all database types.
+		[Test]
+		public void MultipleConsecutiveTransactionScopesCanBeUsedInsideASingleSession()
+		{
+			using (var s = OpenSession())
+			{
+				// usually fails after just a few loops in oracle
+				// this can be run for 10000 loops in sql server without problem
+				for (var i = 0; i < 100; ++i)
+				{
+					Console.WriteLine(i.ToString());
+
+					using (var scope = new TransactionScope())
+					{
+						var criteria = s.CreateCriteria<Person>();
+						var people = criteria.List<Person>();
+
+						Assert.That(people.Count, Is.EqualTo(6));
+
+						scope.Complete();
+					}
+
+					// The exeption is caused by a race condition between two threads.
+					// This can be demonstracted by uncommenting the following line which
+					// causes the test to run without an exception.
+					//System.Threading.Thread.Sleep(1000);
+				}
+			}
+		}
+	}
+}

src/NHibernate.Test/NHSpecificTest/NH2176/Mappings.hbm.xml

@@ -0,0 +1,15 @@
+<?xml version="1.0" encoding="utf-8" ?>
+<hibernate-mapping xmlns="urn:nhibernate-mapping-2.2"
+                   namespace="NHibernate.Test.NHSpecificTest.NH2176"
+                   assembly="NHibernate.Test"
+>
+    <class name="Person" table="NH2176_Person">
+
+    <id name="Id" column="PersonId">
+            <generator class="identity"/>
+        </id>
+
+    <property name="Name" column="Name" />
+
+  </class>
+</hibernate-mapping>

src/NHibernate.Test/NHSpecificTest/NH2176/Model.cs

@@ -0,0 +1,8 @@
+namespace NHibernate.Test.NHSpecificTest.NH2176
+{
+	public class Person
+	{
+		public virtual int Id { get; set; }
+		public virtual string Name { get; set; }
+	}
+}