Merge branch 'different-approach'

app/main.go

@@ -8,7 +8,6 @@ import (
 	"repo-pattern/app/models"
 	"repo-pattern/app/repository"
 	"repo-pattern/app/repository/smartfilter"
-	"time"
 
 	"gorm.io/gorm"
 )
@@ -26,19 +25,21 @@ func doMagic(db *gorm.DB) {
 	// serialNumber := "222"
 	// serialNumberContains := "323"
 	// issuer := "FINA"
-	location, _ := time.LoadLocation("UTC")
-	createdTime := time.Date(2024, 5, 26, 16, 8, 0, 0, location)
+	// location, _ := time.LoadLocation("UTC")
+	// createdTime := time.Date(2024, 5, 26, 16, 8, 0, 0, location)
+	ids := []string{"eb2bcac6-5173-4dbb-93b7-e7c03b924a03", "db9fb837-3483-4736-819d-f427dc8cda23", "1fece5e7-8e8d-4828-8298-3b1f07fd29ff"}
 
-	f := smartfilter.SmartCertFilter[models.Cert]{
+	filter := smartfilter.CertFilter{
 		// Alive: &FALSE,
 		// Id:    &id,
 		// SerialNumber: &serialNumber,
 		// SerialNumberContains: &serialNumberContains,
+		Ids: &ids,
 		// IssuerContains: &issuer,
-		CreatedAt_Lt: &createdTime,
+		// CreatedAt_Lt:   &createdTime,
 	}
 
-	query, err = f.ToQuery(query)
+	query, err = smartfilter.ToQuery(models.Cert{}, filter, query)
 	if err != nil {
 		panic(err)
 	}
@@ -51,6 +52,58 @@ func doMagic(db *gorm.DB) {
 	}
 }
 
+func doList(db *gorm.DB) {
+	repo := repository.RepoBase[models.Cert]{}
+	repo.Init(db)
+
+	filter := smartfilter.CertFilter{
+		Alive: &TRUE,
+	}
+
+	certs, err := repo.List(filter)
+	if err != nil {
+		panic(err)
+	}
+
+	for n, cert := range *certs {
+		fmt.Printf(">> [%d] %+v  %s (alive %t)\n", n, cert.Id, cert.CreatedAt, cert.Alive)
+	}
+}
+
+func doGet(db *gorm.DB) {
+	repo := repository.RepoBase[models.Cert]{}
+	repo.Init(db)
+
+	id := "db9fb837-3483-4736-819d-f427dc8cda23"
+
+	filter := smartfilter.CertFilter{
+		Id: &id,
+	}
+
+	cert, err := repo.Get(filter)
+	if err != nil {
+		panic(err)
+	}
+	fmt.Printf(">> %+v  %s (alive %t)\n", cert.Id, cert.CreatedAt, cert.Alive)
+}
+
+func doExists(db *gorm.DB) {
+	repo := repository.RepoBase[models.Cert]{}
+	repo.Init(db)
+
+	id := "db9fb837-3483-4736-819d-f427dc8cda23"
+
+	filter := smartfilter.CertFilter{
+		Id: &id,
+	}
+
+	exists, err := repo.Exists(filter)
+	if err != nil {
+		panic(err)
+	}
+	fmt.Printf(">> EXISTS: %t\n", exists)
+}
+
 func main() {
 	cfg.Init()
 	logging.Init()
@@ -60,6 +113,8 @@ func main() {
 	repository.Dao = repository.CreateDAO(db)
 
 	doMagic(db)
-
-	fmt.Println("Running...")
+	// doList(db)
+	// doGet(db)
+	// doExists(db)
+	// inheritance.DoInheritanceTest()
 }

app/repository/methods.go

@@ -0,0 +1,84 @@
+package repository
+
+import (
+	"errors"
+	"repo-pattern/app/repository/smartfilter"
+
+	"gorm.io/gorm"
+	"gorm.io/gorm/schema"
+)
+
+type ListMethod[T schema.Tabler] struct {
+	DbConn *gorm.DB
+}
+
+func (m *ListMethod[T]) Init(dbConn *gorm.DB) {
+	m.DbConn = dbConn
+}
+
+func (m ListMethod[T]) List(filter interface{}) (*[]T, error) {
+	var (
+		model  T
+		models []T
+	)
+
+	query, err := smartfilter.ToQuery(model, filter, m.DbConn)
+	if err != nil {
+		return nil, err
+	}
+
+	query.Find(&models)
+	return &models, nil
+}
+
+type GetMethod[T schema.Tabler] struct {
+	DbConn *gorm.DB
+}
+
+func (m *GetMethod[T]) Init(dbConn *gorm.DB) {
+	m.DbConn = dbConn
+}
+
+func (m GetMethod[T]) Get(filter interface{}) (*T, error) {
+	var (
+		model T
+	)
+
+	query, err := smartfilter.ToQuery(model, filter, m.DbConn)
+	if err != nil {
+		return nil, err
+	}
+
+	result := query.First(&model)
+	if result.Error != nil {
+		return nil, result.Error
+	}
+
+	return &model, nil
+}
+
+type ExistsMethod[T schema.Tabler] struct {
+	DbConn *gorm.DB
+}
+
+func (m *ExistsMethod[T]) Init(dbConn *gorm.DB) {
+	m.DbConn = dbConn
+}
+
+func (m ExistsMethod[T]) Exists(filter interface{}) (bool, error) {
+	var (
+		model T
+	)
+
+	query := m.DbConn.Model(model)
+
+	query, err := smartfilter.ToQuery(model, filter, query)
+	if err != nil {
+		return false, err
+	}
+
+	result := query.Select("*").First(&model)
+
+	exists := !errors.Is(result.Error, gorm.ErrRecordNotFound) && result.Error == nil
+	return exists, nil
+}

app/repository/repository.go

@@ -0,0 +1,29 @@
+package repository
+
+import (
+	"gorm.io/gorm"
+	"gorm.io/gorm/schema"
+)
+
+type MethodInitInterface interface {
+	Init(dbConn *gorm.DB)
+}
+
+type RepoBase[T schema.Tabler] struct {
+	DbConn int
+	ListMethod[T]
+	GetMethod[T]
+	ExistsMethod[T]
+	methods []MethodInitInterface
+}
+
+func (b *RepoBase[T]) InitMethods(dbConn *gorm.DB) {
+	for _, method := range b.methods {
+		method.Init(dbConn)
+	}
+}
+
+func (m *RepoBase[T]) Init(dbConn *gorm.DB) {
+	m.methods = []MethodInitInterface{&m.ListMethod, &m.GetMethod, &m.ExistsMethod}
+	m.InitMethods(dbConn)
+}

app/repository/smartfilter/filterfield.go

@@ -16,7 +16,11 @@ type FilterField struct {
 	uintValue   *uint64
 	floatValue  *float64
 	strValue    *string
-	timeValue  *time.Time
+	boolValues  *[]bool
+	intValues   *[]int64
+	uintValues  *[]uint64
+	floatValues *[]float64
+	strValues   *[]string
 }
 
 func (ff *FilterField) setValueFromReflection(v reflect.Value) {
@@ -24,17 +28,70 @@ func (ff *FilterField) setValueFromReflection(v reflect.Value) {
 	fn(ff, v)
 }
 
-// func (ff *FilterField) getValueWithOperator(v reflect.Value) string {
-// 	value := ff.getValue(v)
+func (ff *FilterField) appendStr(value string) {
+	var valueArray []string
 
-// 	switch ff.valueKind {
-// 	case reflect.Bool:
-// 		return fmt.Sprintf("IS %s", value)
-// 	case reflect.Int, reflect.Uint, reflect.Float32, reflect.Float64, reflect.String:
-// 		return fmt.Sprintf("= %s", value)
-// 	}
-// 	return "???"
-// }
+	if ff.strValues == nil {
+		valueArray = make([]string, 0)
+	} else {
+		valueArray = *ff.strValues
+	}
+	valueArray = append(valueArray, value)
+	ff.strValues = &valueArray
+	ff.valueKind = reflect.String
+}
+
+func (ff *FilterField) appendBool(value bool) {
+	var valueArray []bool
+
+	if ff.boolValues == nil {
+		valueArray = make([]bool, 0)
+	} else {
+		valueArray = *ff.boolValues
+	}
+	valueArray = append(valueArray, value)
+	ff.boolValues = &valueArray
+	ff.valueKind = reflect.Bool
+}
+
+func (ff *FilterField) appendInt(value int64) {
+	var valueArray []int64
+
+	if ff.boolValues == nil {
+		valueArray = make([]int64, 0)
+	} else {
+		valueArray = *ff.intValues
+	}
+	valueArray = append(valueArray, value)
+	ff.intValues = &valueArray
+	ff.valueKind = reflect.Int
+}
+
+func (ff *FilterField) appendUint(value uint64) {
+	var valueArray []uint64
+
+	if ff.boolValues == nil {
+		valueArray = make([]uint64, 0)
+	} else {
+		valueArray = *ff.uintValues
+	}
+	valueArray = append(valueArray, value)
+	ff.uintValues = &valueArray
+	ff.valueKind = reflect.Int
+}
+
+func (ff *FilterField) appendFloat(value float64) {
+	var valueArray []float64
+
+	if ff.boolValues == nil {
+		valueArray = make([]float64, 0)
+	} else {
+		valueArray = *ff.floatValues
+	}
+	valueArray = append(valueArray, value)
+	ff.floatValues = &valueArray
+	ff.valueKind = reflect.Int
+}
 
 type valueGetterFunc func(ff *FilterField, v reflect.Value) error
 
@@ -132,10 +189,10 @@ func newTypeGetter(t reflect.Type, allowAddr bool) valueGetterFunc {
 		}
 	// case reflect.Map:
 	// 	return newMapEncoder(t)
-	// case reflect.Slice:
-	// 	return newSliceEncoder(t)
+	case reflect.Slice:
+		return newSliceGetter(t)
 	// case reflect.Array:
-	// 	return newArrayEncoder(t)
+	// 	return newArrayGetter(t)
 	case reflect.Pointer:
 		return newPtrValueGetter(t)
 	}
@@ -143,15 +200,64 @@ func newTypeGetter(t reflect.Type, allowAddr bool) valueGetterFunc {
 }
 
 type ptrValueGetter struct {
-	elemEnc valueGetterFunc
+	elemGetter valueGetterFunc
 }
 
 func (pvg ptrValueGetter) getValue(ff *FilterField, v reflect.Value) error {
-	pvg.elemEnc(ff, v.Elem())
+	pvg.elemGetter(ff, v.Elem())
 	return nil
 }
 
 func newPtrValueGetter(t reflect.Type) valueGetterFunc {
-	enc := ptrValueGetter{elemEnc: typeGetter(t.Elem())}
+	enc := ptrValueGetter{elemGetter: typeGetter(t.Elem())}
+	return enc.getValue
+}
+
+type arrayGetter struct {
+	elemGetter valueGetterFunc
+}
+
+func (ag arrayGetter) getValue(ff *FilterField, v reflect.Value) error {
+	ag.elemGetter(ff, v.Elem())
+	return nil
+}
+
+func newArrayGetter(t reflect.Type) valueGetterFunc {
+	enc := arrayGetter{elemGetter: typeGetter(t.Elem())}
+	return enc.getValue
+}
+
+type sliceGetter struct {
+	elemGetter valueGetterFunc
+}
+
+func (sg sliceGetter) getValue(ff *FilterField, v reflect.Value) error {
+	for n := range v.Len() {
+		element := v.Index(n)
+		fmt.Printf("ELEMENT: %+v\n", element)
+
+		switch element.Kind() {
+		case reflect.Bool:
+			ff.appendBool(element.Bool())
+		case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
+			ff.appendInt(element.Int())
+		case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64, reflect.Uintptr:
+			ff.appendUint(element.Uint())
+		case reflect.Float32, reflect.Float64:
+			ff.appendFloat(element.Float())
+		case reflect.String:
+			ff.appendStr(element.String())
+		}
+	}
+	fmt.Println(v.Len())
+	fmt.Printf(">>> getValue %+v\n", v)
+	fmt.Printf(">>> ff %+v\n", ff.strValues)
+	// fmt.Printf("%+v\n", v.Slice(0, 1))
+	// sg.elemGetter(ff, v.Elem())
+	return nil
+}
+
+func newSliceGetter(t reflect.Type) valueGetterFunc {
+	enc := sliceGetter{elemGetter: newArrayGetter(t)}
 	return enc.getValue
 }

app/repository/smartfilter/filters.go

@@ -49,3 +49,15 @@ func applyFilterLE[T bool | int64 | uint64 | float64 | string](
 ) *gorm.DB {
 	return query.Where(fmt.Sprintf("%s.%s <= ?", tableName, filterField.Name), value)
 }
+
+func applyFilterIN[T bool | int64 | uint64 | float64 | string](
+	query *gorm.DB, tableName string, filterField *FilterField, value *[]T,
+) *gorm.DB {
+	return query.Where(fmt.Sprintf("%s.%s IN (?)", tableName, filterField.Name), *value)
+}
+
+func applyFilterNOT_IN[T bool | int64 | uint64 | float64 | string](
+	query *gorm.DB, tableName string, filterField *FilterField, value *[]T,
+) *gorm.DB {
+	return query.Where(fmt.Sprintf("%s.%s NOT IN (?)", tableName, filterField.Name), *value)
+}

app/repository/smartfilter/handlers.go

@@ -0,0 +1,143 @@
+package smartfilter
+
+import (
+	"reflect"
+
+	"gorm.io/gorm"
+)
+
+func handleOperatorEQ(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
+	switch filterField.valueKind {
+	case reflect.Bool:
+		return applyFilterEQ(query, tableName, filterField, *filterField.boolValue)
+	case reflect.Int, reflect.Int16, reflect.Int32, reflect.Int64:
+		return applyFilterEQ(query, tableName, filterField, *filterField.intValue)
+	case reflect.Uint, reflect.Uint16, reflect.Uint32, reflect.Uint64:
+		return applyFilterEQ(query, tableName, filterField, *filterField.uintValue)
+	case reflect.Float32, reflect.Float64:
+		return applyFilterEQ(query, tableName, filterField, *filterField.floatValue)
+	case reflect.String:
+		return applyFilterEQ(query, tableName, filterField, *filterField.strValue)
+	}
+	return nil
+}
+
+func handleOperatorNE(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
+	switch filterField.valueKind {
+	case reflect.Bool:
+		return applyFilterNE(query, tableName, filterField, *filterField.boolValue)
+	case reflect.Int, reflect.Int16, reflect.Int32, reflect.Int64:
+		return applyFilterNE(query, tableName, filterField, *filterField.intValue)
+	case reflect.Uint, reflect.Uint16, reflect.Uint32, reflect.Uint64:
+		return applyFilterNE(query, tableName, filterField, *filterField.uintValue)
+	case reflect.Float32, reflect.Float64:
+		return applyFilterNE(query, tableName, filterField, *filterField.floatValue)
+	case reflect.String:
+		return applyFilterNE(query, tableName, filterField, *filterField.strValue)
+	}
+	return nil
+}
+
+func handleOperatorLIKE(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
+	switch filterField.valueKind {
+	case reflect.String:
+		return applyFilterLIKE(query, tableName, filterField, *filterField.strValue)
+	}
+	return nil
+}
+
+func handleOperatorILIKE(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
+	switch filterField.valueKind {
+	case reflect.String:
+		return applyFilterILIKE(query, tableName, filterField, *filterField.strValue)
+	}
+	return nil
+}
+
+func handleOperatorGT(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
+	switch filterField.valueKind {
+	case reflect.Int, reflect.Int16, reflect.Int32, reflect.Int64:
+		return applyFilterGT(query, tableName, filterField, *filterField.intValue)
+	case reflect.Uint, reflect.Uint16, reflect.Uint32, reflect.Uint64:
+		return applyFilterGT(query, tableName, filterField, *filterField.uintValue)
+	case reflect.Float32, reflect.Float64:
+		return applyFilterGT(query, tableName, filterField, *filterField.floatValue)
+	case reflect.String:
+		return applyFilterGT(query, tableName, filterField, *filterField.strValue)
+	}
+	return nil
+}
+
+func handleOperatorGE(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
+	switch filterField.valueKind {
+	case reflect.Int, reflect.Int16, reflect.Int32, reflect.Int64:
+		return applyFilterGE(query, tableName, filterField, *filterField.intValue)
+	case reflect.Uint, reflect.Uint16, reflect.Uint32, reflect.Uint64:
+		return applyFilterGE(query, tableName, filterField, *filterField.uintValue)
+	case reflect.Float32, reflect.Float64:
+		return applyFilterGE(query, tableName, filterField, *filterField.floatValue)
+	case reflect.String:
+		return applyFilterGE(query, tableName, filterField, *filterField.strValue)
+	}
+	return nil
+}
+
+func handleOperatorLT(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
+	switch filterField.valueKind {
+	case reflect.Int, reflect.Int16, reflect.Int32, reflect.Int64:
+		return applyFilterLT(query, tableName, filterField, *filterField.intValue)
+	case reflect.Uint, reflect.Uint16, reflect.Uint32, reflect.Uint64:
+		return applyFilterLT(query, tableName, filterField, *filterField.uintValue)
+	case reflect.Float32, reflect.Float64:
+		return applyFilterLT(query, tableName, filterField, *filterField.floatValue)
+	case reflect.String:
+		return applyFilterLT(query, tableName, filterField, *filterField.strValue)
+	}
+	return nil
+}
+
+func handleOperatorLE(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
+	switch filterField.valueKind {
+	case reflect.Int, reflect.Int16, reflect.Int32, reflect.Int64:
+		return applyFilterLE(query, tableName, filterField, *filterField.intValue)
+	case reflect.Uint, reflect.Uint16, reflect.Uint32, reflect.Uint64:
+		return applyFilterLE(query, tableName, filterField, *filterField.uintValue)
+	case reflect.Float32, reflect.Float64:
+		return applyFilterLE(query, tableName, filterField, *filterField.floatValue)
+	case reflect.String:
+		return applyFilterLE(query, tableName, filterField, *filterField.strValue)
+	}
+	return nil
+}
+
+func handleOperatorIN(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
+	switch filterField.valueKind {
+	case reflect.Bool:
+		return applyFilterIN(query, tableName, filterField, filterField.boolValues)
+	case reflect.Int, reflect.Int16, reflect.Int32, reflect.Int64:
+		return applyFilterIN(query, tableName, filterField, filterField.intValues)
+	case reflect.Uint, reflect.Uint16, reflect.Uint32, reflect.Uint64:
+		return applyFilterIN(query, tableName, filterField, filterField.uintValues)
+	case reflect.Float32, reflect.Float64:
+		return applyFilterIN(query, tableName, filterField, filterField.floatValues)
+	case reflect.String:
+		return applyFilterIN(query, tableName, filterField, filterField.strValues)
+	}
+	return nil
+}
+
+func handleOperatorNOT_IN(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
+	switch filterField.valueKind {
+	case reflect.Bool:
+		return applyFilterNOT_IN(query, tableName, filterField, filterField.boolValues)
+	case reflect.Int, reflect.Int16, reflect.Int32, reflect.Int64:
+		return applyFilterNOT_IN(query, tableName, filterField, filterField.intValues)
+	case reflect.Uint, reflect.Uint16, reflect.Uint32, reflect.Uint64:
+		return applyFilterNOT_IN(query, tableName, filterField, filterField.uintValues)
+	case reflect.Float32, reflect.Float64:
+		return applyFilterNOT_IN(query, tableName, filterField, filterField.floatValues)
+	case reflect.String:
+		return applyFilterNOT_IN(query, tableName, filterField, filterField.strValues)
+	}
+	return nil
+}

app/repository/smartfilter/handlers_test.go

@@ -0,0 +1,610 @@
+package smartfilter
+
+import (
+	"log"
+	"reflect"
+	"testing"
+
+	"github.com/DATA-DOG/go-sqlmock"
+	"github.com/go-playground/assert"
+	"gorm.io/driver/mysql"
+	"gorm.io/gorm"
+)
+
+func NewMockDB() (*gorm.DB, sqlmock.Sqlmock) {
+	db, mock, err := sqlmock.New()
+	if err != nil {
+		log.Fatalf("An error '%s' was not expected when opening a stub database connection", err)
+	}
+
+	gormDB, err := gorm.Open(mysql.New(mysql.Config{
+		Conn:                      db,
+		SkipInitializeWithVersion: true,
+	}), &gorm.Config{})
+
+	if err != nil {
+		log.Fatalf("An error '%s' was not expected when opening gorm database", err)
+	}
+
+	return gormDB, mock
+}
+
+type MyModel struct {
+	Id    int
+	Value string
+}
+
+func (m MyModel) TableName() string {
+	return "my_models"
+}
+
+type TestCase struct {
+	name        string
+	filterField FilterField
+	expected    string
+}
+
+var (
+	boolTrue    bool    = true
+	boolFalse   bool    = false
+	int64Value  int64   = -123456
+	uint64Value uint64  = 123456
+	floatValue  float64 = -123456.789
+	strValue    string  = "Some Value"
+
+	boolValues   = []bool{true, false}
+	int64Values  = []int64{-123456, 1, 123456}
+	uint64Values = []uint64{123456, 1234567, 1234568}
+	floatValues  = []float64{-123456.789, -1, 123456.789}
+	strValues    = []string{"First Value", "Second Value", "Third Value"}
+)
+
+func TestHandleOperatorEQ(t *testing.T) {
+	db, _ := NewMockDB()
+	testFunc := handleOperatorEQ
+
+	testCases := []TestCase{
+		{
+			name: "handleOperatorEQ bool true",
+			filterField: FilterField{
+				Name:      "my_field",
+				boolValue: &boolTrue,
+				valueKind: reflect.Bool,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field = true ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorEQ bool false",
+			filterField: FilterField{
+				Name:      "my_field",
+				boolValue: &boolFalse,
+				valueKind: reflect.Bool,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field = false ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorEQ int64",
+			filterField: FilterField{
+				Name:      "my_field",
+				intValue:  &int64Value,
+				valueKind: reflect.Int64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field = -123456 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorEQ uint64",
+			filterField: FilterField{
+				Name:      "my_field",
+				uintValue: &uint64Value,
+				valueKind: reflect.Uint64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field = 123456 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorEQ float",
+			filterField: FilterField{
+				Name:       "my_field",
+				floatValue: &floatValue,
+				valueKind:  reflect.Float64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field = -123456.789 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorEQ string",
+			filterField: FilterField{
+				Name:      "my_field",
+				strValue:  &strValue,
+				valueKind: reflect.String,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field = 'Some Value' ORDER BY `my_models`.`id` LIMIT 1",
+		},
+	}
+
+	for _, testCase := range testCases {
+		t.Run(testCase.name, func(t *testing.T) {
+			sql := db.ToSQL(func(tx *gorm.DB) *gorm.DB {
+				query := tx.Model(&MyModel{})
+				query = testFunc(query, "my_table", &testCase.filterField)
+				return query.First(&MyModel{})
+			})
+			assert.Equal(t, testCase.expected, sql)
+		})
+	}
+}
+
+func TestHandleOperatorNE(t *testing.T) {
+	db, _ := NewMockDB()
+	testFunc := handleOperatorNE
+
+	testCases := []TestCase{
+		{
+			name: "handleOperatorNE bool true",
+			filterField: FilterField{
+				Name:      "my_field",
+				boolValue: &boolTrue,
+				valueKind: reflect.Bool,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field != true ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorNE bool false",
+			filterField: FilterField{
+				Name:      "my_field",
+				boolValue: &boolFalse,
+				valueKind: reflect.Bool,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field != false ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorNE int64",
+			filterField: FilterField{
+				Name:      "my_field",
+				intValue:  &int64Value,
+				valueKind: reflect.Int64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field != -123456 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorNE uint64",
+			filterField: FilterField{
+				Name:      "my_field",
+				uintValue: &uint64Value,
+				valueKind: reflect.Uint64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field != 123456 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorNE float",
+			filterField: FilterField{
+				Name:       "my_field",
+				floatValue: &floatValue,
+				valueKind:  reflect.Float64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field != -123456.789 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorNE string",
+			filterField: FilterField{
+				Name:      "my_field",
+				strValue:  &strValue,
+				valueKind: reflect.String,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field != 'Some Value' ORDER BY `my_models`.`id` LIMIT 1",
+		},
+	}
+
+	for _, testCase := range testCases {
+		t.Run(testCase.name, func(t *testing.T) {
+			sql := db.ToSQL(func(tx *gorm.DB) *gorm.DB {
+				query := tx.Model(&MyModel{})
+				query = testFunc(query, "my_table", &testCase.filterField)
+				return query.First(&MyModel{})
+			})
+			assert.Equal(t, testCase.expected, sql)
+		})
+	}
+}
+
+func TestHandleOperatorLIKE(t *testing.T) {
+	db, _ := NewMockDB()
+	testFunc := handleOperatorLIKE
+
+	testCases := []TestCase{
+		{
+			name: "handleOperatorLIKE",
+			filterField: FilterField{
+				Name:      "my_field",
+				strValue:  &strValue,
+				valueKind: reflect.String,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field LIKE '%Some Value%' ORDER BY `my_models`.`id` LIMIT 1",
+		},
+	}
+
+	for _, testCase := range testCases {
+		t.Run(testCase.name, func(t *testing.T) {
+			sql := db.ToSQL(func(tx *gorm.DB) *gorm.DB {
+				query := tx.Model(&MyModel{})
+				query = testFunc(query, "my_table", &testCase.filterField)
+				return query.First(&MyModel{})
+			})
+			assert.Equal(t, testCase.expected, sql)
+		})
+	}
+}
+
+func TestHandleOperatorILIKE(t *testing.T) {
+	db, _ := NewMockDB()
+	testFunc := handleOperatorILIKE
+
+	testCases := []TestCase{
+		{
+			name: "handleOperatorILIKE",
+			filterField: FilterField{
+				Name:      "my_field",
+				strValue:  &strValue,
+				valueKind: reflect.String,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field ILIKE '%Some Value%' ORDER BY `my_models`.`id` LIMIT 1",
+		},
+	}
+
+	for _, testCase := range testCases {
+		t.Run(testCase.name, func(t *testing.T) {
+			sql := db.ToSQL(func(tx *gorm.DB) *gorm.DB {
+				query := tx.Model(&MyModel{})
+				query = testFunc(query, "my_table", &testCase.filterField)
+				return query.First(&MyModel{})
+			})
+			assert.Equal(t, testCase.expected, sql)
+		})
+	}
+}
+
+func TestHandleOperatorGT(t *testing.T) {
+	db, _ := NewMockDB()
+	testFunc := handleOperatorGT
+
+	testCases := []TestCase{
+		{
+			name: "handleOperatorGT int64",
+			filterField: FilterField{
+				Name:      "my_field",
+				intValue:  &int64Value,
+				valueKind: reflect.Int64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field > -123456 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorGT uint64",
+			filterField: FilterField{
+				Name:      "my_field",
+				uintValue: &uint64Value,
+				valueKind: reflect.Uint64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field > 123456 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorGT float",
+			filterField: FilterField{
+				Name:       "my_field",
+				floatValue: &floatValue,
+				valueKind:  reflect.Float64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field > -123456.789 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorGT string",
+			filterField: FilterField{
+				Name:      "my_field",
+				strValue:  &strValue,
+				valueKind: reflect.String,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field > 'Some Value' ORDER BY `my_models`.`id` LIMIT 1",
+		},
+	}
+
+	for _, testCase := range testCases {
+		t.Run(testCase.name, func(t *testing.T) {
+			sql := db.ToSQL(func(tx *gorm.DB) *gorm.DB {
+				query := tx.Model(&MyModel{})
+				query = testFunc(query, "my_table", &testCase.filterField)
+				return query.First(&MyModel{})
+			})
+			assert.Equal(t, testCase.expected, sql)
+		})
+	}
+}
+
+func TestHandleOperatorGE(t *testing.T) {
+	db, _ := NewMockDB()
+	testFunc := handleOperatorGE
+
+	testCases := []TestCase{
+		{
+			name: "handleOperatorGE int64",
+			filterField: FilterField{
+				Name:      "my_field",
+				intValue:  &int64Value,
+				valueKind: reflect.Int64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field >= -123456 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorGE uint64",
+			filterField: FilterField{
+				Name:      "my_field",
+				uintValue: &uint64Value,
+				valueKind: reflect.Uint64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field >= 123456 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorGE float",
+			filterField: FilterField{
+				Name:       "my_field",
+				floatValue: &floatValue,
+				valueKind:  reflect.Float64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field >= -123456.789 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorGE string",
+			filterField: FilterField{
+				Name:      "my_field",
+				strValue:  &strValue,
+				valueKind: reflect.String,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field >= 'Some Value' ORDER BY `my_models`.`id` LIMIT 1",
+		},
+	}
+
+	for _, testCase := range testCases {
+		t.Run(testCase.name, func(t *testing.T) {
+			sql := db.ToSQL(func(tx *gorm.DB) *gorm.DB {
+				query := tx.Model(&MyModel{})
+				query = testFunc(query, "my_table", &testCase.filterField)
+				return query.First(&MyModel{})
+			})
+			assert.Equal(t, testCase.expected, sql)
+		})
+	}
+}
+
+func TestHandleOperatorLT(t *testing.T) {
+	db, _ := NewMockDB()
+	testFunc := handleOperatorLT
+
+	testCases := []TestCase{
+		{
+			name: "handleOperatorLT int64",
+			filterField: FilterField{
+				Name:      "my_field",
+				intValue:  &int64Value,
+				valueKind: reflect.Int64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field < -123456 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorLT uint64",
+			filterField: FilterField{
+				Name:      "my_field",
+				uintValue: &uint64Value,
+				valueKind: reflect.Uint64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field < 123456 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorLT float",
+			filterField: FilterField{
+				Name:       "my_field",
+				floatValue: &floatValue,
+				valueKind:  reflect.Float64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field < -123456.789 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorLT string",
+			filterField: FilterField{
+				Name:      "my_field",
+				strValue:  &strValue,
+				valueKind: reflect.String,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field < 'Some Value' ORDER BY `my_models`.`id` LIMIT 1",
+		},
+	}
+
+	for _, testCase := range testCases {
+		t.Run(testCase.name, func(t *testing.T) {
+			sql := db.ToSQL(func(tx *gorm.DB) *gorm.DB {
+				query := tx.Model(&MyModel{})
+				query = testFunc(query, "my_table", &testCase.filterField)
+				return query.First(&MyModel{})
+			})
+			assert.Equal(t, testCase.expected, sql)
+		})
+	}
+}
+
+func TestHandleOperatorLE(t *testing.T) {
+	db, _ := NewMockDB()
+	testFunc := handleOperatorLE
+
+	testCases := []TestCase{
+		{
+			name: "handleOperatorLE int64",
+			filterField: FilterField{
+				Name:      "my_field",
+				intValue:  &int64Value,
+				valueKind: reflect.Int64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field <= -123456 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorLE uint64",
+			filterField: FilterField{
+				Name:      "my_field",
+				uintValue: &uint64Value,
+				valueKind: reflect.Uint64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field <= 123456 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorLE float",
+			filterField: FilterField{
+				Name:       "my_field",
+				floatValue: &floatValue,
+				valueKind:  reflect.Float64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field <= -123456.789 ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorLE string",
+			filterField: FilterField{
+				Name:      "my_field",
+				strValue:  &strValue,
+				valueKind: reflect.String,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field <= 'Some Value' ORDER BY `my_models`.`id` LIMIT 1",
+		},
+	}
+
+	for _, testCase := range testCases {
+		t.Run(testCase.name, func(t *testing.T) {
+			sql := db.ToSQL(func(tx *gorm.DB) *gorm.DB {
+				query := tx.Model(&MyModel{})
+				query = testFunc(query, "my_table", &testCase.filterField)
+				return query.First(&MyModel{})
+			})
+			assert.Equal(t, testCase.expected, sql)
+		})
+	}
+}
+
+func TestHandleOperatorIN(t *testing.T) {
+	db, _ := NewMockDB()
+	testFunc := handleOperatorIN
+
+	testCases := []TestCase{
+		{
+			name: "handleOperatorIN bool",
+			filterField: FilterField{
+				Name:       "my_field",
+				boolValues: &boolValues,
+				valueKind:  reflect.Bool,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field IN (true,false) ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorIN int64",
+			filterField: FilterField{
+				Name:      "my_field",
+				intValues: &int64Values,
+				valueKind: reflect.Int64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field IN (-123456,1,123456) ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorIN uint64",
+			filterField: FilterField{
+				Name:       "my_field",
+				uintValues: &uint64Values,
+				valueKind:  reflect.Uint64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field IN (123456,1234567,1234568) ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorIN float",
+			filterField: FilterField{
+				Name:        "my_field",
+				floatValues: &floatValues,
+				valueKind:   reflect.Float64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field IN (-123456.789,-1,123456.789) ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorIN string",
+			filterField: FilterField{
+				Name:      "my_field",
+				strValues: &strValues,
+				valueKind: reflect.String,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field IN ('First Value','Second Value','Third Value') ORDER BY `my_models`.`id` LIMIT 1",
+		},
+	}
+
+	for _, testCase := range testCases {
+		t.Run(testCase.name, func(t *testing.T) {
+			sql := db.ToSQL(func(tx *gorm.DB) *gorm.DB {
+				query := tx.Model(&MyModel{})
+				query = testFunc(query, "my_table", &testCase.filterField)
+				return query.First(&MyModel{})
+			})
+			assert.Equal(t, testCase.expected, sql)
+		})
+	}
+}
+
+func TestHandleOperatorNOT_IN(t *testing.T) {
+	db, _ := NewMockDB()
+	testFunc := handleOperatorNOT_IN
+
+	testCases := []TestCase{
+		{
+			name: "handleOperatorNOT_IN bool",
+			filterField: FilterField{
+				Name:       "my_field",
+				boolValues: &boolValues,
+				valueKind:  reflect.Bool,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field NOT IN (true,false) ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorNOT_IN int64",
+			filterField: FilterField{
+				Name:      "my_field",
+				intValues: &int64Values,
+				valueKind: reflect.Int64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field NOT IN (-123456,1,123456) ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorNOT_IN uint64",
+			filterField: FilterField{
+				Name:       "my_field",
+				uintValues: &uint64Values,
+				valueKind:  reflect.Uint64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field NOT IN (123456,1234567,1234568) ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorNOT_IN float",
+			filterField: FilterField{
+				Name:        "my_field",
+				floatValues: &floatValues,
+				valueKind:   reflect.Float64,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field NOT IN (-123456.789,-1,123456.789) ORDER BY `my_models`.`id` LIMIT 1",
+		},
+		{
+			name: "handleOperatorNOT_IN string",
+			filterField: FilterField{
+				Name:      "my_field",
+				strValues: &strValues,
+				valueKind: reflect.String,
+			},
+			expected: "SELECT * FROM `my_models` WHERE my_table.my_field NOT IN ('First Value','Second Value','Third Value') ORDER BY `my_models`.`id` LIMIT 1",
+		},
+	}
+
+	for _, testCase := range testCases {
+		t.Run(testCase.name, func(t *testing.T) {
+			sql := db.ToSQL(func(tx *gorm.DB) *gorm.DB {
+				query := tx.Model(&MyModel{})
+				query = testFunc(query, "my_table", &testCase.filterField)
+				return query.First(&MyModel{})
+			})
+			assert.Equal(t, testCase.expected, sql)
+		})
+	}
+}

app/repository/smartfilter/operators.go

@@ -12,11 +12,12 @@ const (
 	OperatorLIKE   Operator = "LIKE"
 	OperatorILIKE  Operator = "ILIKE"
 	OperatorIN     Operator = "IN"
+	OperatorNOT_IN Operator = "NOT_IN"
 )
 
 var OPERATORS = []Operator{
 	OperatorEQ, OperatorNE,
 	OperatorGT, OperatorGE, OperatorLT, OperatorLE,
 	OperatorLIKE, OperatorILIKE,
-	OperatorIN,
+	OperatorIN, OperatorNOT_IN,
 }

app/repository/smartfilter/smartfilter.go

@@ -25,28 +25,32 @@ var operatorHandlers = map[Operator]handlerFunc{
 	OperatorLE:     handleOperatorLE,
 	OperatorLIKE:   handleOperatorLIKE,
 	OperatorILIKE:  handleOperatorILIKE,
+	OperatorIN:     handleOperatorIN,
+	OperatorNOT_IN: handleOperatorNOT_IN,
 }
 
-type SmartCertFilter[T schema.Tabler] struct {
-	Model                T
+type CertFilter struct {
 	Alive                *bool      `filterfield:"alive,EQ"`
 	SerialNumber         *string    `filterfield:"serial_number,NE"`
 	SerialNumberContains *string    `filterfield:"serial_number,LIKE"`
 	IssuerContains       *string    `filterfield:"issuer,ILIKE"`
 	Id                   *string    `filterfield:"id,EQ"`
 	Ids                  *[]string  `filterfield:"id,IN"`
+	IdsNot               *[]string  `filterfield:"id,NOT_IN"`
 	CreatedAt_Lt         *time.Time `filterfield:"created_at,LT"`
 }
 
-func (f SmartCertFilter[T]) ToQuery(query *gorm.DB) (*gorm.DB, error) {
-	tableName := f.Model.TableName()
+type ReflectedStructField struct {
+	name     string
+	value    reflect.Value
+	tagValue string
+}
 
-	fmt.Printf("Table name: %s\n", tableName)
-	// fmt.Printf("%+v\n", f)
+func getFilterFields(filter interface{}) []ReflectedStructField {
+	res := make([]ReflectedStructField, 0)
 
-	st := reflect.TypeOf(f)
-	modelName := st.Name()
-	reflectValue := reflect.ValueOf(f)
+	st := reflect.TypeOf(filter)
+	reflectValue := reflect.ValueOf(filter)
 
 	for i := 0; i < st.NumField(); i++ {
 		field := st.Field(i)
@@ -57,23 +61,43 @@ func (f SmartCertFilter[T]) ToQuery(query *gorm.DB) (*gorm.DB, error) {
 			continue
 		}
 
-		fieldReflect := reflectValue.FieldByName(field.Name)
+		// get field value
+		fieldValue := reflectValue.FieldByName(field.Name)
 
 		// skip field if value is nil
-		if fieldReflect.IsNil() {
+		if fieldValue.IsNil() {
 			continue
 		}
 
-		t := fieldReflect.Type()
-		fmt.Printf(">>> %+v    --- %+v\n", field, t)
+		res = append(res, ReflectedStructField{
+			name:     field.Name,
+			tagValue: tagValue,
+			value:    fieldValue,
+		})
+	}
+	fmt.Println("-------------- RES --------------")
+	fmt.Printf("%+v\n", res)
+	return res
+}
 
-		filterField, err := newFilterField(tagValue)
+func ToQuery(model schema.Tabler, filter interface{}, query *gorm.DB) (*gorm.DB, error) {
+	st := reflect.TypeOf(filter)
+
+	tableName := model.TableName()
+	modelName := st.Name()
+
+	fmt.Printf("Table name: %s\n", tableName)
+	fmt.Printf("Model name: %s\n", modelName)
+
+	fields := getFilterFields(filter)
+	for _, field := range fields {
+		filterField, err := newFilterField(field.tagValue)
 		if err != nil {
-			return nil, fmt.Errorf("%s.%s: %s", modelName, field.Name, err)
+			return nil, fmt.Errorf("%s.%s: %s", modelName, field.name, err)
 		}
 
 		// must be called!
-		filterField.setValueFromReflection(fieldReflect)
+		filterField.setValueFromReflection(field.value)
 
 		operatorHandler, ok := operatorHandlers[filterField.Operator]
 		if !ok {
@@ -106,107 +130,3 @@ func newFilterField(tagValue string) (*FilterField, error) {
 	}
 	return &f, nil
 }
-
-func handleOperatorEQ(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
-	switch filterField.valueKind {
-	case reflect.Bool:
-		return applyFilterEQ(query, tableName, filterField, *filterField.boolValue)
-	case reflect.Int, reflect.Int16, reflect.Int32, reflect.Int64:
-		return applyFilterEQ(query, tableName, filterField, *filterField.intValue)
-	case reflect.Uint, reflect.Uint16, reflect.Uint32, reflect.Uint64:
-		return applyFilterEQ(query, tableName, filterField, *filterField.uintValue)
-	case reflect.Float32, reflect.Float64:
-		return applyFilterEQ(query, tableName, filterField, *filterField.floatValue)
-	case reflect.String:
-		return applyFilterEQ(query, tableName, filterField, *filterField.strValue)
-	}
-	return nil
-}
-
-func handleOperatorNE(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
-	switch filterField.valueKind {
-	case reflect.Bool:
-		return applyFilterNE(query, tableName, filterField, *filterField.boolValue)
-	case reflect.Int, reflect.Int16, reflect.Int32, reflect.Int64:
-		return applyFilterNE(query, tableName, filterField, *filterField.intValue)
-	case reflect.Uint, reflect.Uint16, reflect.Uint32, reflect.Uint64:
-		return applyFilterNE(query, tableName, filterField, *filterField.uintValue)
-	case reflect.Float32, reflect.Float64:
-		return applyFilterNE(query, tableName, filterField, *filterField.floatValue)
-	case reflect.String:
-		return applyFilterNE(query, tableName, filterField, *filterField.strValue)
-	}
-	return nil
-}
-
-func handleOperatorLIKE(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
-	switch filterField.valueKind {
-	case reflect.String:
-		return applyFilterLIKE(query, tableName, filterField, *filterField.strValue)
-	}
-	return nil
-}
-
-func handleOperatorILIKE(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
-	switch filterField.valueKind {
-	case reflect.String:
-		return applyFilterILIKE(query, tableName, filterField, *filterField.strValue)
-	}
-	return nil
-}
-
-func handleOperatorGT(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
-	switch filterField.valueKind {
-	case reflect.Int, reflect.Int16, reflect.Int32, reflect.Int64:
-		return applyFilterGT(query, tableName, filterField, *filterField.intValue)
-	case reflect.Uint, reflect.Uint16, reflect.Uint32, reflect.Uint64:
-		return applyFilterGT(query, tableName, filterField, *filterField.uintValue)
-	case reflect.Float32, reflect.Float64:
-		return applyFilterGT(query, tableName, filterField, *filterField.floatValue)
-	case reflect.String:
-		return applyFilterGT(query, tableName, filterField, *filterField.strValue)
-	}
-	return nil
-}
-
-func handleOperatorGE(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
-	switch filterField.valueKind {
-	case reflect.Int, reflect.Int16, reflect.Int32, reflect.Int64:
-		return applyFilterGE(query, tableName, filterField, *filterField.intValue)
-	case reflect.Uint, reflect.Uint16, reflect.Uint32, reflect.Uint64:
-		return applyFilterGE(query, tableName, filterField, *filterField.uintValue)
-	case reflect.Float32, reflect.Float64:
-		return applyFilterGE(query, tableName, filterField, *filterField.floatValue)
-	case reflect.String:
-		return applyFilterGE(query, tableName, filterField, *filterField.strValue)
-	}
-	return nil
-}
-
-func handleOperatorLT(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
-	switch filterField.valueKind {
-	case reflect.Int, reflect.Int16, reflect.Int32, reflect.Int64:
-		return applyFilterLT(query, tableName, filterField, *filterField.intValue)
-	case reflect.Uint, reflect.Uint16, reflect.Uint32, reflect.Uint64:
-		return applyFilterLT(query, tableName, filterField, *filterField.uintValue)
-	case reflect.Float32, reflect.Float64:
-		return applyFilterLT(query, tableName, filterField, *filterField.floatValue)
-	case reflect.String:
-		return applyFilterLT(query, tableName, filterField, *filterField.strValue)
-	}
-	return nil
-}
-
-func handleOperatorLE(query *gorm.DB, tableName string, filterField *FilterField) *gorm.DB {
-	switch filterField.valueKind {
-	case reflect.Int, reflect.Int16, reflect.Int32, reflect.Int64:
-		return applyFilterLE(query, tableName, filterField, *filterField.intValue)
-	case reflect.Uint, reflect.Uint16, reflect.Uint32, reflect.Uint64:
-		return applyFilterLE(query, tableName, filterField, *filterField.uintValue)
-	case reflect.Float32, reflect.Float64:
-		return applyFilterLE(query, tableName, filterField, *filterField.floatValue)
-	case reflect.String:
-		return applyFilterLE(query, tableName, filterField, *filterField.strValue)
-	}
-	return nil
-}

go.mod

@@ -6,7 +6,7 @@ require (
 	github.com/google/uuid v1.6.0
 	github.com/kelseyhightower/envconfig v1.4.0
 	github.com/mozillazg/go-slugify v0.2.0
-	github.com/stretchr/testify v1.8.1
+	github.com/stretchr/testify v1.9.0
 	go.uber.org/zap v1.27.0
 	gopkg.in/yaml.v3 v3.0.1
 	gorm.io/datatypes v1.2.1
@@ -16,7 +16,9 @@ require (
 
 require (
 	filippo.io/edwards25519 v1.1.0 // indirect
+	github.com/DATA-DOG/go-sqlmock v1.5.2 // indirect
 	github.com/davecgh/go-spew v1.1.1 // indirect
+	github.com/go-playground/assert v1.2.1 // indirect
 	github.com/go-sql-driver/mysql v1.8.1 // indirect
 	github.com/jackc/pgpassfile v1.0.0 // indirect
 	github.com/jackc/pgservicefile v0.0.0-20231201235250-de7065d80cb9 // indirect

go.sum

@@ -1,8 +1,12 @@
 filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA=
 filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4=
+github.com/DATA-DOG/go-sqlmock v1.5.2 h1:OcvFkGmslmlZibjAjaHm3L//6LiuBgolP7OputlJIzU=
+github.com/DATA-DOG/go-sqlmock v1.5.2/go.mod h1:88MAG/4G7SMwSE3CeA0ZKzrT5CiOU3OJ+JlNzwDqpNU=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/go-playground/assert v1.2.1 h1:ad06XqC+TOv0nJWnbULSlh3ehp5uLuQEojZY5Tq8RgI=
+github.com/go-playground/assert v1.2.1/go.mod h1:Lgy+k19nOB/wQG/fVSQ7rra5qYugmytMQqvQ2dgjWn8=
 github.com/go-sql-driver/mysql v1.7.0/go.mod h1:OXbVy3sEdcQ2Doequ6Z5BW6fXNQTmx+9S1MCJN5yJMI=
 github.com/go-sql-driver/mysql v1.8.1 h1:LedoTUt/eveggdHS9qUFC1EFSa8bU2+1pZjSRpvNJ1Y=
 github.com/go-sql-driver/mysql v1.8.1/go.mod h1:wEBSXgmK//2ZFJyE+qWnIsVGmvmEKlqwuVSjsCm7DZg=
@@ -26,6 +30,7 @@ github.com/jinzhu/now v1.1.5 h1:/o9tlHleP7gOFmsnYNz3RGnqzefHA47wQpKrrdTIwXQ=
 github.com/jinzhu/now v1.1.5/go.mod h1:d3SSVoowX0Lcu0IBviAWJpolVfI5UJVZZ7cO71lE/z8=
 github.com/kelseyhightower/envconfig v1.4.0 h1:Im6hONhd3pLkfDFsbRgu68RDNkGF1r3dvMUtDTo2cv8=
 github.com/kelseyhightower/envconfig v1.4.0/go.mod h1:cccZRl6mQpaq41TPp5QxidR+Sa3axMbJDNb//FQX6Gg=
+github.com/kisielk/sqlstruct v0.0.0-20201105191214-5f3e10d3ab46/go.mod h1:yyMNCyc/Ib3bDTKd379tNMpB/7/H5TjM2Y9QJ5THLbE=
 github.com/kr/pretty v0.3.0 h1:WgNl7dwNpEZ6jJ9k1snq4pZsg7DOEN8hP9Xw0Tsjwk0=
 github.com/kr/pretty v0.3.0/go.mod h1:640gp4NfQd8pI5XOwp5fnNeVWj67G7CFk/SaSQn7NBk=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
@@ -51,6 +56,8 @@ github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/
 github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
 github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk=
 github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
+github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
+github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
 go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
 go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
 go.uber.org/multierr v1.10.0 h1:S0h4aNzvfcFsC3dRF1jLoaov7oRaKqRGC/pUEJ2yvPQ=