LinqToFutureValueFixture.cs

//------------------------------------------------------------------------------
// <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.Linq;
using NHibernate.Linq;
using NUnit.Framework;

namespace NHibernate.Test.Futures
{
	using System.Threading.Tasks;
	[TestFixture]
	public class LinqToFutureValueFixtureAsync : FutureFixture
	{
		[Test]
		public async Task CanExecuteToFutureValueCountAsync()
		{
			using (var session = OpenSession())
			using (session.BeginTransaction())
			{
				var personsCount = session.Query<Person>()
					.Where(x => x.Name == "Test1")
					.ToFutureValue(x => x.Count());

				Assert.AreEqual(1, await (personsCount.GetValueAsync()));
			}
		}

		[Test]
		public async Task CanExecuteToFutureValueCountWithPredicateAsync()
		{
			using (var session = OpenSession())
			using (session.BeginTransaction())
			{
				var personsCount = session.Query<Person>()
					.ToFutureValue(q => q.Count(x => x.Name == "Test1"));

				Assert.AreEqual(1, await (personsCount.GetValueAsync()));
			}
		}

		[Test(Description = "https://github.com/nhibernate/nhibernate-core/issues/1387")]
		public async Task ToFutureValueWithSumReturnsResultAsync()
		{
			using (var s = OpenSession())
			{
				var personsSum = s.Query<Person>()
					.Select(x => x.Id)
					.ToFutureValue(x => x.Sum());

				Assert.IsNotNull(personsSum);
				Assert.NotZero(await (personsSum.GetValueAsync()));
			}
		}

		[Test]
		public void ToFutureValueWithSumOnEmptySetThrowsAsync()
		{
			using (var s = OpenSession())
			{
				var personsSum = s.Query<Person>()
					.Where(x => false) // make this an empty set
					.Select(x => x.Id)
					.ToFutureValue(x => x.Sum());

				Assert.That(() => personsSum.GetValueAsync(), Throws.InnerException.TypeOf<InvalidOperationException>().Or.InnerException.TypeOf<ArgumentNullException>());
			}
		}

		[Test]
		public async Task ToFutureValueWithNullableSumReturnsResultAsync()
		{
			using (var s = OpenSession())
			{
				var ageSum = s.Query<Person>()
					.Select(x => x.Age)
					.ToFutureValue(x => x.Sum());

				Assert.IsNotNull(ageSum);
				Assert.IsNotNull(await (ageSum.GetValueAsync()));
				Assert.NotZero((await (ageSum.GetValueAsync())).Value);
			}
		}

		[Test]
		public async Task ToFutureValueWithNullableSumOnEmptySetReturnsNullAsync()
		{
			using (var s = OpenSession())
			{
				var ageSum = s.Query<Person>()
					.Where(x => false) // make this an empty set
					.Select(x => x.Age)
					.ToFutureValue(x => x.Sum());

				Assert.IsNotNull(ageSum);
				Assert.IsNull(await (ageSum.GetValueAsync()));
			}
		}

		protected override void OnSetUp()
		{
			using (var session = OpenSession())
			using (var transaction = session.BeginTransaction())
			{
				session.Save(new Person {Name = "Test1", Age = 20});
				session.Save(new Person {Name = "Test2", Age = 30});
				session.Save(new Person {Name = "Test3"});
				session.Save(new Person {Name = "Test4"});
				transaction.Commit();
			}
		}

		protected override void OnTearDown()
		{
			using (var session = OpenSession())
			using (var transaction = session.BeginTransaction())
			{
				session.Delete("from System.Object");
				transaction.Commit();
			}
		}
	}
}