【问题标题】:Need help creating sum aggregation operation in HotChocolate Filters需要帮助在 HotChocolate Filters 中创建求和聚合操作
【发布时间】:2021-04-16 07:29:56
【问题描述】:

这个问题基于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);

这将有效地为我提供在此时间点剩余 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

但在最终版本中,我希望能够不使用 const 编号而是使用 Employee WorkHours 进行查询

employees (where: {allocations: {sum: {gt: workHours}}}) {
  nodes{
    id, name
  }
}

谁能协助创建一个过滤器操作?也许你做过类似的事情,或者知道这实际上是不可能的。

如果有人想使用它,我已将我所有的代码放在 GitHub 存储库中https://github.com/LordLyng/sum-filter-example

【问题讨论】:

    标签: c# asp.net-core graphql hotchocolate


    【解决方案1】:

    我仍然没有找到使用实际聚合的解决方案。但是我找到了一种在数据库级别而不是在 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 方法来确保这些值不是由我们的应用程序设置的,而是留给数据库处理。

    计算列方法适用于单个表中的单个行,因此默认情况下现在可以查询其他表或行。这正是我解决问题所需要的。

    眼尖的观察者可能已经注意到,我在计算列中使用了一些看起来很像方法的东西。而事实上,仅此而已。

    我知道我会根据StartEnd 进行大量分配查找,因此我对这些进行了索引并通过运行dotnet ef migrations add "&lt;migration name"&gt; 创建了我的迁移。 剩下要做的就是修改生成的迁移。

    编辑后的迁移最终如下所示

    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,'1970-01-01 00:00:00.000', 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",
            table: "Employees",
            type: "float",
            nullable: false,
            computedColumnSql: "IIF([WorkHours] - [dbo].[AllocSumForEmployee] ([Id]) > 0, [WorkHours] - [dbo].[AllocSumForEmployee] ([Id]), 0)",
            stored: false);
    
        migrationBuilder.CreateIndex(
            name: "IX_Allocations_End",
            table: "Allocations",
            column: "End");
    
        migrationBuilder.CreateIndex(
            name: "IX_Allocations_Start",
            table: "Allocations",
            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,'1970-01-01 00:00:00.000', SYSUTCDATETIME()) 是一种在 T-SQL 中以毫秒为单位获取现在的 unix 时间戳的方法) , 以及 End 现在在哪里(即活动分配)。

    这实际上意味着计算属性的计算是在数据库上完成的,HotChocolte 并不明智。它允许我进行类似的查询

    query {
      employees (where: {available: {eq: true}}) {
        nodes {
          id, name, available, availableHours
        }
      }
    }
    

    甚至

    query {
      employees (where: {availableHours: {gt: 15}}) {
        nodes {
          id, name, available, availableHours
        }
      }
    }
    

    希望这可以帮助其他尝试使用聚合解决内联计算的人!

    替代方法的代码可在此处获得https://github.com/LordLyng/sum-filter-example/tree/computed-prop-on-entity

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2020-09-08
      • 2012-09-21
      • 1970-01-01
      • 1970-01-01
      • 2020-03-06
      • 2018-07-18
      • 2011-09-23
      • 2017-12-28
      相关资源
      最近更新 更多