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

Method querySpec

pkg/database/ent/metric_query.go:367–405  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

365}
366
367func (_q *MetricQuery) querySpec() *sqlgraph.QuerySpec {
368 _spec := sqlgraph.NewQuerySpec(metric.Table, metric.Columns, sqlgraph.NewFieldSpec(metric.FieldID, field.TypeInt))
369 _spec.From = _q.sql
370 if unique := _q.ctx.Unique; unique != nil {
371 _spec.Unique = *unique
372 } else if _q.path != nil {
373 _spec.Unique = true
374 }
375 if fields := _q.ctx.Fields; len(fields) > 0 {
376 _spec.Node.Columns = make([]string, 0, len(fields))
377 _spec.Node.Columns = append(_spec.Node.Columns, metric.FieldID)
378 for i := range fields {
379 if fields[i] != metric.FieldID {
380 _spec.Node.Columns = append(_spec.Node.Columns, fields[i])
381 }
382 }
383 }
384 if ps := _q.predicates; len(ps) > 0 {
385 _spec.Predicate = func(selector *sql.Selector) {
386 for i := range ps {
387 ps[i](selector)
388 }
389 }
390 }
391 if limit := _q.ctx.Limit; limit != nil {
392 _spec.Limit = *limit
393 }
394 if offset := _q.ctx.Offset; offset != nil {
395 _spec.Offset = *offset
396 }
397 if ps := _q.order; len(ps) > 0 {
398 _spec.Order = func(selector *sql.Selector) {
399 for i := range ps {
400 ps[i](selector)
401 }
402 }
403 }
404 return _spec
405}
406
407func (_q *MetricQuery) sqlQuery(ctx context.Context) *sql.Selector {
408 builder := sql.Dialect(_q.driver.Dialect())

Callers 2

sqlAllMethod · 0.95
sqlCountMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected