Generate async files

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

@@ -151,6 +151,11 @@ public partial class DriverForSubstitutedCommand : IDriver
 		#endregion
 		#region Pure forwarding
 
+		Task<DbDataReader> IDriver.ExecuteReaderAsync(DbCommand cmd, CancellationToken cancellationToken)
+		{
+			return _driverImplementation.ExecuteReaderAsync(cmd, cancellationToken);
+		}
+
 		#endregion
 
 		private partial class SubstituteDbCommand : DbCommand

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

@@ -53,6 +53,7 @@ protected override void CreateSchema()
 		CreateTable("DateTime");
 		CreateTable("Double");
 		CreateTable("Decimal");
+		CreateTable("Float");
 
 		base.CreateSchema();
 	}
@@ -194,6 +195,14 @@ public async Task TestIntegerAsync(CultureInfo from, CultureInfo to)
 		await (PerformTestAsync<int, IntegerEntity>(from, to, integerValue, (expected, actual) => Assert.AreEqual(expected, actual)));
 	}
 
+	[Test, TestCaseSource(nameof(GetTestCases))]
+	public async Task TestFloatAsync(CultureInfo from, CultureInfo to)
+	{
+		float floatValue = 12.3f;
+
+		await (PerformTestAsync<float, FloatEntity>(from, to, floatValue, (expected, actual) => Assert.AreEqual(expected, actual)));
+	}
+
 	private CultureInfo CurrentCulture
 	{
 		get => CultureInfo.CurrentCulture;

src/NHibernate.Test/Async/TypesTest/AbstractDateTimeTypeFixture.cs

@@ -489,4 +489,20 @@ protected DateTimeKind GetTypeKind()
 			return (DateTimeKind) _kindProperty.GetValue(Type);
 		}
 	}
+
+	public partial class ClientDriverWithParamsStats : IDriver
+	{
+
+		Task<DbDataReader> IDriver.ExecuteReaderAsync(DbCommand cmd, CancellationToken cancellationToken)
+		{
+			return _driverImplementation.ExecuteReaderAsync(cmd, cancellationToken);
+		}
+
+		#region Firebird mess
+
+		#endregion
+		#region Pure forwarding
+
+		#endregion
+	}
 }

src/NHibernate.Test/TypesTest/AbstractDateTimeTypeFixture.cs

@@ -544,7 +544,7 @@ protected DateTimeKind GetTypeKind()
 		}
 	}
 
