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

Method sqlAll

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

Source from the content-addressed store, hash-verified

366}
367
368func (feq *FsEventQuery) sqlAll(ctx context.Context, hooks ...queryHook) ([]*FsEvent, error) {
369 var (
370 nodes = []*FsEvent{}
371 _spec = feq.querySpec()
372 loadedTypes = [1]bool{
373 feq.withUser != nil,
374 }
375 )
376 _spec.ScanValues = func(columns []string) ([]any, error) {
377 return (*FsEvent).scanValues(nil, columns)
378 }
379 _spec.Assign = func(columns []string, values []any) error {
380 node := &FsEvent{config: feq.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, feq.driver, _spec); err != nil {
389 return nil, err
390 }
391 if len(nodes) == 0 {
392 return nodes, nil
393 }
394 if query := feq.withUser; query != nil {
395 if err := feq.loadUser(ctx, query, nodes, nil,
396 func(n *FsEvent, e *User) { n.Edges.User = e }); err != nil {
397 return nil, err
398 }
399 }
400 return nodes, nil
401}
402
403func (feq *FsEventQuery) loadUser(ctx context.Context, query *UserQuery, nodes []*FsEvent, init func(*FsEvent), assign func(*FsEvent, *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