Method sqlAll

ent/storagepolicy_query.go:477–534

(ctx context.Context, hooks ...queryHook)

}

func (spq *StoragePolicyQuery) sqlAll(ctx context.Context, hooks ...queryHook) ([]*StoragePolicy, error) {
	var (
		nodes       = []*StoragePolicy{}
		_spec       = spq.querySpec()
		loadedTypes = [4]bool{
			spq.withGroups != nil,
			spq.withFiles != nil,
			spq.withEntities != nil,
			spq.withNode != nil,
		}
	)
	_spec.ScanValues = func(columns []string) ([]any, error) {
		return (*StoragePolicy).scanValues(nil, columns)
	}
	_spec.Assign = func(columns []string, values []any) error {
		node := &StoragePolicy{config: spq.config}
		nodes = append(nodes, node)
		node.Edges.loadedTypes = loadedTypes
		return node.assignValues(columns, values)
	}
	for i := range hooks {
		hooks[i](ctx, _spec)
	}
	if err := sqlgraph.QueryNodes(ctx, spq.driver, _spec); err != nil {
		return nil, err
	}
	if len(nodes) == 0 {
		return nodes, nil
	}
	if query := spq.withGroups; query != nil {
		if err := spq.loadGroups(ctx, query, nodes,
			func(n *StoragePolicy) { n.Edges.Groups = []*Group{} },
			func(n *StoragePolicy, e *Group) { n.Edges.Groups = append(n.Edges.Groups, e) }); err != nil {
			return nil, err
		}
	}
	if query := spq.withFiles; query != nil {
		if err := spq.loadFiles(ctx, query, nodes,
			func(n *StoragePolicy) { n.Edges.Files = []*File{} },
			func(n *StoragePolicy, e *File) { n.Edges.Files = append(n.Edges.Files, e) }); err != nil {
			return nil, err
		}
	}
	if query := spq.withEntities; query != nil {
		if err := spq.loadEntities(ctx, query, nodes,
			func(n *StoragePolicy) { n.Edges.Entities = []*Entity{} },
			func(n *StoragePolicy, e *Entity) { n.Edges.Entities = append(n.Edges.Entities, e) }); err != nil {
			return nil, err
		}
	}
	if query := spq.withNode; query != nil {
		if err := spq.loadNode(ctx, query, nodes, nil,
			func(n *StoragePolicy, e *Node) { n.Edges.Node = e }); err != nil {
			return nil, err
		}
	}
	return nodes, nil
}