@@ -60,7 +60,7 @@ private static async Task<int> _CountAsync(IDatabase database, CompileInfo compi
60
60
return await connection . ExecuteScalarAsync < int > ( compileInfo . Sql , compileInfo . NamedBindings ) ;
61
61
}
62
62
63
- public static async Task < int > SumAsync ( IDatabase database , string tableName , IRedis redis , string columnName , Query query = null )
63
+ public static async Task < TValue > SumValueAsync < TValue > ( IDatabase database , string tableName , IRedis redis , string columnName , Query query = null )
64
64
{
65
65
var xQuery = NewQuery ( tableName , query ) ;
66
66
xQuery . AsSum ( columnName ) ;
@@ -70,17 +70,17 @@ public static async Task<int> SumAsync(IDatabase database, string tableName, IRe
70
70
{
71
71
var cacheManager = await CachingUtils . GetCacheManagerAsync ( redis ) ;
72
72
return await cacheManager . GetOrCreateAsync ( compileInfo . Caching . CacheKey ,
73
- async ( ) => await _SumAsync ( database , compileInfo )
73
+ async ( ) => await _SumValueAsync < TValue > ( database , compileInfo )
74
74
) ;
75
75
}
76
76
77
- return await _SumAsync ( database , compileInfo ) ;
77
+ return await _SumValueAsync < TValue > ( database , compileInfo ) ;
78
78
}
79
79
80
- private static async Task < int > _SumAsync ( IDatabase database , CompileInfo compileInfo )
80
+ private static async Task < TValue > _SumValueAsync < TValue > ( IDatabase database , CompileInfo compileInfo )
81
81
{
82
82
using var connection = database . GetConnection ( ) ;
83
- return await connection . ExecuteScalarAsync < int > ( compileInfo . Sql , compileInfo . NamedBindings ) ;
83
+ return await connection . ExecuteScalarAsync < TValue > ( compileInfo . Sql , compileInfo . NamedBindings ) ;
84
84
}
85
85
86
86
public static async Task < TValue > GetValueAsync < TValue > ( IDatabase database , string tableName , IRedis redis , Query query )
0 commit comments