如何解决需要帮助在 HotChocolate 过滤器中创建总和聚合操作
这个问题基于 https://github.com/ChilliCream/hotchocolate/issues/924 中的讨论 - 这也是我的灵感来源。
我有一个系统，我在其中保存了一份员工名单。每个员工都有一个 WorkHours 属性，表示您每周工作多少小时。
我还有一系列任务需要由上述员工解决。
关联是通过分配类处理的。此类包含两个 unix 时间戳 Start 和 End，表示员工正在处理特定任务的时间段。此外，它们有一个 HoursPerWeek 属性，表示员工每周必须在给定的任务上花费多少小时，HoursPerWeek 是必要的，因为只要是 Allocation.HoursPerWeek 的总和，员工就可以在同一时间段内与多个任务相关联不超过 Employee.WorkHours。
本质上，我想按照这个 LINQ 查询的方式实现一些东西
var ts = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
employees.Where(e =>
e.Allocations
.Where(a => a.Start < ts && a.End > ts)
.Sum(a => a.HoursPerWeek)
< e.WorkHours);
这将有效地为我提供在这个时间点有剩余工作时间的任何员工。
我无法在我的查询中直接引用employee.WorkHours，但我试图与双打相比使其工作。这就是我现在已经走了多远
public class CustomFilterConventionExtension : FilterConventionExtension
{
protected override void Configure(IFilterConventionDescriptor descriptor)
{
descriptor.Operation(CustomFilterOperations.Sum)
.Name("sum");
descriptor.Configure<ListFilterInputType<FilterInputType<Allocation>>>(descriptor =>
{
descriptor
.Operation(CustomFilterOperations.Sum)
.Type<ComparableOperationFilterInputType<double>>();
});
descriptor.AddProviderExtension(new QueryableFilterProviderExtension(
y =>
{
y.AddFieldHandler<EmployeeAllocationSumOperationHandler>();
}));
}
}
public class EmployeeAllocationSumOperationHandler : FilterOperationHandler<QueryableFilterContext,Expression>
{
public override bool CanHandle(ITypeCompletionContext context,IFilterInputTypeDefinition typeDefinition,IFilterFieldDefinition fieldDefinition)
{
return context.Type is IListFilterInputType &&
fieldDefinition is FilterOperationFieldDefinition { Id: CustomFilterOperations.Sum };
}
public override bool TryHandleEnter(QueryableFilterContext context,IFilterField field,ObjectFieldNode node,[NotNullWhen(true)] out ISyntaxVisitorAction? action)
{
var ts = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
var property = context.GetInstance();
Expression<Func<ICollection<Allocation>,double>> expression = _ => _
.Where(_ => _.Start < ts && _.End > ts)
.Sum(_ => _.HoursPerWeek);
var invoke = Expression.Invoke(expression,property);
context.PushInstance(invoke);
action = SyntaxVisitor.Continue;
return true;
}
}
services.AddGraphQLServer()
.AddQueryType<EmployeeQuery>()
.AddType<EmployeeType>()
.AddProjections()
.AddFiltering()
.AddConvention<IFilterConvention,CustomFilterConventionExtension>()
.AddSorting();
有了这个，我然后尝试编写我的查询
employees (where: {allocations: {sum: {gt: 5}}}) {
nodes{
id,name
}
}
然而，此实现不断抛出异常，因为它无法从 System.Obejct 强制转换为 System.Generic.IEnumerable。
然而，在最终版本中，我希望能够不使用常量编号，而是使用像这样的员工工作时间进行查询
employees (where: {allocations: {sum: {gt: workHours}}}) {
nodes{
id,name
}
}
任何人都可以协助创建吸滤器操作？也许你已经做过类似的事情，或者知道这实际上是不可能的。
我已将所有代码放在 GitHub 存储库中，如果有人愿意使用它https://github.com/LordLyng/sum-filter-example
解决方法
我仍然没有找到使用实际聚合的解决方案。但是我找到了一种在数据库级别而不是在 GraphQL 中解决我的特定问题的方法。
我最终为我的实体 public bool Available { get; set; } 和 public double AvailableHours { get; set; } 添加了两个道具。添加这些道具后，我为员工实体编辑了我的 EntityTypeConfiguration。在这里，我添加了以下几行。请原谅我的 SQL，我远非流利 ;)
builder.Property(e => e.Available)
.HasComputedColumnSql("CASE WHEN [WorkHours] > [dbo].[AllocSumForEmployee] ([Id]) THEN CAST(1 AS BIT) ELSE CAST(0 AS BIT) END",stored: false)
.ValueGeneratedOnAddOrUpdate();
builder.Property(e => e.AvailableHours)
.HasComputedColumnSql("IIF([WorkHours] - [dbo].[AllocSumForEmployee] ([Id]) > 0,[WorkHours] - [dbo].[AllocSumForEmployee] ([Id]),0)",stored: false)
.ValueGeneratedOnAddOrUpdate();
这里发生了一些事情 - 首先，我们向我们的数据库模式添加了一个计算列。其次，我们添加 ValueGeneratedOnAddOrUpdate 方法以确保这些值不是由我们的应用程序设置的，而是由数据库来处理。
计算列方法在单个表中的单个行的上下文中工作，因此默认情况下现在可以查询其他表或行。这正是我解决问题所需要的。
眼尖的观察者可能已经注意到我在计算列中使用了一些看起来非常像方法的东西。而事实上，仅此而已。
我知道我会根据 Start 和 End 进行大量分配查找，因此我将它们编入索引并通过运行 dotnet ef migrations add "<migration name"> 来创建我的迁移。
剩下要做的就是修改生成的迁移。
编辑后的迁移结果如下
protected override void Up(MigrationBuilder migrationBuilder)
{
migrationBuilder.Sql(@"
CREATE FUNCTION [dbo].[AllocSumForEmployee] (@id nvarchar(36))
RETURNS Float
AS
BEGIN
RETURN
(SELECT COALESCE(SUM([HoursPerWeek]),0) FROM [Allocations]
WHERE
[Start] < DATEDIFF_BIG(MILLISECOND,'1970-01-01 00:00:00.000',SYSUTCDATETIME()) AND
[End] > DATEDIFF_BIG(MILLISECOND,SYSUTCDATETIME()) AND
[EmployeeId] = @id)
END
");
migrationBuilder.AddColumn<bool>(
name: "Available",table: "Employees",type: "bit",nullable: false,computedColumnSql: "CASE WHEN [WorkHours] > [dbo].[AllocSumForEmployee] ([Id]) THEN CAST(1 AS BIT) ELSE CAST(0 AS BIT) END",stored: false);
migrationBuilder.AddColumn<double>(
name: "AvailableHours",type: "float",computedColumnSql: "IIF([WorkHours] - [dbo].[AllocSumForEmployee] ([Id]) > 0,stored: false);
migrationBuilder.CreateIndex(
name: "IX_Allocations_End",table: "Allocations",column: "End");
migrationBuilder.CreateIndex(
name: "IX_Allocations_Start",column: "Start");
}
protected override void Down(MigrationBuilder migrationBuilder)
{
migrationBuilder.DropIndex(
name: "IX_Allocations_End",table: "Allocations");
migrationBuilder.DropIndex(
name: "IX_Allocations_Start",table: "Allocations");
migrationBuilder.DropColumn(
name: "Available",table: "Employees");
migrationBuilder.DropColumn(
name: "AvailableHours",table: "Employees");
migrationBuilder.Sql("DROP FUNCTION [dbo].[AllocSumForEmployee]");
}
我添加的“唯一”不是自动生成的东西是 Up 方法的第一部分和 Down 方法的最后一部分。有效地在 Up 中注册用户定义的函数并在 Down 中删除该函数。
我的函数返回给定员工的HoursPerWeek所有分配的总和，其中Start（以毫秒为单位存储为unix时间戳）在现在之前（DATEDIFF_BIG(MILLISECOND,SYSUTCDATETIME())是一种以毫秒为单位的unix时间戳在T- SQL)，以及现在之后 End 的位置（即活动分配）。
这实际上意味着计算属性的计算是在数据库上完成的，而 HotChocolte 也不聪明。它允许我做像
这样的查询query {
employees (where: {available: {eq: true}}) {
nodes {
id,name,available,availableHours
}
}
}
甚至
query {
employees (where: {availableHours: {gt: 15}}) {
nodes {
id,availableHours
}
}
}
希望这能帮助其他尝试使用聚合解决内联计算的人！
此处提供替代方法的代码https://github.com/LordLyng/sum-filter-example/tree/computed-prop-on-entity
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
