weiai/FreeSql
1
0
Fork 0
mirror of https://github.com/dotnetcore/FreeSql.git synced 2026-02-07 00:40:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

- 增加 SqlExt.AggregateCount/AggregateSum 等方法，区分 SqlExt.Count/SqlExt.Sum 开窗方法；

Browse Source
This commit is contained in:
2881099
2025-02-08 15:11:58 +08:00
parent 5f36b72e7e
commit 2f32bb6165
1 changed files with 70 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

73
FreeSql/Extensions/FreeSqlGlobalExpressionCallExtensions.cs
View File

@@ -150,12 +150,79 @@ namespace FreeSql
// return false;
//}
#region SqlServer/PostgreSQL over
/// <summary>
/// rank() over(order by ...)
/// count(1)
/// </summary>
/// <returns></returns>
public static ISqlOver<long> Rank() => Over<long>("rank()");
public static int AggregateCount()
{
expContext.Value.Result = "count(1)";
return 0;
}
/// <summary>
/// count(column)<para></para>
/// 或者<para></para>
/// sum(case when column then 1 else 0 end)
/// </summary>
/// <typeparam name="T3"></typeparam>
/// <param name="column"></param>
/// <returns></returns>
public static int AggregateCount<T3>(T3 column) {
if (typeof(T3) == typeof(bool)) expContext.Value.Result = $"sum({expContext.Value.Utility.CommonUtils.IIF(expContext.Value.ParsedContent["column"], "1", "0")})";
else expContext.Value.Result = $"count({expContext.Value.ParsedContent["column"]})";
return 0;
}
/// <summary>
/// sum(column)
/// </summary>
/// <typeparam name="T3"></typeparam>
/// <param name="column"></param>
/// <returns></returns>
public static decimal AggregateSum<T3>(T3 column)
{
expContext.Value.Result = $"sum({expContext.Value.ParsedContent["column"]})";
return 0;
}
/// <summary>
/// avg(column)
/// </summary>
/// <typeparam name="T3"></typeparam>
/// <param name="column"></param>
/// <returns></returns>
public static decimal AggregateAvg<T3>(T3 column)
{
expContext.Value.Result = $"avg({expContext.Value.ParsedContent["column"]})";
return 0;
}
/// <summary>
/// max(column)
/// </summary>
/// <typeparam name="T3"></typeparam>
/// <param name="column"></param>
/// <returns></returns>
public static T3 AggregateMax<T3>(T3 column)
{
expContext.Value.Result = $"max({expContext.Value.ParsedContent["column"]})";
return default;
}
/// <summary>
/// min(column)
/// </summary>
/// <typeparam name="T3"></typeparam>
/// <param name="column"></param>
/// <returns></returns>
public static T3 AggregateMin<T3>(T3 column)
{
expContext.Value.Result = $"min({expContext.Value.ParsedContent["column"]})";
return default;
}
#region SqlServer/PostgreSQL over
/// <summary>
/// rank() over(order by ...)
/// </summary>
/// <returns></returns>
public static ISqlOver<long> Rank() => Over<long>("rank()");
/// <summary>
/// dense_rank() over(order by ...)
/// </summary>