Method sqlQuery

ent/nodeversion_query.go:654–687

(ctx context.Context)

}

func (nvq *NodeVersionQuery) sqlQuery(ctx context.Context) *sql.Selector {
	builder := sql.Dialect(nvq.driver.Dialect())
	t1 := builder.Table(nodeversion.Table)
	columns := nvq.ctx.Fields
	if len(columns) == 0 {
		columns = nodeversion.Columns
	}
	selector := builder.Select(t1.Columns(columns...)...).From(t1)
	if nvq.sql != nil {
		selector = nvq.sql
		selector.Select(selector.Columns(columns...)...)
	}
	if nvq.ctx.Unique != nil && *nvq.ctx.Unique {
		selector.Distinct()
	}
	for _, m := range nvq.modifiers {
		m(selector)
	}
	for _, p := range nvq.predicates {
		p(selector)
	}
	for _, p := range nvq.order {
		p(selector)
	}
	if offset := nvq.ctx.Offset; offset != nil {
		// limit is mandatory for offset clause. We start
		// with default value, and override it below if needed.
		selector.Offset(*offset).Limit(math.MaxInt32)
	}
	if limit := nvq.ctx.Limit; limit != nil {
		selector.Limit(*limit)
	}
	return selector
}

// ForUpdate locks the selected rows against concurrent updates, and prevent them from being
// updated, deleted or "selected ... for update" by other sessions, until the transaction is