Added SqlDataReader.ResultsAsync methods.

Author: electricessence

Open.Database.Extensions.csproj

@@ -11,9 +11,9 @@
     <Description>Useful set of utilities and abstractions for simplifying modern database operations and ensuring DI compatibility.</Description>
     <RepositoryUrl>https://github.com/electricessence/Open.Database.Extensions</RepositoryUrl>
     <RepositoryType>git</RepositoryType>
-    <Version>5.2.0</Version>
-    <AssemblyVersion>5.2.0.0</AssemblyVersion>
-    <FileVersion>5.2.0.0</FileVersion>
+    <Version>5.2.1</Version>
+    <AssemblyVersion>5.2.1.0</AssemblyVersion>
+    <FileVersion>5.2.1.0</FileVersion>
     <PackageReleaseNotes>- More extensions and flexibility for transforming results.</PackageReleaseNotes>
   </PropertyGroup>
 

SqlClient/Extensions.cs

@@ -286,6 +286,42 @@ public static Task<QueryResult<Queue<object[]>>> RetrieveAsync(this SqlDataReade
             => RetrieveAsync(reader, new string[1] { c }.Concat(others));
 
 
+        /// <summary>
+        /// Asynchronously returns all records and iteratively attempts to map the fields to type T.
+        /// </summary>
+        /// <typeparam name="T">The model type to map the values to (using reflection).</typeparam>
+        /// <param name="reader">The IDataReader to read results from.</param>
+        /// <param name="fieldMappingOverrides">An override map of field names to column names where the keys are the property names, and values are the column names.</param>
+        /// <returns>A task containing the list of results.</returns>
+        public static async Task<IEnumerable<T>> ResultsAsync<T>(this SqlDataReader reader, IEnumerable<(string Field, string Column)> fieldMappingOverrides) where T : new()
+        {
+            var x = new Transformer<T>(fieldMappingOverrides);
+            return x.AsDequeueingEnumerable(await reader.RetrieveAsync(x.ColumnNames));
+        }
+
+        /// <summary>
+        /// Asynchronously returns all records and iteratively attempts to map the fields to type T.
+        /// </summary>
+        /// <typeparam name="T">The model type to map the values to (using reflection).</typeparam>
+        /// <param name="reader">The IDataReader to read results from.</param>
+        /// <param name="fieldMappingOverrides">An override map of field names to column names where the keys are the property names, and values are the column names.</param>
+        /// <returns>A task containing the list of results.</returns>
+        public static Task<IEnumerable<T>> ResultsAsync<T>(this SqlDataReader reader, IEnumerable<KeyValuePair<string, string>> fieldMappingOverrides) where T : new()
+            => reader.ResultsAsync<T>(fieldMappingOverrides?.Select(kvp => (kvp.Key, kvp.Value)));
+
+        /// <summary>
+        /// Asynchronously returns all records and iteratively attempts to map the fields to type T.
+        /// </summary>
+        /// <typeparam name="T">The model type to map the values to (using reflection).</typeparam>
+        /// <param name="reader">The IDataReader to read results from.</param>
+        /// <param name="fieldMappingOverrides">An override map of field names to column names where the keys are the property names, and values are the column names.</param>
+        /// <returns>A task containing the list of results.</returns>
+        public static async Task<IEnumerable<T>> ResultsAsync<T>(this SqlDataReader reader, params (string Field, string Column)[] fieldMappingOverrides) where T : new()
+        {
+            var x = new Transformer<T>(fieldMappingOverrides);
+            return x.AsDequeueingEnumerable(await reader.RetrieveAsync(x.ColumnNames));
+        }
+
         /// <summary>
         /// Creates an ExpressiveSqlCommand for subsequent configuration and execution.
         /// </summary>