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

Method querySpec

pkg/database/ent/meta_query.go:443–484  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

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

Callers 2

sqlAllMethod · 0.95
sqlCountMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected