v0.0.389
Some checks failed
Build Docker and Deploy / Run goext test-suite (push) Has been cancelled

This commit is contained in:
2024-02-21 16:10:28 +01:00
parent 3cc8dccc63
commit 9e586f7706
6 changed files with 60 additions and 14 deletions

49
sq/filter.go Normal file
View File

@@ -0,0 +1,49 @@
package sq
import ct "gogs.mikescher.com/BlackForestBytes/goext/cursortoken"
type FilterSort struct {
Field string
Direction ct.SortDirection
}
type PaginateFilter interface {
SQL(params PP) (filterClause string, joinClause string, joinTables []string)
Sort() []FilterSort
}
type genericPaginateFilter struct {
sql func(params PP) (filterClause string, joinClause string, joinTables []string)
sort func() []FilterSort
}
func (g genericPaginateFilter) SQL(params PP) (filterClause string, joinClause string, joinTables []string) {
return g.sql(params)
}
func (g genericPaginateFilter) Sort() []FilterSort {
return g.sort()
}
func NewPaginateFilter(sql func(params PP) (filterClause string, joinClause string, joinTables []string), sort []FilterSort) PaginateFilter {
return genericPaginateFilter{
sql: func(params PP) (filterClause string, joinClause string, joinTables []string) {
return sql(params)
},
sort: func() []FilterSort {
return sort
},
}
}
func NewSimplePaginateFilter(filterClause string, params PP, sort []FilterSort) PaginateFilter {
return genericPaginateFilter{
sql: func(params PP) (filterClause string, joinClause string, joinTables []string) {
params.AddAll(params)
return filterClause, "", nil
},
sort: func() []FilterSort {
return sort
},
}
}

View File

@@ -3,22 +3,11 @@ package sq
import (
"context"
"fmt"
ct "gogs.mikescher.com/BlackForestBytes/goext/cursortoken"
"gogs.mikescher.com/BlackForestBytes/goext/exerr"
"gogs.mikescher.com/BlackForestBytes/goext/langext"
pag "gogs.mikescher.com/BlackForestBytes/goext/pagination"
)
type PaginateFilter interface {
SQL(params PP) (filterClause string, joinClause string, joinTables []string)
Sort() []FilterSort
}
type FilterSort struct {
Field string
Direction ct.SortDirection
}
func Paginate[TData any](ctx context.Context, q Queryable, table string, filter PaginateFilter, scanMode StructScanMode, scanSec StructScanSafety, page int, limit *int) ([]TData, pag.Pagination, error) {
prepParams := PP{}

View File

@@ -20,6 +20,12 @@ func (pp *PP) Add(v any) string {
return id
}
func (pp *PP) AddAll(other PP) {
for id, v := range other {
(*pp)[id] = v
}
}
func PPID() string {
return "p_" + langext.RandBase62(8)
}