MCPcopy Create free account
hub / github.com/crowdsecurity/crowdsec / querySpec

Method querySpec

pkg/database/ent/alert_query.go:677–715  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

675}
676
677func (_q *AlertQuery) querySpec() *sqlgraph.QuerySpec {
678 _spec := sqlgraph.NewQuerySpec(alert.Table, alert.Columns, sqlgraph.NewFieldSpec(alert.FieldID, field.TypeInt))
679 _spec.From = _q.sql
680 if unique := _q.ctx.Unique; unique != nil {
681 _spec.Unique = *unique
682 } else if _q.path != nil {
683 _spec.Unique = true
684 }
685 if fields := _q.ctx.Fields; len(fields) > 0 {
686 _spec.Node.Columns = make([]string, 0, len(fields))
687 _spec.Node.Columns = append(_spec.Node.Columns, alert.FieldID)
688 for i := range fields {
689 if fields[i] != alert.FieldID {
690 _spec.Node.Columns = append(_spec.Node.Columns, fields[i])
691 }
692 }
693 }
694 if ps := _q.predicates; len(ps) > 0 {
695 _spec.Predicate = func(selector *sql.Selector) {
696 for i := range ps {
697 ps[i](selector)
698 }
699 }
700 }
701 if limit := _q.ctx.Limit; limit != nil {
702 _spec.Limit = *limit
703 }
704 if offset := _q.ctx.Offset; offset != nil {
705 _spec.Offset = *offset
706 }
707 if ps := _q.order; len(ps) > 0 {
708 _spec.Order = func(selector *sql.Selector) {
709 for i := range ps {
710 ps[i](selector)
711 }
712 }
713 }
714 return _spec
715}
716
717func (_q *AlertQuery) sqlQuery(ctx context.Context) *sql.Selector {
718 builder := sql.Dialect(_q.driver.Dialect())

Callers 2

sqlAllMethod · 0.95
sqlCountMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected