Generate tests for GetFieldValueAsync.

Author: bgrainger

src/AdoNet.Specification.Tests/GetValueConversionTestBase.cs

@@ -2,6 +2,7 @@
 using System.Data;
 using System.Data.Common;
 using System.Linq;
+using System.Threading.Tasks;
 using Xunit;
 using Xunit.Sdk;
 
@@ -23,9 +24,9 @@ protected GetValueConversionTestBase(TFixture fixture)
 		protected virtual void TestGetFieldValue<T>(DbType dbType, ValueKind kind, T expected) => DoTest(dbType, kind, reader => Assert.Equal(expected, reader.GetFieldValue<T>(0)));
 		protected virtual void TestGetValue<T>(DbType dbType, ValueKind kind, T expected) => DoTest(dbType, kind, reader => Assert.Equal(expected, reader.GetValue(0)));
 		protected virtual void TestGetValue<T>(DbType dbType, ValueKind kind, Func<DbDataReader, T> getValue, T expected) => DoTest(dbType, kind, reader => Assert.Equal(expected, getValue(reader)));
+		protected virtual async Task TestGetValueAsync<T>(DbType dbType, ValueKind kind, Func<DbDataReader, Task<T>> getValue, T expected) => await DoTestAsync(dbType, kind, async reader => Assert.Equal(expected, await getValue(reader)));
 
-		protected virtual void TestException<T>(DbType dbType, ValueKind kind, Func<DbDataReader, T> getValue, Type exceptionType)
-		{
+		protected virtual void TestException<T>(DbType dbType, ValueKind kind, Func<DbDataReader, T> getValue, Type exceptionType) =>
 			DoTest(dbType, kind, reader =>
 			{
 				try
@@ -45,7 +46,28 @@ protected virtual void TestException<T>(DbType dbType, ValueKind kind, Func<DbDa
 					throw new ThrowsException(exceptionType, ex);
 				}
 			});
-		}
+
+
+		protected virtual async Task TestExceptionAsync<T>(DbType dbType, ValueKind kind, Func<DbDataReader, Task<T>> getValue, Type exceptionType) =>
+			await DoTestAsync(dbType, kind, async reader =>
+			{
+				try
+				{
+					var value = await getValue(reader);
+					throw new UnexpectedValueException(value);
+				}
+				catch (UnexpectedValueException)
+				{
+					throw;
+				}
+				catch (Exception ex) when (ex.GetType() == exceptionType)
+				{
+				}
+				catch (Exception ex)
+				{
+					throw new ThrowsException(exceptionType, ex);
+				}
+			});
 
 		protected virtual void DoTest(DbType dbType, ValueKind kind, Action<DbDataReader> action)
 		{
@@ -59,5 +81,18 @@ protected virtual void DoTest(DbType dbType, ValueKind kind, Action<DbDataReader
 			Assert.True(reader.Read());
 			action(reader);
 		}
+
+		protected virtual async Task DoTestAsync(DbType dbType, ValueKind kind, Func<DbDataReader, Task> action)
+		{
+			if (!Fixture.SupportedDbTypes.Contains(dbType))
+				throw new SkipException("Database doesn't support this data type");
+
+			using var connection = CreateOpenConnection();
+			using var command = connection.CreateCommand();
+			command.CommandText = Fixture.CreateSelectSql(dbType, kind);
+			using var reader = command.ExecuteReader();
+			Assert.True(reader.Read());
+			await action(reader);
+		}
 	}
 }