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

Method sqlAll

ent/user_query.go:657–754  ·  view source on GitHub ↗
(ctx context.Context, hooks ...queryHook)

Source from the content-addressed store, hash-verified

655}
656
657func (uq *UserQuery) sqlAll(ctx context.Context, hooks ...queryHook) ([]*User, error) {
658 var (
659 nodes = []*User{}
660 _spec = uq.querySpec()
661 loadedTypes = [9]bool{
662 uq.withGroup != nil,
663 uq.withFiles != nil,
664 uq.withDavAccounts != nil,
665 uq.withShares != nil,
666 uq.withPasskey != nil,
667 uq.withTasks != nil,
668 uq.withFsevents != nil,
669 uq.withEntities != nil,
670 uq.withOauthGrants != nil,
671 }
672 )
673 _spec.ScanValues = func(columns []string) ([]any, error) {
674 return (*User).scanValues(nil, columns)
675 }
676 _spec.Assign = func(columns []string, values []any) error {
677 node := &User{config: uq.config}
678 nodes = append(nodes, node)
679 node.Edges.loadedTypes = loadedTypes
680 return node.assignValues(columns, values)
681 }
682 for i := range hooks {
683 hooks[i](ctx, _spec)
684 }
685 if err := sqlgraph.QueryNodes(ctx, uq.driver, _spec); err != nil {
686 return nil, err
687 }
688 if len(nodes) == 0 {
689 return nodes, nil
690 }
691 if query := uq.withGroup; query != nil {
692 if err := uq.loadGroup(ctx, query, nodes, nil,
693 func(n *User, e *Group) { n.Edges.Group = e }); err != nil {
694 return nil, err
695 }
696 }
697 if query := uq.withFiles; query != nil {
698 if err := uq.loadFiles(ctx, query, nodes,
699 func(n *User) { n.Edges.Files = []*File{} },
700 func(n *User, e *File) { n.Edges.Files = append(n.Edges.Files, e) }); err != nil {
701 return nil, err
702 }
703 }
704 if query := uq.withDavAccounts; query != nil {
705 if err := uq.loadDavAccounts(ctx, query, nodes,
706 func(n *User) { n.Edges.DavAccounts = []*DavAccount{} },
707 func(n *User, e *DavAccount) { n.Edges.DavAccounts = append(n.Edges.DavAccounts, e) }); err != nil {
708 return nil, err
709 }
710 }
711 if query := uq.withShares; query != nil {
712 if err := uq.loadShares(ctx, query, nodes,
713 func(n *User) { n.Edges.Shares = []*Share{} },
714 func(n *User, e *Share) { n.Edges.Shares = append(n.Edges.Shares, e) }); err != nil {

Callers

nothing calls this directly

Calls 12

querySpecMethod · 0.95
assignValuesMethod · 0.95
loadGroupMethod · 0.95
loadFilesMethod · 0.95
loadDavAccountsMethod · 0.95
loadSharesMethod · 0.95
loadPasskeyMethod · 0.95
loadTasksMethod · 0.95
loadFseventsMethod · 0.95
loadEntitiesMethod · 0.95
loadOauthGrantsMethod · 0.95
scanValuesMethod · 0.45

Tested by

no test coverage detected