| 413 | } |
| 414 | |
| 415 | func (eq *EntityQuery) prepareQuery(ctx context.Context) error { |
| 416 | for _, inter := range eq.inters { |
| 417 | if inter == nil { |
| 418 | return fmt.Errorf("ent: uninitialized interceptor (forgotten import ent/runtime?)") |
| 419 | } |
| 420 | if trv, ok := inter.(Traverser); ok { |
| 421 | if err := trv.Traverse(ctx, eq); err != nil { |
| 422 | return err |
| 423 | } |
| 424 | } |
| 425 | } |
| 426 | for _, f := range eq.ctx.Fields { |
| 427 | if !entity.ValidColumn(f) { |
| 428 | return &ValidationError{Name: f, err: fmt.Errorf("ent: invalid field %q for query", f)} |
| 429 | } |
| 430 | } |
| 431 | if eq.path != nil { |
| 432 | prev, err := eq.path(ctx) |
| 433 | if err != nil { |
| 434 | return err |
| 435 | } |
| 436 | eq.sql = prev |
| 437 | } |
| 438 | return nil |
| 439 | } |
| 440 | |
| 441 | func (eq *EntityQuery) sqlAll(ctx context.Context, hooks ...queryHook) ([]*Entity, error) { |
| 442 | var ( |