GH2201: Add async versions of fetch loop detection tests.

Author: David Ellingsworth

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

@@ -0,0 +1,134 @@
+//------------------------------------------------------------------------------
+// <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.Collections.Generic;
+using System.Linq;
+using NHibernate.Stat;
+using NUnit.Framework;
+using NHCfg = NHibernate.Cfg;
+
+namespace NHibernate.Test.NHSpecificTest.GH2201
+{
+	using System.Threading.Tasks;
+	[TestFixture]
+	public class FixtureAsync : BugTestCase
+	{
+		protected override void Configure(NHCfg.Configuration configuration)
+		{
+			configuration.SetProperty(NHCfg.Environment.GenerateStatistics, "true");
+			configuration.SetProperty(NHCfg.Environment.DetectFetchLoops, "false");
+		}
+
+		protected override void OnTearDown()
+		{
+			using (var s = OpenSession())
+			using (var tx = s.BeginTransaction())
+			{
+				s.Delete("from Person");
+
+				tx.Commit();
+			}
+		}
+
+		protected override void OnSetUp()
+		{
+			using (var s = OpenSession())
+			using (var tx = s.BeginTransaction())
+			{
+				string[] names = { "Alice", "Bob" };
+
+				for (int i = 0; i < names.Length; i++)
+				{
+					var name = names[i];
+
+					Person parent = new Person()
+					{
+						Name = name,
+						Details = new Detail()
+						{
+							Data = $"Details for ${name}"
+						}
+					};
+
+					for (int j = 1; j <= 3; j++)
+					{
+						Person child = new Person()
+						{
+							Name = $"Child ${j} of ${parent.Name}",
+							Parent = parent,
+							Details = new Detail()
+							{
+								Data = $"Details for child ${j} of ${name}"
+							}
+						};
+
+						parent.Children.Add(child);
+					}
+					
+					s.Save(parent);
+				}
+
+				tx.Commit();
+			}
+		}
+
+		[Test]
+		public async Task QueryOverPersonWithParentAsync()
+		{
+			var stats = Sfi.Statistics;
+
+			stats.Clear();
+
+			using (var s = OpenSession())
+			using (var tx = s.BeginTransaction())
+			{
+				var people = await (s.QueryOver<Person>()
+					.Fetch(SelectMode.Fetch,p => p.Parent)
+					.Where(p => p.Parent != null)
+					.ListAsync());
+
+				foreach (Person p in people)
+				{
+					Assert.That(p.Parent, Is.Not.Null);
+					Assert.That(p.Parent.Details, Is.Not.Null);
+				}
+
+				Assert.That(people.Count, Is.EqualTo(6));
+				Assert.That(stats.QueryExecutionCount, Is.EqualTo(1));
+				Assert.That(stats.EntityFetchCount, Is.EqualTo(0));
+				Assert.That(stats.EntityLoadCount, Is.EqualTo(16));
+			}
+		}
+
+		[Test]
+		public async Task QueryOverSinglePersonWithParentAsync()
+		{
+			var stats = Sfi.Statistics;
+
+			stats.Clear();
+
+			using (var s = OpenSession())
+			using (var tx = s.BeginTransaction())
+			{
+				var person = await (s.QueryOver<Person>()
+					.Where(p => p.Parent != null)
+					.Fetch(SelectMode.Fetch, p => p.Parent)
+					.Take(1)
+					.SingleOrDefaultAsync());
+
+				Assert.That(person, Is.Not.Null);
+				Assert.That(stats.QueryExecutionCount, Is.EqualTo(1));
+				Assert.That(stats.EntityFetchCount, Is.EqualTo(0));
+				Assert.That(stats.EntityLoadCount, Is.EqualTo(4));
+			}
+		}
+	}
+}