| 413 | } |
| 414 | |
| 415 | func (_q *DBPackageQuery) sqlQuery(ctx context.Context) *sql.Selector { |
| 416 | builder := sql.Dialect(_q.driver.Dialect()) |
| 417 | t1 := builder.Table(dbpackage.Table) |
| 418 | columns := _q.ctx.Fields |
| 419 | if len(columns) == 0 { |
| 420 | columns = dbpackage.Columns |
| 421 | } |
| 422 | selector := builder.Select(t1.Columns(columns...)...).From(t1) |
| 423 | if _q.sql != nil { |
| 424 | selector = _q.sql |
| 425 | selector.Select(selector.Columns(columns...)...) |
| 426 | } |
| 427 | if _q.ctx.Unique != nil && *_q.ctx.Unique { |
| 428 | selector.Distinct() |
| 429 | } |
| 430 | for _, m := range _q.modifiers { |
| 431 | m(selector) |
| 432 | } |
| 433 | for _, p := range _q.predicates { |
| 434 | p(selector) |
| 435 | } |
| 436 | for _, p := range _q.order { |
| 437 | p(selector) |
| 438 | } |
| 439 | if offset := _q.ctx.Offset; offset != nil { |
| 440 | // limit is mandatory for offset clause. We start |
| 441 | // with default value, and override it below if needed. |
| 442 | selector.Offset(*offset).Limit(math.MaxInt32) |
| 443 | } |
| 444 | if limit := _q.ctx.Limit; limit != nil { |
| 445 | selector.Limit(*limit) |
| 446 | } |
| 447 | return selector |
| 448 | } |
| 449 | |
| 450 | // Modify adds a query modifier for attaching custom logic to queries. |
| 451 | func (_q *DBPackageQuery) Modify(modifiers ...func(s *sql.Selector)) *DBPackageSelect { |