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

Method sqlAll

ent/share_query.go:405–452  ·  view source on GitHub ↗
(ctx context.Context, hooks ...queryHook)

Source from the content-addressed store, hash-verified

403}
404
405func (sq *ShareQuery) sqlAll(ctx context.Context, hooks ...queryHook) ([]*Share, error) {
406 var (
407 nodes = []*Share{}
408 withFKs = sq.withFKs
409 _spec = sq.querySpec()
410 loadedTypes = [2]bool{
411 sq.withUser != nil,
412 sq.withFile != nil,
413 }
414 )
415 if sq.withUser != nil || sq.withFile != nil {
416 withFKs = true
417 }
418 if withFKs {
419 _spec.Node.Columns = append(_spec.Node.Columns, share.ForeignKeys...)
420 }
421 _spec.ScanValues = func(columns []string) ([]any, error) {
422 return (*Share).scanValues(nil, columns)
423 }
424 _spec.Assign = func(columns []string, values []any) error {
425 node := &Share{config: sq.config}
426 nodes = append(nodes, node)
427 node.Edges.loadedTypes = loadedTypes
428 return node.assignValues(columns, values)
429 }
430 for i := range hooks {
431 hooks[i](ctx, _spec)
432 }
433 if err := sqlgraph.QueryNodes(ctx, sq.driver, _spec); err != nil {
434 return nil, err
435 }
436 if len(nodes) == 0 {
437 return nodes, nil
438 }
439 if query := sq.withUser; query != nil {
440 if err := sq.loadUser(ctx, query, nodes, nil,
441 func(n *Share, e *User) { n.Edges.User = e }); err != nil {
442 return nil, err
443 }
444 }
445 if query := sq.withFile; query != nil {
446 if err := sq.loadFile(ctx, query, nodes, nil,
447 func(n *Share, e *File) { n.Edges.File = e }); err != nil {
448 return nil, err
449 }
450 }
451 return nodes, nil
452}
453
454func (sq *ShareQuery) loadUser(ctx context.Context, query *UserQuery, nodes []*Share, init func(*Share), assign func(*Share, *User)) error {
455 ids := make([]int, 0, len(nodes))

Callers

nothing calls this directly

Calls 5

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

Tested by

no test coverage detected