添加异步聚合函数。

Kogel.Dapper.Extension/Core/Interfaces/IAggregation.cs

@@ -11,29 +11,52 @@ public interface IAggregation<T>
         /// </summary>
         /// <returns></returns>
         int Count();
-
-		/// <summary>
-		/// 总和
-		/// </summary>
-		/// <typeparam name="TResult"></typeparam>
-		/// <param name="sumExpression"></param>
-		/// <returns></returns>
-		TResult Sum<TResult>(Expression<Func<T, TResult>> sumExpression);
-
+        /// <summary>
+        /// 行数
+        /// </summary>
+        /// <returns></returns>
+        Task<int> CountAsync();
+        /// <summary>
+        /// 总和
+        /// </summary>
+        /// <typeparam name="TResult"></typeparam>
+        /// <param name="sumExpression"></param>
+        /// <returns></returns>
+        TResult Sum<TResult>(Expression<Func<T, TResult>> sumExpression);
+        /// <summary>
+        /// 总和
+        /// </summary>
+        /// <typeparam name="TResult"></typeparam>
+        /// <param name="sumExpression"></param>
+        /// <returns></returns>
+        Task<TResult> SumAsync<TResult>(Expression<Func<T, TResult>> sumExpression);
         /// <summary>
         /// 最小值
         /// </summary>
         /// <typeparam name="TResult"></typeparam>
         /// <param name="minExpression"></param>
         /// <returns></returns>
         TResult Min<TResult>(Expression<Func<T, TResult>> minExpression);
-
+        /// <summary>
+        /// 最小值
+        /// </summary>
+        /// <typeparam name="TResult"></typeparam>
+        /// <param name="minExpression"></param>
+        /// <returns></returns>
+        Task<TResult> MinAsync<TResult>(Expression<Func<T, TResult>> minExpression);
         /// <summary>
         /// 最大值
         /// </summary>
         /// <typeparam name="TResult"></typeparam>
         /// <param name="maxExpression"></param>
         /// <returns></returns>
         TResult Max<TResult>(Expression<Func<T, TResult>> maxExpression);
+        /// <summary>
+        /// 最大值
+        /// </summary>
+        /// <typeparam name="TResult"></typeparam>
+        /// <param name="maxExpression"></param>
+        /// <returns></returns>
+        Task<TResult> MaxAsync<TResult>(Expression<Func<T, TResult>> maxExpression);
     }
 }

Kogel.Dapper.Extension/Core/SetQ/Aggregation.cs

@@ -27,26 +27,48 @@ protected Aggregation(IDbConnection conn, SqlProvider sqlProvider, IDbTransactio
         public int Count()
         {
             SqlProvider.FormatCount();
-			return DbCon.QuerySingleOrDefault<int>(SqlProvider.SqlString, SqlProvider.Params, dbTransaction);
+            return DbCon.QuerySingleOrDefault<int>(SqlProvider.SqlString, SqlProvider.Params, dbTransaction);
+        }
+        public async Task<int> CountAsync()
+        {
+            SqlProvider.FormatCount();
+            return await DbCon.QuerySingleOrDefaultAsync<int>(SqlProvider.SqlString, SqlProvider.Params, dbTransaction);
         }
 
         /// <inheritdoc />
         public TResult Sum<TResult>(Expression<Func<T, TResult>> sumExpression)
         {
             SqlProvider.FormatSum(sumExpression);
             return DbCon.QuerySingleOrDefault<TResult>(SqlProvider.SqlString, SqlProvider.Params, dbTransaction);
-		}
+        }
+        public async Task<TResult> SumAsync<TResult>(Expression<Func<T, TResult>> sumExpression)
+        {
+            SqlProvider.FormatSum(sumExpression);
+            return await DbCon.QuerySingleOrDefaultAsync<TResult>(SqlProvider.SqlString, SqlProvider.Params, dbTransaction);
+        }
 
         public TResult Max<TResult>(Expression<Func<T, TResult>> maxExpression)
         {
             SqlProvider.FormatMax(maxExpression);
             return DbCon.QuerySingleOrDefault<TResult>(SqlProvider.SqlString, SqlProvider.Params, dbTransaction);
-		}
+        }
+
+        public async Task<TResult> MaxAsync<TResult>(Expression<Func<T, TResult>> maxExpression)
+        {
+            SqlProvider.FormatMax(maxExpression);
+            return await DbCon.QuerySingleOrDefaultAsync<TResult>(SqlProvider.SqlString, SqlProvider.Params, dbTransaction);
+        }
+
 
         public TResult Min<TResult>(Expression<Func<T, TResult>> minExpression)
         {
             SqlProvider.FormatMin(minExpression);
             return DbCon.QuerySingleOrDefault<TResult>(SqlProvider.SqlString, SqlProvider.Params, dbTransaction);
-		}
+        }
+        public async Task<TResult> MinAsync<TResult>(Expression<Func<T, TResult>> minExpression)
+        {
+            SqlProvider.FormatMin(minExpression);
+            return await DbCon.QuerySingleOrDefaultAsync<TResult>(SqlProvider.SqlString, SqlProvider.Params, dbTransaction);
+        }
     }
 }