聚合

分组

对 users 按 name 和 age 字段分组，并计算 age 的总和。

  1. package main
  4. import (
  5.     "context"
  8.     "<project>/ent"
  9.     "<project>/ent/user"
  10. )
  13. func Do(ctx context.Context, client *ent.Client) {
  14.     var v []struct {
  15.         Name  string `json:"name"`
  16.         Age   int    `json:"age"`
  17.         Sum   int    `json:"sum"`
  18.         Count int    `json:"count"`
  19.     }
  20.     err := client.User.Query().
  21.         GroupBy(user.FieldName, user.FieldAge).
  22.         Aggregate(ent.Count(), ent.Sum(user.FieldAge)).
  23.         Scan(ctx, &v)
  24. }

按单个字段分组.

  1. package main
  4. import (
  5.     "context"
  8.     "<project>/ent"
  9.     "<project>/ent/user"
  10. )
  13. func Do(ctx context.Context, client *ent.Client) {
  14.     names, err := client.User.
  15.         Query().
  16.         GroupBy(user.FieldName).
  17.         Strings(ctx)
  18. }

根据边进行分组

如果您想按照自己的逻辑进行聚合，可以使用自定义聚合函数。

下面展示了：如何根据用户的 id 和 name 进行分组，并计算其宠物的平均 age。

  1. package main
  4. import (
  5.     "context"
  6.     "log"
  9.     "<project>/ent"
  10.     "<project>/ent/pet"
  11.     "<project>/ent/user"
  12. )
  15. func Do(ctx context.Context, client *ent.Client) {
  16.     var users []struct {
  17.         ID      int
  18.         Name    string
  19.         Average float64
  20.     }
  21.     err := client.User.Query().
  22.         GroupBy(user.FieldID, user.FieldName).
  23.         Aggregate(func(s *sql.Selector) string {
  24.             t := sql.Table(pet.Table)
  25.             s.Join(t).On(s.C(user.FieldID), t.C(pet.OwnerColumn))
  26.             return sql.As(sql.Avg(t.C(pet.FieldAge)), "average")
  27.         }).
  28.         Scan(ctx, &users)
  29. }