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

Method querySpec

pkg/database/ent/allowlist_query.go:477–515  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

475}
476
477func (_q *AllowListQuery) querySpec() *sqlgraph.QuerySpec {
478 _spec := sqlgraph.NewQuerySpec(allowlist.Table, allowlist.Columns, sqlgraph.NewFieldSpec(allowlist.FieldID, field.TypeInt))
479 _spec.From = _q.sql
480 if unique := _q.ctx.Unique; unique != nil {
481 _spec.Unique = *unique
482 } else if _q.path != nil {
483 _spec.Unique = true
484 }
485 if fields := _q.ctx.Fields; len(fields) > 0 {
486 _spec.Node.Columns = make([]string, 0, len(fields))
487 _spec.Node.Columns = append(_spec.Node.Columns, allowlist.FieldID)
488 for i := range fields {
489 if fields[i] != allowlist.FieldID {
490 _spec.Node.Columns = append(_spec.Node.Columns, fields[i])
491 }
492 }
493 }
494 if ps := _q.predicates; len(ps) > 0 {
495 _spec.Predicate = func(selector *sql.Selector) {
496 for i := range ps {
497 ps[i](selector)
498 }
499 }
500 }
501 if limit := _q.ctx.Limit; limit != nil {
502 _spec.Limit = *limit
503 }
504 if offset := _q.ctx.Offset; offset != nil {
505 _spec.Offset = *offset
506 }
507 if ps := _q.order; len(ps) > 0 {
508 _spec.Order = func(selector *sql.Selector) {
509 for i := range ps {
510 ps[i](selector)
511 }
512 }
513 }
514 return _spec
515}
516
517func (_q *AllowListQuery) sqlQuery(ctx context.Context) *sql.Selector {
518 builder := sql.Dialect(_q.driver.Dialect())

Callers 2

sqlAllMethod · 0.95
sqlCountMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected