123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209 |
- // Code generated by ent, DO NOT EDIT.
- package intercept
- import (
- "context"
- "fmt"
- "wechat-api/ent"
- "wechat-api/ent/contact"
- "wechat-api/ent/predicate"
- "wechat-api/ent/server"
- "wechat-api/ent/wx"
- "entgo.io/ent/dialect/sql"
- )
- // The Query interface represents an operation that queries a graph.
- // By using this interface, users can write generic code that manipulates
- // query builders of different types.
- type Query interface {
- // Type returns the string representation of the query type.
- Type() string
- // Limit the number of records to be returned by this query.
- Limit(int)
- // Offset to start from.
- Offset(int)
- // Unique configures the query builder to filter duplicate records.
- Unique(bool)
- // Order specifies how the records should be ordered.
- Order(...func(*sql.Selector))
- // WhereP appends storage-level predicates to the query builder. Using this method, users
- // can use type-assertion to append predicates that do not depend on any generated package.
- WhereP(...func(*sql.Selector))
- }
- // The Func type is an adapter that allows ordinary functions to be used as interceptors.
- // Unlike traversal functions, interceptors are skipped during graph traversals. Note that the
- // implementation of Func is different from the one defined in entgo.io/ent.InterceptFunc.
- type Func func(context.Context, Query) error
- // Intercept calls f(ctx, q) and then applied the next Querier.
- func (f Func) Intercept(next ent.Querier) ent.Querier {
- return ent.QuerierFunc(func(ctx context.Context, q ent.Query) (ent.Value, error) {
- query, err := NewQuery(q)
- if err != nil {
- return nil, err
- }
- if err := f(ctx, query); err != nil {
- return nil, err
- }
- return next.Query(ctx, q)
- })
- }
- // The TraverseFunc type is an adapter to allow the use of ordinary function as Traverser.
- // If f is a function with the appropriate signature, TraverseFunc(f) is a Traverser that calls f.
- type TraverseFunc func(context.Context, Query) error
- // Intercept is a dummy implementation of Intercept that returns the next Querier in the pipeline.
- func (f TraverseFunc) Intercept(next ent.Querier) ent.Querier {
- return next
- }
- // Traverse calls f(ctx, q).
- func (f TraverseFunc) Traverse(ctx context.Context, q ent.Query) error {
- query, err := NewQuery(q)
- if err != nil {
- return err
- }
- return f(ctx, query)
- }
- // The ContactFunc type is an adapter to allow the use of ordinary function as a Querier.
- type ContactFunc func(context.Context, *ent.ContactQuery) (ent.Value, error)
- // Query calls f(ctx, q).
- func (f ContactFunc) Query(ctx context.Context, q ent.Query) (ent.Value, error) {
- if q, ok := q.(*ent.ContactQuery); ok {
- return f(ctx, q)
- }
- return nil, fmt.Errorf("unexpected query type %T. expect *ent.ContactQuery", q)
- }
- // The TraverseContact type is an adapter to allow the use of ordinary function as Traverser.
- type TraverseContact func(context.Context, *ent.ContactQuery) error
- // Intercept is a dummy implementation of Intercept that returns the next Querier in the pipeline.
- func (f TraverseContact) Intercept(next ent.Querier) ent.Querier {
- return next
- }
- // Traverse calls f(ctx, q).
- func (f TraverseContact) Traverse(ctx context.Context, q ent.Query) error {
- if q, ok := q.(*ent.ContactQuery); ok {
- return f(ctx, q)
- }
- return fmt.Errorf("unexpected query type %T. expect *ent.ContactQuery", q)
- }
- // The ServerFunc type is an adapter to allow the use of ordinary function as a Querier.
- type ServerFunc func(context.Context, *ent.ServerQuery) (ent.Value, error)
- // Query calls f(ctx, q).
- func (f ServerFunc) Query(ctx context.Context, q ent.Query) (ent.Value, error) {
- if q, ok := q.(*ent.ServerQuery); ok {
- return f(ctx, q)
- }
- return nil, fmt.Errorf("unexpected query type %T. expect *ent.ServerQuery", q)
- }
- // The TraverseServer type is an adapter to allow the use of ordinary function as Traverser.
- type TraverseServer func(context.Context, *ent.ServerQuery) error
- // Intercept is a dummy implementation of Intercept that returns the next Querier in the pipeline.
- func (f TraverseServer) Intercept(next ent.Querier) ent.Querier {
- return next
- }
- // Traverse calls f(ctx, q).
- func (f TraverseServer) Traverse(ctx context.Context, q ent.Query) error {
- if q, ok := q.(*ent.ServerQuery); ok {
- return f(ctx, q)
- }
- return fmt.Errorf("unexpected query type %T. expect *ent.ServerQuery", q)
- }
- // The WxFunc type is an adapter to allow the use of ordinary function as a Querier.
- type WxFunc func(context.Context, *ent.WxQuery) (ent.Value, error)
- // Query calls f(ctx, q).
- func (f WxFunc) Query(ctx context.Context, q ent.Query) (ent.Value, error) {
- if q, ok := q.(*ent.WxQuery); ok {
- return f(ctx, q)
- }
- return nil, fmt.Errorf("unexpected query type %T. expect *ent.WxQuery", q)
- }
- // The TraverseWx type is an adapter to allow the use of ordinary function as Traverser.
- type TraverseWx func(context.Context, *ent.WxQuery) error
- // Intercept is a dummy implementation of Intercept that returns the next Querier in the pipeline.
- func (f TraverseWx) Intercept(next ent.Querier) ent.Querier {
- return next
- }
- // Traverse calls f(ctx, q).
- func (f TraverseWx) Traverse(ctx context.Context, q ent.Query) error {
- if q, ok := q.(*ent.WxQuery); ok {
- return f(ctx, q)
- }
- return fmt.Errorf("unexpected query type %T. expect *ent.WxQuery", q)
- }
- // NewQuery returns the generic Query interface for the given typed query.
- func NewQuery(q ent.Query) (Query, error) {
- switch q := q.(type) {
- case *ent.ContactQuery:
- return &query[*ent.ContactQuery, predicate.Contact, contact.OrderOption]{typ: ent.TypeContact, tq: q}, nil
- case *ent.ServerQuery:
- return &query[*ent.ServerQuery, predicate.Server, server.OrderOption]{typ: ent.TypeServer, tq: q}, nil
- case *ent.WxQuery:
- return &query[*ent.WxQuery, predicate.Wx, wx.OrderOption]{typ: ent.TypeWx, tq: q}, nil
- default:
- return nil, fmt.Errorf("unknown query type %T", q)
- }
- }
- type query[T any, P ~func(*sql.Selector), R ~func(*sql.Selector)] struct {
- typ string
- tq interface {
- Limit(int) T
- Offset(int) T
- Unique(bool) T
- Order(...R) T
- Where(...P) T
- }
- }
- func (q query[T, P, R]) Type() string {
- return q.typ
- }
- func (q query[T, P, R]) Limit(limit int) {
- q.tq.Limit(limit)
- }
- func (q query[T, P, R]) Offset(offset int) {
- q.tq.Offset(offset)
- }
- func (q query[T, P, R]) Unique(unique bool) {
- q.tq.Unique(unique)
- }
- func (q query[T, P, R]) Order(orders ...func(*sql.Selector)) {
- rs := make([]R, len(orders))
- for i := range orders {
- rs[i] = orders[i]
- }
- q.tq.Order(rs...)
- }
- func (q query[T, P, R]) WhereP(ps ...func(*sql.Selector)) {
- p := make([]P, len(ps))
- for i := range ps {
- p[i] = ps[i]
- }
- q.tq.Where(p...)
- }
|