ent/entc/gen/template/dialect/sql/select.tmpl

{{/*
Copyright 2019-present Facebook Inc. All rights reserved.
This source code is licensed under the Apache 2.0 license found
in the LICENSE file in the root directory of this source tree.
*/}}

{{ define "dialect/sql/select" }}
{{ $builder := pascal $.Scope.Builder }}
{{ $receiver := receiver $builder }}

func ({{ $receiver }} *{{ $builder }}) sqlScan(ctx context.Context, v interface{}) error {
	for _, f := range {{ $receiver }}.fields {
		if !{{ $.Package }}.ValidColumn(f) {
			return &ValidationError{Name: f, err: fmt.Errorf("invalid field %q for selection", f)}
		}
	}
	rows := &sql.Rows{}
	query, args := {{ $receiver }}.sqlQuery().Query()
	if err := {{ $receiver }}.driver.Query(ctx, query, args, rows); err != nil {
		return err
	}
	defer rows.Close()
	return sql.ScanSlice(rows, v)
}


func ({{ $receiver }} *{{ $builder }}) sqlQuery() sql.Querier {
	selector := {{ $receiver }}.sql
	selector.Select(selector.Columns({{ $receiver }}.fields...)...)
	return selector
}
{{ end }}