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

Method querySpec

pkg/database/ent/machine_query.go:447–485  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

445}
446
447func (_q *MachineQuery) querySpec() *sqlgraph.QuerySpec {
448 _spec := sqlgraph.NewQuerySpec(machine.Table, machine.Columns, sqlgraph.NewFieldSpec(machine.FieldID, field.TypeInt))
449 _spec.From = _q.sql
450 if unique := _q.ctx.Unique; unique != nil {
451 _spec.Unique = *unique
452 } else if _q.path != nil {
453 _spec.Unique = true
454 }
455 if fields := _q.ctx.Fields; len(fields) > 0 {
456 _spec.Node.Columns = make([]string, 0, len(fields))
457 _spec.Node.Columns = append(_spec.Node.Columns, machine.FieldID)
458 for i := range fields {
459 if fields[i] != machine.FieldID {
460 _spec.Node.Columns = append(_spec.Node.Columns, fields[i])
461 }
462 }
463 }
464 if ps := _q.predicates; len(ps) > 0 {
465 _spec.Predicate = func(selector *sql.Selector) {
466 for i := range ps {
467 ps[i](selector)
468 }
469 }
470 }
471 if limit := _q.ctx.Limit; limit != nil {
472 _spec.Limit = *limit
473 }
474 if offset := _q.ctx.Offset; offset != nil {
475 _spec.Offset = *offset
476 }
477 if ps := _q.order; len(ps) > 0 {
478 _spec.Order = func(selector *sql.Selector) {
479 for i := range ps {
480 ps[i](selector)
481 }
482 }
483 }
484 return _spec
485}
486
487func (_q *MachineQuery) sqlQuery(ctx context.Context) *sql.Selector {
488 builder := sql.Dialect(_q.driver.Dialect())

Callers 2

sqlAllMethod · 0.95
sqlCountMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected