MCPcopy Create free account
hub / github.com/cloudreve/cloudreve / sqlAll

Method sqlAll

ent/task_query.go:368–401  ·  view source on GitHub ↗
(ctx context.Context, hooks ...queryHook)

Source from the content-addressed store, hash-verified

366}
367
368func (tq *TaskQuery) sqlAll(ctx context.Context, hooks ...queryHook) ([]*Task, error) {
369 var (
370 nodes = []*Task{}
371 _spec = tq.querySpec()
372 loadedTypes = [1]bool{
373 tq.withUser != nil,
374 }
375 )
376 _spec.ScanValues = func(columns []string) ([]any, error) {
377 return (*Task).scanValues(nil, columns)
378 }
379 _spec.Assign = func(columns []string, values []any) error {
380 node := &Task{config: tq.config}
381 nodes = append(nodes, node)
382 node.Edges.loadedTypes = loadedTypes
383 return node.assignValues(columns, values)
384 }
385 for i := range hooks {
386 hooks[i](ctx, _spec)
387 }
388 if err := sqlgraph.QueryNodes(ctx, tq.driver, _spec); err != nil {
389 return nil, err
390 }
391 if len(nodes) == 0 {
392 return nodes, nil
393 }
394 if query := tq.withUser; query != nil {
395 if err := tq.loadUser(ctx, query, nodes, nil,
396 func(n *Task, e *User) { n.Edges.User = e }); err != nil {
397 return nil, err
398 }
399 }
400 return nodes, nil
401}
402
403func (tq *TaskQuery) loadUser(ctx context.Context, query *UserQuery, nodes []*Task, init func(*Task), assign func(*Task, *User)) error {
404 ids := make([]int, 0, len(nodes))

Callers

nothing calls this directly

Calls 4

querySpecMethod · 0.95
assignValuesMethod · 0.95
loadUserMethod · 0.95
scanValuesMethod · 0.45

Tested by

no test coverage detected