Add test for commit/rollback through session

Author: fredericDelaporte

src/NHibernate.Test/Async/TransactionTest/TransactionFixture.cs

@@ -228,5 +228,97 @@ public async Task WhenCommittingItemsWillAddThemTo2ndLevelCacheAsync()
 				Assert.That(person.NotNullData, Is.EqualTo(notNullData));
 			}
 		}
+
+		[Test]
+		public async Task CanCommitFromSessionTransactionAsync()
+		{
+			int id;
+			using (var s = OpenSession())
+			using (s.BeginTransaction())
+			{
+				var person = new Person();
+				await (s.SaveAsync(person));
+				id = person.Id;
+
+				await (s.CurrentTransaction.CommitAsync());
+			}
+
+			using (var s = OpenSession())
+			using (var t = s.BeginTransaction())
+			{
+				var person = await (s.GetAsync<Person>(id));
+				Assert.That(person, Is.Not.Null);
+				await (t.CommitAsync());
+			}
+		}
+
+		[Test]
+		public async Task CanRollbackFromSessionTransactionAsync()
+		{
+			int id;
+			using (var s = OpenSession())
+			using (s.BeginTransaction())
+			{
+				var person = new Person();
+				await (s.SaveAsync(person));
+				id = person.Id;
+
+				await (s.CurrentTransaction.RollbackAsync());
+			}
+
+			using (var s = OpenSession())
+			using (var t = s.BeginTransaction())
+			{
+				var person = await (s.GetAsync<Person>(id));
+				Assert.That(person, Is.Null);
+				await (t.CommitAsync());
+			}
+		}
+
+		[Test, Obsolete]
+		public async Task CanCommitFromSessionObsoleteTransactionAsync()
+		{
+			int id;
+			using (var s = OpenSession())
+			using (s.BeginTransaction())
+			{
+				var person = new Person();
+				await (s.SaveAsync(person));
+				id = person.Id;
+
+				await (s.Transaction.CommitAsync());
+			}
+
+			using (var s = OpenSession())
+			using (var t = s.BeginTransaction())
+			{
+				var person = await (s.GetAsync<Person>(id));
+				Assert.That(person, Is.Not.Null);
+				await (t.CommitAsync());
+			}
+		}
+
+		[Test, Obsolete]
+		public async Task CanRollbackFromSessionObsoleteTransactionAsync()
+		{
+			int id;
+			using (var s = OpenSession())
+			using (s.BeginTransaction())
+			{
+				var person = new Person();
+				await (s.SaveAsync(person));
+				id = person.Id;
+
+				await (s.Transaction.RollbackAsync());
+			}
+
+			using (var s = OpenSession())
+			using (var t = s.BeginTransaction())
+			{
+				var person = await (s.GetAsync<Person>(id));
+				Assert.That(person, Is.Null);
+				await (t.CommitAsync());
+			}
+		}
 	}
 }

src/NHibernate.Test/TransactionTest/TransactionFixture.cs

@@ -230,5 +230,97 @@ public void WhenCommittingItemsWillAddThemTo2ndLevelCache()
 				Assert.That(person.NotNullData, Is.EqualTo(notNullData));
 			}
 		}
+
+		[Test]
+		public void CanCommitFromSessionTransaction()
+		{
+			int id;
+			using (var s = OpenSession())
+			using (s.BeginTransaction())
+			{
+				var person = new Person();
+				s.Save(person);
+				id = person.Id;
+
+				s.CurrentTransaction.Commit();
+			}
+
+			using (var s = OpenSession())
+			using (var t = s.BeginTransaction())
+			{
+				var person = s.Get<Person>(id);
+				Assert.That(person, Is.Not.Null);
+				t.Commit();
+			}
+		}
+
+		[Test]
+		public void CanRollbackFromSessionTransaction()
+		{
+			int id;
+			using (var s = OpenSession())
+			using (s.BeginTransaction())
+			{
+				var person = new Person();
+				s.Save(person);
+				id = person.Id;
+
+				s.CurrentTransaction.Rollback();
+			}
+
+			using (var s = OpenSession())
+			using (var t = s.BeginTransaction())
+			{
+				var person = s.Get<Person>(id);
+				Assert.That(person, Is.Null);
+				t.Commit();
+			}
+		}
+
+		[Test, Obsolete]
+		public void CanCommitFromSessionObsoleteTransaction()
+		{
+			int id;
+			using (var s = OpenSession())
+			using (s.BeginTransaction())
+			{
+				var person = new Person();
+				s.Save(person);
+				id = person.Id;
+
+				s.Transaction.Commit();
+			}
+
+			using (var s = OpenSession())
+			using (var t = s.BeginTransaction())
+			{
+				var person = s.Get<Person>(id);
+				Assert.That(person, Is.Not.Null);
+				t.Commit();
+			}
+		}
+
+		[Test, Obsolete]
+		public void CanRollbackFromSessionObsoleteTransaction()
+		{
+			int id;
+			using (var s = OpenSession())
+			using (s.BeginTransaction())
+			{
+				var person = new Person();
+				s.Save(person);
+				id = person.Id;
+
+				s.Transaction.Rollback();
+			}
+
+			using (var s = OpenSession())
+			using (var t = s.BeginTransaction())
+			{
+				var person = s.Get<Person>(id);
+				Assert.That(person, Is.Null);
+				t.Commit();
+			}
+		}
 	}
 }