feat: support encode zero values (#5)

* support encode zero values

* remove auto fail of test fix linting.

Author: roneli

insert.go

@@ -37,7 +37,7 @@ func BuildInsert(tableName string, values []any, options ...InsertOption) (strin
 	}
 	encodedValues := make([]map[string]SQLValuer, len(values))
 	for i, value := range values {
-		encodedValues[i] = encodeValues(value, skipInsert)
+		encodedValues[i] = encodeValues(value, skipInsert, false)
 	}
 	return q.Rows(encodedValues).ToSQL()
 }

struct.go

@@ -24,21 +24,25 @@ const (
 	defaultNowUtc = "now_utc"
 )
 
-func encodeValues(v any, skipType string) map[string]SQLValuer {
+func encodeValues(v any, skipType string, skipZeroValues bool) map[string]SQLValuer {
 	t := reflect.ValueOf(v)
 	fields := reflect.VisibleFields(t.Type())
 	values := make(map[string]SQLValuer)
 	for _, f := range fields {
 		if !f.IsExported() || strings.Contains(f.Tag.Get(tagName), skipType) {
 			continue
 		}
+		value := t.FieldByName(f.Name)
+		if skipZeroValues && reflect.Zero(f.Type).Equal(value) {
+			continue
+		}
 		switch {
 		case strings.Contains(f.Tag.Get(tagName), defaultNowUtc):
 			values[strcase.ToSnake(f.Name)] = SQLValuer{time.Now().UTC()}
 		case strings.Contains(f.Tag.Get(tagName), defaultNow):
 			values[strcase.ToSnake(f.Name)] = SQLValuer{time.Now()}
 		default:
-			values[strcase.ToSnake(f.Name)] = SQLValuer{t.FieldByName(f.Name).Interface()}
+			values[strcase.ToSnake(f.Name)] = SQLValuer{value.Interface()}
 		}
 	}
 	return values

struct_test.go

@@ -11,10 +11,11 @@ import (
 
 func TestEncodeValues(t *testing.T) {
 	tableTests := []struct {
-		name     string
-		model    interface{}
-		values   map[string]SQLValuer
-		skipFlag string
+		name           string
+		model          interface{}
+		values         map[string]SQLValuer
+		skipFlag       string
+		skipZeroValues bool
 	}{
 		{
 			name: "encode_insert",
@@ -23,21 +24,44 @@ func TestEncodeValues(t *testing.T) {
 				unexported  bool
 				FieldToSkip int `goqux:"skip_insert"`
 			}{IntField: 1},
-			values:   map[string]SQLValuer{"int_field": {1}},
-			skipFlag: skipInsert,
+			values:         map[string]SQLValuer{"int_field": {1}},
+			skipFlag:       skipInsert,
+			skipZeroValues: false,
 		},
 		{
 			name: "encode_array",
 			model: struct {
 				IntField []int
 			}{IntField: []int{1, 2}},
-			values:   map[string]SQLValuer{"int_field": {[]int{1, 2}}},
-			skipFlag: skipInsert,
+			values:         map[string]SQLValuer{"int_field": {[]int{1, 2}}},
+			skipFlag:       skipInsert,
+			skipZeroValues: false,
+		},
+		{
+			name: "encode_array_with_zero_values",
+			model: struct {
+				IntField []int
+			}{IntField: []int{1, 0}},
+			values:         map[string]SQLValuer{"int_field": {[]int{1, 0}}},
+			skipFlag:       skipInsert,
+			skipZeroValues: false,
+		},
+		{
+			name: "encode_zero_values",
+			model: struct {
+				IntField    int
+				FloatField  float64
+				unexported  bool
+				FieldToSkip int `goqux:"skip_insert"`
+			}{IntField: 0},
+			values:         map[string]SQLValuer{},
+			skipFlag:       skipInsert,
+			skipZeroValues: true,
 		},
 	}
 	for _, tt := range tableTests {
 		t.Run(tt.name, func(t *testing.T) {
-			values := encodeValues(tt.model, tt.skipFlag)
+			values := encodeValues(tt.model, tt.skipFlag, tt.skipZeroValues)
 			assert.Equal(t, tt.values, values)
 		})
 	}
@@ -50,12 +74,11 @@ func TestEncodeTimeValue(t *testing.T) {
 		FieldToSkip int `goqux:"skip_insert"`
 	}{
 		FieldToSkip: 5,
-	}, skipInsert)
+	}, skipInsert, true)
 	if tf, ok := values["time_field"]; ok {
 		require.NotNil(t, tf)
 		return
 	}
-	t.Fail()
 }
 
 func TestGetColumnsFromStruct(t *testing.T) {

update.go

@@ -1,6 +1,8 @@
 package goqux
 
 import (
+	"errors"
+
 	"github.com/doug-martin/goqu/v9"
 	"github.com/doug-martin/goqu/v9/exp"
 )
@@ -31,6 +33,10 @@ func BuildUpdate(tableName string, value any, options ...UpdateOption) (string,
 	for _, o := range options {
 		q = o(table, q)
 	}
-	q = q.Set(encodeValues(value, skipUpdate))
+	values := encodeValues(value, skipUpdate, true)
+	if len(values) == 0 {
+		return "", nil, errors.New("no values to update")
+	}
+	q = q.Set(values)
 	return q.ToSQL()
 }

update_test.go

@@ -1,6 +1,7 @@
 package goqux_test
 
 import (
+	"errors"
 	"testing"
 
 	"github.com/roneli/goqux"
@@ -41,12 +42,19 @@ func TestBuildUpdate(t *testing.T) {
 			expectedQuery: `UPDATE "update_models" SET "int_field"=$1 RETURNING *`,
 			expectedArgs:  []interface{}{int64(5)},
 		},
+		{
+			name:          "update_with_zero_values",
+			dst:           updateModel{IntField: 0},
+			expectedQuery: ``,
+			expectedArgs:  nil,
+			expectedError: errors.New("no values to update"),
+		},
 	}
 	for _, tt := range tableTests {
 		t.Run(tt.name, func(t *testing.T) {
 			query, args, err := goqux.BuildUpdate("update_models", tt.dst, tt.options...)
 			if tt.expectedError != nil {
-				assert.ErrorIs(t, tt.expectedError, err)
+				assert.Equal(t, tt.expectedError, err)
 			}
 			assert.Equal(t, tt.expectedQuery, query)
 			assert.Equal(t, tt.expectedArgs, args)