-	public class ClientDriverWithParamsStats : IDriver
+	public partial class ClientDriverWithParamsStats : IDriver
 	{
 		private readonly Dictionary<SqlType, int> _usedSqlTypes = new Dictionary<SqlType, int>();
 		private readonly Dictionary<DbType, int> _usedDbTypes = new Dictionary<DbType, int>();

src/NHibernate/Async/AdoNet/AbstractBatcher.cs

@@ -167,13 +167,16 @@ private async Task<DbDataReader> DoExecuteReaderAsync(DbCommand cmd, Cancellatio
 			cancellationToken.ThrowIfCancellationRequested();
 			try
 			{
-				var reader = await (cmd.ExecuteReaderAsync(cancellationToken)).ConfigureAwait(false);
+				var driver = _factory.ConnectionProvider.Driver;
+				var reader = await (driver.ExecuteReaderAsync(cmd, cancellationToken)).ConfigureAwait(false);
+
 				if (reader == null)
 				{
 					// MySql may return null instead of an exception, by example when the query is canceled by another thread.
 					throw new InvalidOperationException("The query execution has yielded a null reader. (Has it been canceled?)");
 				}
-				return _factory.ConnectionProvider.Driver.SupportsMultipleOpenReaders
+
+				return driver.SupportsMultipleOpenReaders
 					? reader
 					: await (NHybridDataReader.CreateAsync(reader, cancellationToken)).ConfigureAwait(false);
 			}

src/NHibernate/Async/Driver/DirectCastDbDataReader.cs

@@ -0,0 +1,41 @@
+//------------------------------------------------------------------------------
+// <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;
+using System.Data.Common;
+using System.Diagnostics.CodeAnalysis;
+
+namespace NHibernate.Driver
+{
+	using System.Threading.Tasks;
+	using System.Threading;
+	public partial class DirectCastDbDataReader : DbDataReader
+	{
+
+		public override Task<bool> NextResultAsync(CancellationToken cancellationToken)
+		{
+			if (cancellationToken.IsCancellationRequested)
+			{
+				return Task.FromCanceled<bool>(cancellationToken);
+			}
+			return _reader.NextResultAsync(cancellationToken);
+		}
+
+		public override Task<bool> ReadAsync(CancellationToken cancellationToken)
+		{
+			if (cancellationToken.IsCancellationRequested)
+			{
+				return Task.FromCanceled<bool>(cancellationToken);
+			}
+			return _reader.ReadAsync(cancellationToken);
+		}
+	}
+}

src/NHibernate/Async/Driver/DriverBase.cs

@@ -0,0 +1,51 @@
+//------------------------------------------------------------------------------
+// <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.Data;
+using System.Data.Common;
+using System.Linq;
+using NHibernate.Engine;
+using NHibernate.SqlCommand;
+using NHibernate.SqlTypes;
+using NHibernate.Util;
+using Environment = NHibernate.Cfg.Environment;
+
+namespace NHibernate.Driver
+{
+	using System.Threading.Tasks;
+	using System.Threading;
+	public abstract partial class DriverBase : IDriver, ISqlParameterFormatter
+	{
+
+		#if NETFX
+		#else
+
+		#endif
+
+		/// <summary>
+		/// Provides a mechanism to override the default DbDataReader used
+		/// by a data provider. Some providers don't provide a DataReader
+		/// that implement all of the methods.
+		/// </summary>
+		/// <param name="cmd">The command to execute.</param>
+		/// <param name="cancellationToken">A cancellation token that can be used to cancel the work</param>
+		/// <returns>A <see cref="DbDataReader">DbDataReader</see> object.</returns>
+		public virtual Task<DbDataReader> ExecuteReaderAsync(DbCommand cmd, CancellationToken cancellationToken)
+		{
+			if (cancellationToken.IsCancellationRequested)
+			{
+				return Task.FromCanceled<DbDataReader>(cancellationToken);
+			}
+			return cmd.ExecuteReaderAsync(cancellationToken);
+		}
+	}
+}

src/NHibernate/Async/Driver/IDriver.cs

@@ -0,0 +1,36 @@
+//------------------------------------------------------------------------------
+// <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.Data;
+using System.Data.Common;
+using NHibernate.Engine;
+using NHibernate.SqlCommand;
+using NHibernate.SqlTypes;
+
+namespace NHibernate.Driver
+{
+	using System.Threading.Tasks;
+	using System.Threading;
+	public partial interface IDriver
+	{
+
+		/// <summary>
+		/// Provides a mechanism to override the default DbDataReader used
+		/// by a data provider. Some providers don't provide a DataReader
+		/// that implement all of the methods.
+		/// </summary>
+		/// <param name="cmd">The command to execute.</param>
+		/// <param name="cancellationToken">A cancellation token that can be used to cancel the work</param>
+		/// <returns>A <see cref="DbDataReader">DbDataReader</see> object.</returns>
+		Task<DbDataReader> ExecuteReaderAsync(DbCommand cmd, CancellationToken cancellationToken);
+	}
+}

src/NHibernate/Async/Driver/OracleDataClientDriverBase.cs

@@ -35,5 +35,11 @@ protected override async Task<DbDataReader> ExecuteDbDataReaderAsync(CommandBeha
 				return reader;
 			}
 		}
+
+		public override async Task<DbDataReader> ExecuteReaderAsync(DbCommand cmd, CancellationToken cancellationToken)
+		{
+			cancellationToken.ThrowIfCancellationRequested();
+			return new DirectCastDbDataReader(await (cmd.ExecuteReaderAsync(cancellationToken)).ConfigureAwait(false));
+		}
 	}
 }

src/NHibernate/Async/Driver/Sql2008ClientDriver.cs

@@ -0,0 +1,34 @@
+//------------------------------------------------------------------------------
+// <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.Data;
+using System.Data.Common;
+using NHibernate.Util;
+
+namespace NHibernate.Driver
+{
+	using System.Threading.Tasks;
+	using System.Threading;
+	public partial class Sql2008ClientDriver : SqlClientDriver
+	{
+
+		#if NETFX
+		#else
+
+		#endif
+
+		public override async Task<DbDataReader> ExecuteReaderAsync(DbCommand cmd, CancellationToken cancellationToken)
+		{
+			cancellationToken.ThrowIfCancellationRequested();
+			return new DirectCastDbDataReader(await (cmd.ExecuteReaderAsync(cancellationToken)).ConfigureAwait(false));
+		}
+	}
+}

src/NHibernate/Driver/DirectCastDbDataReader.cs

@@ -5,7 +5,7 @@
 
 namespace NHibernate.Driver
 {
-	public class DirectCastDbDataReader : DbDataReader
+	public partial class DirectCastDbDataReader : DbDataReader
 	{
 		private readonly DbDataReader _reader;
 

src/NHibernate/Driver/DriverBase.cs

@@ -14,7 +14,7 @@ namespace NHibernate.Driver
 	/// <summary>
 	/// Base class for the implementation of IDriver
 	/// </summary>
-	public abstract class DriverBase : IDriver, ISqlParameterFormatter
+	public abstract partial class DriverBase : IDriver, ISqlParameterFormatter
 	{
 		private static readonly INHibernateLogger log = NHibernateLogger.For(typeof(DriverBase));
 

src/NHibernate/Driver/IDriver.cs

@@ -30,7 +30,7 @@ namespace NHibernate.Driver
 	/// value="FullyQualifiedClassName, AssemblyName"
 	/// </code>
 	/// </remarks>
-	public interface IDriver
+	public partial interface IDriver
 	{
 		/// <summary>
 		/// Configure the driver using <paramref name="settings"/>.

src/NHibernate/Driver/Sql2008ClientDriver.cs

@@ -5,7 +5,7 @@
 
 namespace NHibernate.Driver
 {
-	public class Sql2008ClientDriver : SqlClientDriver
+	public partial class Sql2008ClientDriver : SqlClientDriver
 	{
 		const byte MaxTime = 5;