2020-01-31 07:22:37 +03:00
|
|
|
package schema
|
|
|
|
|
|
|
|
import (
|
2020-02-15 11:04:21 +03:00
|
|
|
"database/sql"
|
2020-01-31 07:22:37 +03:00
|
|
|
"database/sql/driver"
|
2020-02-15 11:04:21 +03:00
|
|
|
"fmt"
|
2020-01-31 07:22:37 +03:00
|
|
|
"reflect"
|
|
|
|
"strconv"
|
2020-02-18 17:56:37 +03:00
|
|
|
"strings"
|
2020-01-31 07:22:37 +03:00
|
|
|
"sync"
|
|
|
|
"time"
|
2020-02-15 11:04:21 +03:00
|
|
|
|
2020-06-02 04:25:55 +03:00
|
|
|
"github.com/jinzhu/now"
|
2020-06-02 04:16:07 +03:00
|
|
|
"gorm.io/gorm/utils"
|
2020-01-31 07:22:37 +03:00
|
|
|
)
|
|
|
|
|
2020-02-01 07:46:52 +03:00
|
|
|
type DataType string
|
2020-01-31 07:22:37 +03:00
|
|
|
|
2020-02-18 17:56:37 +03:00
|
|
|
type TimeType int64
|
|
|
|
|
2020-09-24 15:08:24 +03:00
|
|
|
var TimeReflectType = reflect.TypeOf(time.Time{})
|
|
|
|
|
2020-02-18 17:56:37 +03:00
|
|
|
const (
|
2020-07-30 12:39:57 +03:00
|
|
|
UnixSecond TimeType = 1
|
|
|
|
UnixMillisecond TimeType = 2
|
|
|
|
UnixNanosecond TimeType = 3
|
2020-02-18 17:56:37 +03:00
|
|
|
)
|
|
|
|
|
2020-01-31 07:22:37 +03:00
|
|
|
const (
|
2020-02-01 07:46:52 +03:00
|
|
|
Bool DataType = "bool"
|
2020-07-16 06:27:04 +03:00
|
|
|
Int DataType = "int"
|
|
|
|
Uint DataType = "uint"
|
|
|
|
Float DataType = "float"
|
|
|
|
String DataType = "string"
|
|
|
|
Time DataType = "time"
|
|
|
|
Bytes DataType = "bytes"
|
2020-01-31 07:22:37 +03:00
|
|
|
)
|
|
|
|
|
|
|
|
type Field struct {
|
2020-02-18 17:56:37 +03:00
|
|
|
Name string
|
|
|
|
DBName string
|
|
|
|
BindNames []string
|
|
|
|
DataType DataType
|
2020-07-20 13:59:28 +03:00
|
|
|
GORMDataType DataType
|
2020-02-18 17:56:37 +03:00
|
|
|
PrimaryKey bool
|
|
|
|
AutoIncrement bool
|
|
|
|
Creatable bool
|
|
|
|
Updatable bool
|
2020-04-08 03:15:00 +03:00
|
|
|
Readable bool
|
2020-02-18 17:56:37 +03:00
|
|
|
HasDefaultValue bool
|
|
|
|
AutoCreateTime TimeType
|
|
|
|
AutoUpdateTime TimeType
|
|
|
|
DefaultValue string
|
|
|
|
DefaultValueInterface interface{}
|
|
|
|
NotNull bool
|
|
|
|
Unique bool
|
|
|
|
Comment string
|
|
|
|
Size int
|
|
|
|
Precision int
|
2020-08-23 10:40:19 +03:00
|
|
|
Scale int
|
2020-02-18 17:56:37 +03:00
|
|
|
FieldType reflect.Type
|
|
|
|
IndirectFieldType reflect.Type
|
|
|
|
StructField reflect.StructField
|
|
|
|
Tag reflect.StructTag
|
|
|
|
TagSettings map[string]string
|
|
|
|
Schema *Schema
|
|
|
|
EmbeddedSchema *Schema
|
2020-08-04 07:10:19 +03:00
|
|
|
OwnerSchema *Schema
|
2020-02-18 17:56:37 +03:00
|
|
|
ReflectValueOf func(reflect.Value) reflect.Value
|
|
|
|
ValueOf func(reflect.Value) (value interface{}, zero bool)
|
|
|
|
Set func(reflect.Value, interface{}) error
|
2020-01-31 07:22:37 +03:00
|
|
|
}
|
|
|
|
|
|
|
|
func (schema *Schema) ParseField(fieldStruct reflect.StructField) *Field {
|
2020-09-03 13:20:57 +03:00
|
|
|
var err error
|
|
|
|
|
2020-01-31 07:22:37 +03:00
|
|
|
field := &Field{
|
2020-02-15 14:45:27 +03:00
|
|
|
Name: fieldStruct.Name,
|
|
|
|
BindNames: []string{fieldStruct.Name},
|
|
|
|
FieldType: fieldStruct.Type,
|
|
|
|
IndirectFieldType: fieldStruct.Type,
|
|
|
|
StructField: fieldStruct,
|
|
|
|
Creatable: true,
|
|
|
|
Updatable: true,
|
2020-04-08 03:15:00 +03:00
|
|
|
Readable: true,
|
2020-02-15 14:45:27 +03:00
|
|
|
Tag: fieldStruct.Tag,
|
2020-02-21 19:02:05 +03:00
|
|
|
TagSettings: ParseTagSetting(fieldStruct.Tag.Get("gorm"), ";"),
|
2020-02-15 14:45:27 +03:00
|
|
|
Schema: schema,
|
2020-01-31 07:22:37 +03:00
|
|
|
}
|
|
|
|
|
2020-02-15 14:45:27 +03:00
|
|
|
for field.IndirectFieldType.Kind() == reflect.Ptr {
|
|
|
|
field.IndirectFieldType = field.IndirectFieldType.Elem()
|
2020-01-31 07:22:37 +03:00
|
|
|
}
|
|
|
|
|
2020-02-15 14:45:27 +03:00
|
|
|
fieldValue := reflect.New(field.IndirectFieldType)
|
2020-01-31 07:22:37 +03:00
|
|
|
// if field is valuer, used its value or first fields as data type
|
2020-06-18 04:15:23 +03:00
|
|
|
valuer, isValuer := fieldValue.Interface().(driver.Valuer)
|
|
|
|
if isValuer {
|
2020-07-17 07:02:00 +03:00
|
|
|
if _, ok := fieldValue.Interface().(GormDataTypeInterface); !ok {
|
2020-08-19 10:47:08 +03:00
|
|
|
if v, err := valuer.Value(); reflect.ValueOf(v).IsValid() && err == nil {
|
2020-07-17 07:02:00 +03:00
|
|
|
fieldValue = reflect.ValueOf(v)
|
|
|
|
}
|
2020-01-31 07:22:37 +03:00
|
|
|
|
2020-08-19 10:47:08 +03:00
|
|
|
var getRealFieldValue func(reflect.Value)
|
|
|
|
getRealFieldValue = func(v reflect.Value) {
|
|
|
|
rv := reflect.Indirect(v)
|
2020-09-24 15:08:24 +03:00
|
|
|
if rv.Kind() == reflect.Struct && !rv.Type().ConvertibleTo(TimeReflectType) {
|
2020-08-19 10:47:08 +03:00
|
|
|
for i := 0; i < rv.Type().NumField(); i++ {
|
|
|
|
newFieldType := rv.Type().Field(i).Type
|
2020-07-17 07:02:00 +03:00
|
|
|
for newFieldType.Kind() == reflect.Ptr {
|
|
|
|
newFieldType = newFieldType.Elem()
|
|
|
|
}
|
2020-01-31 07:22:37 +03:00
|
|
|
|
2020-07-17 07:02:00 +03:00
|
|
|
fieldValue = reflect.New(newFieldType)
|
2020-01-31 07:22:37 +03:00
|
|
|
|
2020-08-19 10:47:08 +03:00
|
|
|
if rv.Type() != reflect.Indirect(fieldValue).Type() {
|
|
|
|
getRealFieldValue(fieldValue)
|
|
|
|
}
|
|
|
|
|
|
|
|
if fieldValue.IsValid() {
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
for key, value := range ParseTagSetting(field.IndirectFieldType.Field(i).Tag.Get("gorm"), ";") {
|
|
|
|
if _, ok := field.TagSettings[key]; !ok {
|
|
|
|
field.TagSettings[key] = value
|
|
|
|
}
|
2020-07-17 07:02:00 +03:00
|
|
|
}
|
2020-01-31 07:22:37 +03:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2020-08-19 10:47:08 +03:00
|
|
|
|
|
|
|
getRealFieldValue(fieldValue)
|
2020-01-31 07:22:37 +03:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if dbName, ok := field.TagSettings["COLUMN"]; ok {
|
|
|
|
field.DBName = dbName
|
|
|
|
}
|
|
|
|
|
2020-04-16 05:29:18 +03:00
|
|
|
if val, ok := field.TagSettings["PRIMARYKEY"]; ok && utils.CheckTruth(val) {
|
2020-01-31 07:22:37 +03:00
|
|
|
field.PrimaryKey = true
|
2020-04-16 05:29:18 +03:00
|
|
|
} else if val, ok := field.TagSettings["PRIMARY_KEY"]; ok && utils.CheckTruth(val) {
|
2020-04-12 08:16:15 +03:00
|
|
|
field.PrimaryKey = true
|
2020-01-31 07:22:37 +03:00
|
|
|
}
|
|
|
|
|
2020-04-16 05:29:18 +03:00
|
|
|
if val, ok := field.TagSettings["AUTOINCREMENT"]; ok && utils.CheckTruth(val) {
|
2020-01-31 07:22:37 +03:00
|
|
|
field.AutoIncrement = true
|
|
|
|
field.HasDefaultValue = true
|
|
|
|
}
|
|
|
|
|
|
|
|
if v, ok := field.TagSettings["DEFAULT"]; ok {
|
|
|
|
field.HasDefaultValue = true
|
|
|
|
field.DefaultValue = v
|
|
|
|
}
|
|
|
|
|
|
|
|
if num, ok := field.TagSettings["SIZE"]; ok {
|
2020-02-22 12:53:57 +03:00
|
|
|
if field.Size, err = strconv.Atoi(num); err != nil {
|
|
|
|
field.Size = -1
|
|
|
|
}
|
2020-01-31 07:22:37 +03:00
|
|
|
}
|
|
|
|
|
|
|
|
if p, ok := field.TagSettings["PRECISION"]; ok {
|
|
|
|
field.Precision, _ = strconv.Atoi(p)
|
|
|
|
}
|
|
|
|
|
2020-08-23 10:40:19 +03:00
|
|
|
if s, ok := field.TagSettings["SCALE"]; ok {
|
|
|
|
field.Scale, _ = strconv.Atoi(s)
|
|
|
|
}
|
|
|
|
|
2020-04-16 05:29:18 +03:00
|
|
|
if val, ok := field.TagSettings["NOT NULL"]; ok && utils.CheckTruth(val) {
|
2020-01-31 07:22:37 +03:00
|
|
|
field.NotNull = true
|
2020-10-09 12:39:35 +03:00
|
|
|
} else if val, ok := field.TagSettings["NOTNULL"]; ok && utils.CheckTruth(val) {
|
|
|
|
field.NotNull = true
|
2020-01-31 07:22:37 +03:00
|
|
|
}
|
|
|
|
|
2020-04-16 05:29:18 +03:00
|
|
|
if val, ok := field.TagSettings["UNIQUE"]; ok && utils.CheckTruth(val) {
|
2020-01-31 07:22:37 +03:00
|
|
|
field.Unique = true
|
|
|
|
}
|
|
|
|
|
|
|
|
if val, ok := field.TagSettings["COMMENT"]; ok {
|
|
|
|
field.Comment = val
|
|
|
|
}
|
|
|
|
|
2020-09-10 06:59:18 +03:00
|
|
|
// default value is function or null or blank (primary keys)
|
|
|
|
skipParseDefaultValue := strings.Contains(field.DefaultValue, "(") &&
|
|
|
|
strings.Contains(field.DefaultValue, ")") || strings.ToLower(field.DefaultValue) == "null" || field.DefaultValue == ""
|
2020-05-30 16:05:27 +03:00
|
|
|
switch reflect.Indirect(fieldValue).Kind() {
|
2020-01-31 07:22:37 +03:00
|
|
|
case reflect.Bool:
|
|
|
|
field.DataType = Bool
|
2020-09-10 06:59:18 +03:00
|
|
|
if field.HasDefaultValue && !skipParseDefaultValue {
|
2020-09-03 13:20:57 +03:00
|
|
|
if field.DefaultValueInterface, err = strconv.ParseBool(field.DefaultValue); err != nil {
|
|
|
|
schema.err = fmt.Errorf("failed to parse %v as default value for bool, got error: %v", field.DefaultValue, err)
|
|
|
|
}
|
2020-02-18 17:56:37 +03:00
|
|
|
}
|
2020-01-31 07:22:37 +03:00
|
|
|
case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
|
|
|
|
field.DataType = Int
|
2020-09-10 06:59:18 +03:00
|
|
|
if field.HasDefaultValue && !skipParseDefaultValue {
|
2020-09-03 13:20:57 +03:00
|
|
|
if field.DefaultValueInterface, err = strconv.ParseInt(field.DefaultValue, 0, 64); err != nil {
|
|
|
|
schema.err = fmt.Errorf("failed to parse %v as default value for int, got error: %v", field.DefaultValue, err)
|
|
|
|
}
|
2020-02-18 17:56:37 +03:00
|
|
|
}
|
2020-01-31 07:22:37 +03:00
|
|
|
case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64:
|
|
|
|
field.DataType = Uint
|
2020-09-10 06:59:18 +03:00
|
|
|
if field.HasDefaultValue && !skipParseDefaultValue {
|
2020-09-03 13:20:57 +03:00
|
|
|
if field.DefaultValueInterface, err = strconv.ParseUint(field.DefaultValue, 0, 64); err != nil {
|
|
|
|
schema.err = fmt.Errorf("failed to parse %v as default value for uint, got error: %v", field.DefaultValue, err)
|
|
|
|
}
|
2020-02-18 17:56:37 +03:00
|
|
|
}
|
2020-01-31 07:22:37 +03:00
|
|
|
case reflect.Float32, reflect.Float64:
|
|
|
|
field.DataType = Float
|
2020-09-10 06:59:18 +03:00
|
|
|
if field.HasDefaultValue && !skipParseDefaultValue {
|
2020-09-03 13:20:57 +03:00
|
|
|
if field.DefaultValueInterface, err = strconv.ParseFloat(field.DefaultValue, 64); err != nil {
|
|
|
|
schema.err = fmt.Errorf("failed to parse %v as default value for float, got error: %v", field.DefaultValue, err)
|
|
|
|
}
|
2020-02-18 17:56:37 +03:00
|
|
|
}
|
2020-01-31 07:22:37 +03:00
|
|
|
case reflect.String:
|
|
|
|
field.DataType = String
|
2020-06-18 03:20:41 +03:00
|
|
|
|
2020-09-10 06:59:18 +03:00
|
|
|
if field.HasDefaultValue && !skipParseDefaultValue {
|
2020-05-30 11:03:27 +03:00
|
|
|
field.DefaultValue = strings.Trim(field.DefaultValue, "'")
|
|
|
|
field.DefaultValue = strings.Trim(field.DefaultValue, "\"")
|
2020-02-18 17:56:37 +03:00
|
|
|
field.DefaultValueInterface = field.DefaultValue
|
|
|
|
}
|
2020-01-31 07:22:37 +03:00
|
|
|
case reflect.Struct:
|
2020-02-01 15:18:25 +03:00
|
|
|
if _, ok := fieldValue.Interface().(*time.Time); ok {
|
2020-01-31 07:22:37 +03:00
|
|
|
field.DataType = Time
|
2020-09-24 15:08:24 +03:00
|
|
|
} else if fieldValue.Type().ConvertibleTo(TimeReflectType) {
|
2020-07-30 12:36:39 +03:00
|
|
|
field.DataType = Time
|
2020-02-15 19:37:59 +03:00
|
|
|
} else if fieldValue.Type().ConvertibleTo(reflect.TypeOf(&time.Time{})) {
|
|
|
|
field.DataType = Time
|
2020-01-31 07:22:37 +03:00
|
|
|
}
|
|
|
|
case reflect.Array, reflect.Slice:
|
2020-06-18 04:32:31 +03:00
|
|
|
if reflect.Indirect(fieldValue).Type().Elem() == reflect.TypeOf(uint8(0)) {
|
2020-01-31 07:22:37 +03:00
|
|
|
field.DataType = Bytes
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-07-20 13:59:28 +03:00
|
|
|
field.GORMDataType = field.DataType
|
|
|
|
|
2020-06-06 05:47:32 +03:00
|
|
|
if dataTyper, ok := fieldValue.Interface().(GormDataTypeInterface); ok {
|
|
|
|
field.DataType = DataType(dataTyper.GormDataType())
|
|
|
|
}
|
|
|
|
|
2020-06-03 03:44:13 +03:00
|
|
|
if v, ok := field.TagSettings["AUTOCREATETIME"]; ok || (field.Name == "CreatedAt" && (field.DataType == Time || field.DataType == Int || field.DataType == Uint)) {
|
2020-03-08 08:24:08 +03:00
|
|
|
if strings.ToUpper(v) == "NANO" {
|
|
|
|
field.AutoCreateTime = UnixNanosecond
|
2020-07-30 12:39:57 +03:00
|
|
|
} else if strings.ToUpper(v) == "MILLI" {
|
|
|
|
field.AutoCreateTime = UnixMillisecond
|
2020-03-08 08:24:08 +03:00
|
|
|
} else {
|
|
|
|
field.AutoCreateTime = UnixSecond
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-06-03 03:44:13 +03:00
|
|
|
if v, ok := field.TagSettings["AUTOUPDATETIME"]; ok || (field.Name == "UpdatedAt" && (field.DataType == Time || field.DataType == Int || field.DataType == Uint)) {
|
2020-03-08 08:24:08 +03:00
|
|
|
if strings.ToUpper(v) == "NANO" {
|
|
|
|
field.AutoUpdateTime = UnixNanosecond
|
2020-07-30 12:39:57 +03:00
|
|
|
} else if strings.ToUpper(v) == "MILLI" {
|
|
|
|
field.AutoUpdateTime = UnixMillisecond
|
2020-03-08 08:24:08 +03:00
|
|
|
} else {
|
|
|
|
field.AutoUpdateTime = UnixSecond
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-06-26 02:26:45 +03:00
|
|
|
if val, ok := field.TagSettings["TYPE"]; ok {
|
|
|
|
switch DataType(strings.ToLower(val)) {
|
|
|
|
case Bool, Int, Uint, Float, String, Time, Bytes:
|
|
|
|
field.DataType = DataType(strings.ToLower(val))
|
|
|
|
default:
|
|
|
|
field.DataType = DataType(val)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-07-20 13:59:28 +03:00
|
|
|
if field.GORMDataType == "" {
|
|
|
|
field.GORMDataType = field.DataType
|
|
|
|
}
|
|
|
|
|
2020-01-31 07:22:37 +03:00
|
|
|
if field.Size == 0 {
|
2020-03-12 03:39:42 +03:00
|
|
|
switch reflect.Indirect(fieldValue).Kind() {
|
2020-01-31 07:22:37 +03:00
|
|
|
case reflect.Int, reflect.Int64, reflect.Uint, reflect.Uint64, reflect.Float64:
|
|
|
|
field.Size = 64
|
|
|
|
case reflect.Int8, reflect.Uint8:
|
|
|
|
field.Size = 8
|
|
|
|
case reflect.Int16, reflect.Uint16:
|
|
|
|
field.Size = 16
|
|
|
|
case reflect.Int32, reflect.Uint32, reflect.Float32:
|
|
|
|
field.Size = 32
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-06-05 14:18:22 +03:00
|
|
|
// setup permission
|
|
|
|
if _, ok := field.TagSettings["-"]; ok {
|
|
|
|
field.Creatable = false
|
|
|
|
field.Updatable = false
|
|
|
|
field.Readable = false
|
|
|
|
field.DataType = ""
|
|
|
|
}
|
|
|
|
|
|
|
|
if v, ok := field.TagSettings["->"]; ok {
|
|
|
|
field.Creatable = false
|
|
|
|
field.Updatable = false
|
|
|
|
if strings.ToLower(v) == "false" {
|
|
|
|
field.Readable = false
|
|
|
|
} else {
|
|
|
|
field.Readable = true
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if v, ok := field.TagSettings["<-"]; ok {
|
|
|
|
field.Creatable = true
|
|
|
|
field.Updatable = true
|
|
|
|
|
|
|
|
if v != "<-" {
|
|
|
|
if !strings.Contains(v, "create") {
|
|
|
|
field.Creatable = false
|
|
|
|
}
|
|
|
|
|
|
|
|
if !strings.Contains(v, "update") {
|
|
|
|
field.Updatable = false
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-08-11 16:22:51 +03:00
|
|
|
if _, ok := field.TagSettings["EMBEDDED"]; ok || (fieldStruct.Anonymous && !isValuer && (field.Creatable || field.Updatable || field.Readable)) {
|
2020-07-29 05:23:14 +03:00
|
|
|
if reflect.Indirect(fieldValue).Kind() == reflect.Struct {
|
|
|
|
var err error
|
|
|
|
field.Creatable = false
|
|
|
|
field.Updatable = false
|
|
|
|
field.Readable = false
|
2020-08-17 07:02:41 +03:00
|
|
|
|
2020-08-18 06:21:40 +03:00
|
|
|
cacheStore := &sync.Map{}
|
|
|
|
cacheStore.Store(embeddedCacheKey, true)
|
2020-11-27 09:32:20 +03:00
|
|
|
if field.EmbeddedSchema, err = getOrParse(fieldValue.Interface(), cacheStore, embeddedNamer{Table: schema.Table, Namer: schema.namer}); err != nil {
|
2020-07-29 05:23:14 +03:00
|
|
|
schema.err = err
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
2020-08-18 06:21:40 +03:00
|
|
|
|
2020-07-29 05:23:14 +03:00
|
|
|
for _, ef := range field.EmbeddedSchema.Fields {
|
|
|
|
ef.Schema = schema
|
2020-08-04 07:10:19 +03:00
|
|
|
ef.OwnerSchema = field.EmbeddedSchema
|
2020-07-29 05:23:14 +03:00
|
|
|
ef.BindNames = append([]string{fieldStruct.Name}, ef.BindNames...)
|
|
|
|
// index is negative means is pointer
|
|
|
|
if field.FieldType.Kind() == reflect.Struct {
|
|
|
|
ef.StructField.Index = append([]int{fieldStruct.Index[0]}, ef.StructField.Index...)
|
|
|
|
} else {
|
|
|
|
ef.StructField.Index = append([]int{-fieldStruct.Index[0] - 1}, ef.StructField.Index...)
|
|
|
|
}
|
2020-01-31 07:22:37 +03:00
|
|
|
|
2020-09-04 09:30:53 +03:00
|
|
|
if prefix, ok := field.TagSettings["EMBEDDEDPREFIX"]; ok && ef.DBName != "" {
|
2020-07-29 05:23:14 +03:00
|
|
|
ef.DBName = prefix + ef.DBName
|
|
|
|
}
|
2020-01-31 07:22:37 +03:00
|
|
|
|
2020-09-11 05:49:31 +03:00
|
|
|
if ef.PrimaryKey {
|
|
|
|
if val, ok := ef.TagSettings["PRIMARYKEY"]; ok && utils.CheckTruth(val) {
|
|
|
|
ef.PrimaryKey = true
|
|
|
|
} else if val, ok := ef.TagSettings["PRIMARY_KEY"]; ok && utils.CheckTruth(val) {
|
|
|
|
ef.PrimaryKey = true
|
|
|
|
} else {
|
|
|
|
ef.PrimaryKey = false
|
|
|
|
|
|
|
|
if val, ok := ef.TagSettings["AUTOINCREMENT"]; !ok || !utils.CheckTruth(val) {
|
|
|
|
ef.AutoIncrement = false
|
|
|
|
}
|
2020-08-19 14:02:32 +03:00
|
|
|
|
2020-09-11 05:49:31 +03:00
|
|
|
if ef.DefaultValue == "" {
|
|
|
|
ef.HasDefaultValue = false
|
|
|
|
}
|
2020-08-19 14:02:32 +03:00
|
|
|
}
|
2020-07-29 05:23:14 +03:00
|
|
|
}
|
2020-05-31 09:18:07 +03:00
|
|
|
|
2020-07-29 05:23:14 +03:00
|
|
|
for k, v := range field.TagSettings {
|
|
|
|
ef.TagSettings[k] = v
|
|
|
|
}
|
2020-01-31 07:22:37 +03:00
|
|
|
}
|
2020-07-29 05:23:14 +03:00
|
|
|
} else {
|
|
|
|
schema.err = fmt.Errorf("invalid embedded struct for %v's field %v, should be struct, but got %v", field.Schema.Name, field.Name, field.FieldType)
|
|
|
|
}
|
2020-01-31 07:22:37 +03:00
|
|
|
}
|
|
|
|
|
|
|
|
return field
|
|
|
|
}
|
2020-02-15 11:04:21 +03:00
|
|
|
|
|
|
|
// create valuer, setter when parse struct
|
|
|
|
func (field *Field) setupValuerAndSetter() {
|
2020-02-18 17:56:37 +03:00
|
|
|
// ValueOf
|
2020-02-15 11:04:21 +03:00
|
|
|
switch {
|
|
|
|
case len(field.StructField.Index) == 1:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ValueOf = func(value reflect.Value) (interface{}, bool) {
|
|
|
|
fieldValue := reflect.Indirect(value).Field(field.StructField.Index[0])
|
|
|
|
return fieldValue.Interface(), fieldValue.IsZero()
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
case len(field.StructField.Index) == 2 && field.StructField.Index[0] >= 0:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ValueOf = func(value reflect.Value) (interface{}, bool) {
|
|
|
|
fieldValue := reflect.Indirect(value).Field(field.StructField.Index[0]).Field(field.StructField.Index[1])
|
|
|
|
return fieldValue.Interface(), fieldValue.IsZero()
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
default:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ValueOf = func(value reflect.Value) (interface{}, bool) {
|
2020-02-15 14:45:27 +03:00
|
|
|
v := reflect.Indirect(value)
|
|
|
|
|
|
|
|
for _, idx := range field.StructField.Index {
|
|
|
|
if idx >= 0 {
|
|
|
|
v = v.Field(idx)
|
|
|
|
} else {
|
|
|
|
v = v.Field(-idx - 1)
|
|
|
|
|
2020-02-15 11:04:21 +03:00
|
|
|
if v.Type().Elem().Kind() == reflect.Struct {
|
|
|
|
if !v.IsNil() {
|
2020-02-15 14:45:27 +03:00
|
|
|
v = v.Elem()
|
2020-06-01 14:41:33 +03:00
|
|
|
} else {
|
|
|
|
return nil, true
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
2020-02-15 14:45:27 +03:00
|
|
|
} else {
|
2020-02-18 17:56:37 +03:00
|
|
|
return nil, true
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2020-02-18 17:56:37 +03:00
|
|
|
return v.Interface(), v.IsZero()
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-02-18 17:56:37 +03:00
|
|
|
// ReflectValueOf
|
2020-02-15 11:04:21 +03:00
|
|
|
switch {
|
|
|
|
case len(field.StructField.Index) == 1:
|
|
|
|
if field.FieldType.Kind() == reflect.Ptr {
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf = func(value reflect.Value) reflect.Value {
|
2020-02-15 14:45:27 +03:00
|
|
|
fieldValue := reflect.Indirect(value).Field(field.StructField.Index[0])
|
2020-02-15 11:04:21 +03:00
|
|
|
return fieldValue
|
|
|
|
}
|
|
|
|
} else {
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf = func(value reflect.Value) reflect.Value {
|
2020-02-15 14:45:27 +03:00
|
|
|
return reflect.Indirect(value).Field(field.StructField.Index[0])
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
}
|
|
|
|
case len(field.StructField.Index) == 2 && field.StructField.Index[0] >= 0 && field.FieldType.Kind() != reflect.Ptr:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf = func(value reflect.Value) reflect.Value {
|
2020-02-15 14:45:27 +03:00
|
|
|
return reflect.Indirect(value).Field(field.StructField.Index[0]).Field(field.StructField.Index[1])
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
default:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf = func(value reflect.Value) reflect.Value {
|
2020-02-15 14:45:27 +03:00
|
|
|
v := reflect.Indirect(value)
|
2020-06-23 04:09:46 +03:00
|
|
|
for idx, fieldIdx := range field.StructField.Index {
|
|
|
|
if fieldIdx >= 0 {
|
|
|
|
v = v.Field(fieldIdx)
|
2020-02-15 14:45:27 +03:00
|
|
|
} else {
|
2020-06-23 04:09:46 +03:00
|
|
|
v = v.Field(-fieldIdx - 1)
|
2020-02-15 14:45:27 +03:00
|
|
|
}
|
|
|
|
|
2020-02-15 11:04:21 +03:00
|
|
|
if v.Kind() == reflect.Ptr {
|
|
|
|
if v.Type().Elem().Kind() == reflect.Struct {
|
|
|
|
if v.IsNil() {
|
|
|
|
v.Set(reflect.New(v.Type().Elem()))
|
|
|
|
}
|
2020-02-15 14:45:27 +03:00
|
|
|
}
|
2020-02-15 11:04:21 +03:00
|
|
|
|
2020-02-15 14:45:27 +03:00
|
|
|
if idx < len(field.StructField.Index)-1 {
|
|
|
|
v = v.Elem()
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return v
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-06-02 17:13:53 +03:00
|
|
|
fallbackSetter := func(value reflect.Value, v interface{}, setter func(reflect.Value, interface{}) error) (err error) {
|
2020-05-24 12:24:23 +03:00
|
|
|
if v == nil {
|
|
|
|
field.ReflectValueOf(value).Set(reflect.New(field.FieldType).Elem())
|
2020-02-15 19:37:59 +03:00
|
|
|
} else {
|
2020-05-24 12:24:23 +03:00
|
|
|
reflectV := reflect.ValueOf(v)
|
2020-06-03 03:44:13 +03:00
|
|
|
|
2020-06-02 17:13:53 +03:00
|
|
|
if reflectV.Type().AssignableTo(field.FieldType) {
|
|
|
|
field.ReflectValueOf(value).Set(reflectV)
|
|
|
|
return
|
|
|
|
} else if reflectV.Type().ConvertibleTo(field.FieldType) {
|
2020-05-24 12:24:23 +03:00
|
|
|
field.ReflectValueOf(value).Set(reflectV.Convert(field.FieldType))
|
2020-06-02 17:13:53 +03:00
|
|
|
return
|
|
|
|
} else if field.FieldType.Kind() == reflect.Ptr {
|
2020-05-29 18:38:03 +03:00
|
|
|
fieldValue := field.ReflectValueOf(value)
|
2020-06-02 17:13:53 +03:00
|
|
|
|
|
|
|
if reflectV.Type().AssignableTo(field.FieldType.Elem()) {
|
2020-06-23 04:09:46 +03:00
|
|
|
if !fieldValue.IsValid() {
|
|
|
|
fieldValue = reflect.New(field.FieldType.Elem())
|
|
|
|
} else if fieldValue.IsNil() {
|
2020-06-02 17:13:53 +03:00
|
|
|
fieldValue.Set(reflect.New(field.FieldType.Elem()))
|
|
|
|
}
|
|
|
|
fieldValue.Elem().Set(reflectV)
|
|
|
|
return
|
|
|
|
} else if reflectV.Type().ConvertibleTo(field.FieldType.Elem()) {
|
|
|
|
if fieldValue.IsNil() {
|
|
|
|
fieldValue.Set(reflect.New(field.FieldType.Elem()))
|
2020-05-29 18:38:03 +03:00
|
|
|
}
|
2020-06-02 17:13:53 +03:00
|
|
|
|
|
|
|
fieldValue.Elem().Set(reflectV.Convert(field.FieldType.Elem()))
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-08-20 13:13:29 +03:00
|
|
|
if reflectV.Kind() == reflect.Ptr {
|
2020-06-03 03:44:13 +03:00
|
|
|
if reflectV.IsNil() {
|
|
|
|
field.ReflectValueOf(value).Set(reflect.New(field.FieldType).Elem())
|
|
|
|
} else {
|
2020-07-16 06:27:04 +03:00
|
|
|
err = setter(value, reflectV.Elem().Interface())
|
2020-06-03 03:44:13 +03:00
|
|
|
}
|
2020-08-20 13:13:29 +03:00
|
|
|
} else if valuer, ok := v.(driver.Valuer); ok {
|
|
|
|
if v, err = valuer.Value(); err == nil {
|
|
|
|
err = setter(value, v)
|
|
|
|
}
|
2020-05-24 12:24:23 +03:00
|
|
|
} else {
|
|
|
|
return fmt.Errorf("failed to set value %+v to field %v", v, field.Name)
|
|
|
|
}
|
2020-02-15 19:37:59 +03:00
|
|
|
}
|
2020-06-02 17:13:53 +03:00
|
|
|
|
|
|
|
return
|
2020-02-15 19:37:59 +03:00
|
|
|
}
|
|
|
|
|
2020-02-18 17:56:37 +03:00
|
|
|
// Set
|
2020-02-15 11:04:21 +03:00
|
|
|
switch field.FieldType.Kind() {
|
|
|
|
case reflect.Bool:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.Set = func(value reflect.Value, v interface{}) error {
|
2020-02-15 11:04:21 +03:00
|
|
|
switch data := v.(type) {
|
|
|
|
case bool:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetBool(data)
|
2020-02-15 11:04:21 +03:00
|
|
|
case *bool:
|
2020-07-04 03:21:23 +03:00
|
|
|
if data != nil {
|
|
|
|
field.ReflectValueOf(value).SetBool(*data)
|
|
|
|
} else {
|
|
|
|
field.ReflectValueOf(value).SetBool(false)
|
|
|
|
}
|
2020-06-02 17:13:53 +03:00
|
|
|
case int64:
|
|
|
|
if data > 0 {
|
|
|
|
field.ReflectValueOf(value).SetBool(true)
|
|
|
|
} else {
|
|
|
|
field.ReflectValueOf(value).SetBool(false)
|
|
|
|
}
|
|
|
|
case string:
|
|
|
|
b, _ := strconv.ParseBool(data)
|
|
|
|
field.ReflectValueOf(value).SetBool(b)
|
2020-02-15 11:04:21 +03:00
|
|
|
default:
|
2020-06-02 17:13:53 +03:00
|
|
|
return fallbackSetter(value, v, field.Set)
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.Set = func(value reflect.Value, v interface{}) (err error) {
|
2020-02-15 11:04:21 +03:00
|
|
|
switch data := v.(type) {
|
|
|
|
case int64:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetInt(data)
|
2020-02-15 11:04:21 +03:00
|
|
|
case int:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetInt(int64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case int8:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetInt(int64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case int16:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetInt(int64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case int32:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetInt(int64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case uint:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetInt(int64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case uint8:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetInt(int64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case uint16:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetInt(int64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case uint32:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetInt(int64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case uint64:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetInt(int64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case float32:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetInt(int64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case float64:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetInt(int64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case []byte:
|
2020-02-18 17:56:37 +03:00
|
|
|
return field.Set(value, string(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case string:
|
|
|
|
if i, err := strconv.ParseInt(data, 0, 64); err == nil {
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetInt(i)
|
2020-02-15 11:04:21 +03:00
|
|
|
} else {
|
|
|
|
return err
|
|
|
|
}
|
2020-02-18 17:56:37 +03:00
|
|
|
case time.Time:
|
2020-06-05 14:18:22 +03:00
|
|
|
if field.AutoCreateTime == UnixNanosecond || field.AutoUpdateTime == UnixNanosecond {
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetInt(data.UnixNano())
|
2020-07-30 12:39:57 +03:00
|
|
|
} else if field.AutoCreateTime == UnixMillisecond || field.AutoUpdateTime == UnixMillisecond {
|
|
|
|
field.ReflectValueOf(value).SetInt(data.UnixNano() / 1e6)
|
2020-02-18 17:56:37 +03:00
|
|
|
} else {
|
|
|
|
field.ReflectValueOf(value).SetInt(data.Unix())
|
|
|
|
}
|
|
|
|
case *time.Time:
|
|
|
|
if data != nil {
|
2020-06-05 14:18:22 +03:00
|
|
|
if field.AutoCreateTime == UnixNanosecond || field.AutoUpdateTime == UnixNanosecond {
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetInt(data.UnixNano())
|
2020-07-30 12:39:57 +03:00
|
|
|
} else if field.AutoCreateTime == UnixMillisecond || field.AutoUpdateTime == UnixMillisecond {
|
|
|
|
field.ReflectValueOf(value).SetInt(data.UnixNano() / 1e6)
|
2020-02-18 17:56:37 +03:00
|
|
|
} else {
|
|
|
|
field.ReflectValueOf(value).SetInt(data.Unix())
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
field.ReflectValueOf(value).SetInt(0)
|
|
|
|
}
|
2020-02-15 11:04:21 +03:00
|
|
|
default:
|
2020-06-02 17:13:53 +03:00
|
|
|
return fallbackSetter(value, v, field.Set)
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
2020-02-15 19:37:59 +03:00
|
|
|
return err
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.Set = func(value reflect.Value, v interface{}) (err error) {
|
2020-02-15 11:04:21 +03:00
|
|
|
switch data := v.(type) {
|
|
|
|
case uint64:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetUint(data)
|
2020-02-15 11:04:21 +03:00
|
|
|
case uint:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetUint(uint64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case uint8:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetUint(uint64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case uint16:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetUint(uint64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case uint32:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetUint(uint64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case int64:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetUint(uint64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case int:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetUint(uint64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case int8:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetUint(uint64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case int16:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetUint(uint64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case int32:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetUint(uint64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case float32:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetUint(uint64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case float64:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetUint(uint64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case []byte:
|
2020-02-18 17:56:37 +03:00
|
|
|
return field.Set(value, string(data))
|
2020-09-11 12:33:31 +03:00
|
|
|
case time.Time:
|
|
|
|
if field.AutoCreateTime == UnixNanosecond || field.AutoUpdateTime == UnixNanosecond {
|
|
|
|
field.ReflectValueOf(value).SetUint(uint64(data.UnixNano()))
|
|
|
|
} else if field.AutoCreateTime == UnixMillisecond || field.AutoUpdateTime == UnixMillisecond {
|
|
|
|
field.ReflectValueOf(value).SetUint(uint64(data.UnixNano() / 1e6))
|
|
|
|
} else {
|
|
|
|
field.ReflectValueOf(value).SetUint(uint64(data.Unix()))
|
|
|
|
}
|
2020-02-15 11:04:21 +03:00
|
|
|
case string:
|
|
|
|
if i, err := strconv.ParseUint(data, 0, 64); err == nil {
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetUint(i)
|
2020-02-15 11:04:21 +03:00
|
|
|
} else {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
default:
|
2020-06-02 17:13:53 +03:00
|
|
|
return fallbackSetter(value, v, field.Set)
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
2020-02-15 19:37:59 +03:00
|
|
|
return err
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
case reflect.Float32, reflect.Float64:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.Set = func(value reflect.Value, v interface{}) (err error) {
|
2020-02-15 11:04:21 +03:00
|
|
|
switch data := v.(type) {
|
|
|
|
case float64:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetFloat(data)
|
2020-02-15 11:04:21 +03:00
|
|
|
case float32:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetFloat(float64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case int64:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetFloat(float64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case int:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetFloat(float64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case int8:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetFloat(float64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case int16:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetFloat(float64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case int32:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetFloat(float64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case uint:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetFloat(float64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case uint8:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetFloat(float64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case uint16:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetFloat(float64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case uint32:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetFloat(float64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case uint64:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetFloat(float64(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case []byte:
|
2020-02-18 17:56:37 +03:00
|
|
|
return field.Set(value, string(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case string:
|
|
|
|
if i, err := strconv.ParseFloat(data, 64); err == nil {
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetFloat(i)
|
2020-02-15 11:04:21 +03:00
|
|
|
} else {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
default:
|
2020-06-02 17:13:53 +03:00
|
|
|
return fallbackSetter(value, v, field.Set)
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
2020-02-15 19:37:59 +03:00
|
|
|
return err
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
case reflect.String:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.Set = func(value reflect.Value, v interface{}) (err error) {
|
2020-02-15 11:04:21 +03:00
|
|
|
switch data := v.(type) {
|
|
|
|
case string:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetString(data)
|
2020-02-15 11:04:21 +03:00
|
|
|
case []byte:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetString(string(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case int, int8, int16, int32, int64, uint, uint8, uint16, uint32, uint64:
|
2020-09-01 16:03:37 +03:00
|
|
|
field.ReflectValueOf(value).SetString(utils.ToString(data))
|
2020-02-15 11:04:21 +03:00
|
|
|
case float64, float32:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).SetString(fmt.Sprintf("%."+strconv.Itoa(field.Precision)+"f", data))
|
2020-02-15 11:04:21 +03:00
|
|
|
default:
|
2020-06-02 17:13:53 +03:00
|
|
|
return fallbackSetter(value, v, field.Set)
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
2020-02-15 19:37:59 +03:00
|
|
|
return err
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
default:
|
|
|
|
fieldValue := reflect.New(field.FieldType)
|
2020-02-15 14:45:27 +03:00
|
|
|
switch fieldValue.Elem().Interface().(type) {
|
2020-02-15 11:04:21 +03:00
|
|
|
case time.Time:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.Set = func(value reflect.Value, v interface{}) error {
|
2020-02-15 11:04:21 +03:00
|
|
|
switch data := v.(type) {
|
|
|
|
case time.Time:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).Set(reflect.ValueOf(v))
|
2020-02-15 11:04:21 +03:00
|
|
|
case *time.Time:
|
2020-07-04 02:45:07 +03:00
|
|
|
if data != nil {
|
|
|
|
field.ReflectValueOf(value).Set(reflect.ValueOf(data).Elem())
|
|
|
|
} else {
|
|
|
|
field.ReflectValueOf(value).Set(reflect.ValueOf(time.Time{}))
|
|
|
|
}
|
2020-02-15 11:04:21 +03:00
|
|
|
case string:
|
|
|
|
if t, err := now.Parse(data); err == nil {
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).Set(reflect.ValueOf(t))
|
2020-02-15 11:04:21 +03:00
|
|
|
} else {
|
|
|
|
return fmt.Errorf("failed to set string %v to time.Time field %v, failed to parse it as time, got error %v", v, field.Name, err)
|
|
|
|
}
|
|
|
|
default:
|
2020-06-02 17:13:53 +03:00
|
|
|
return fallbackSetter(value, v, field.Set)
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
case *time.Time:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.Set = func(value reflect.Value, v interface{}) error {
|
2020-02-15 11:04:21 +03:00
|
|
|
switch data := v.(type) {
|
|
|
|
case time.Time:
|
2020-05-29 18:38:03 +03:00
|
|
|
fieldValue := field.ReflectValueOf(value)
|
|
|
|
if fieldValue.IsNil() {
|
|
|
|
fieldValue.Set(reflect.New(field.FieldType.Elem()))
|
|
|
|
}
|
|
|
|
fieldValue.Elem().Set(reflect.ValueOf(v))
|
2020-02-15 11:04:21 +03:00
|
|
|
case *time.Time:
|
2020-02-18 17:56:37 +03:00
|
|
|
field.ReflectValueOf(value).Set(reflect.ValueOf(v))
|
2020-02-15 11:04:21 +03:00
|
|
|
case string:
|
|
|
|
if t, err := now.Parse(data); err == nil {
|
2020-05-29 18:38:03 +03:00
|
|
|
fieldValue := field.ReflectValueOf(value)
|
|
|
|
if fieldValue.IsNil() {
|
|
|
|
if v == "" {
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
fieldValue.Set(reflect.New(field.FieldType.Elem()))
|
|
|
|
}
|
|
|
|
fieldValue.Elem().Set(reflect.ValueOf(t))
|
2020-02-15 11:04:21 +03:00
|
|
|
} else {
|
|
|
|
return fmt.Errorf("failed to set string %v to time.Time field %v, failed to parse it as time, got error %v", v, field.Name, err)
|
|
|
|
}
|
|
|
|
default:
|
2020-06-02 17:13:53 +03:00
|
|
|
return fallbackSetter(value, v, field.Set)
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
default:
|
2020-08-13 07:05:55 +03:00
|
|
|
if _, ok := fieldValue.Elem().Interface().(sql.Scanner); ok {
|
|
|
|
// pointer scanner
|
2020-02-18 17:56:37 +03:00
|
|
|
field.Set = func(value reflect.Value, v interface{}) (err error) {
|
2020-06-02 17:13:53 +03:00
|
|
|
reflectV := reflect.ValueOf(v)
|
2020-10-23 13:40:05 +03:00
|
|
|
if !reflectV.IsValid() {
|
|
|
|
field.ReflectValueOf(value).Set(reflect.New(field.FieldType).Elem())
|
|
|
|
} else if reflectV.Type().AssignableTo(field.FieldType) {
|
2020-08-13 07:05:55 +03:00
|
|
|
field.ReflectValueOf(value).Set(reflectV)
|
2020-06-03 03:44:13 +03:00
|
|
|
} else if reflectV.Kind() == reflect.Ptr {
|
2020-10-23 13:40:05 +03:00
|
|
|
if reflectV.IsNil() || !reflectV.IsValid() {
|
2020-06-03 03:44:13 +03:00
|
|
|
field.ReflectValueOf(value).Set(reflect.New(field.FieldType).Elem())
|
|
|
|
} else {
|
2020-10-23 13:40:05 +03:00
|
|
|
return field.Set(value, reflectV.Elem().Interface())
|
2020-06-03 03:44:13 +03:00
|
|
|
}
|
2020-05-24 17:52:16 +03:00
|
|
|
} else {
|
2020-08-13 07:05:55 +03:00
|
|
|
fieldValue := field.ReflectValueOf(value)
|
|
|
|
if fieldValue.IsNil() {
|
|
|
|
fieldValue.Set(reflect.New(field.FieldType.Elem()))
|
|
|
|
}
|
|
|
|
|
|
|
|
if valuer, ok := v.(driver.Valuer); ok {
|
|
|
|
v, _ = valuer.Value()
|
|
|
|
}
|
|
|
|
|
|
|
|
err = fieldValue.Interface().(sql.Scanner).Scan(v)
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
return
|
|
|
|
}
|
2020-08-13 07:05:55 +03:00
|
|
|
} else if _, ok := fieldValue.Interface().(sql.Scanner); ok {
|
|
|
|
// struct scanner
|
2020-02-18 17:56:37 +03:00
|
|
|
field.Set = func(value reflect.Value, v interface{}) (err error) {
|
2020-07-30 05:23:35 +03:00
|
|
|
reflectV := reflect.ValueOf(v)
|
2020-08-13 07:05:55 +03:00
|
|
|
if !reflectV.IsValid() {
|
|
|
|
field.ReflectValueOf(value).Set(reflect.New(field.FieldType).Elem())
|
|
|
|
} else if reflectV.Type().AssignableTo(field.FieldType) {
|
2020-06-03 03:44:13 +03:00
|
|
|
field.ReflectValueOf(value).Set(reflectV)
|
|
|
|
} else if reflectV.Kind() == reflect.Ptr {
|
2020-08-13 07:05:55 +03:00
|
|
|
if reflectV.IsNil() || !reflectV.IsValid() {
|
2020-06-03 03:44:13 +03:00
|
|
|
field.ReflectValueOf(value).Set(reflect.New(field.FieldType).Elem())
|
|
|
|
} else {
|
2020-08-13 07:05:55 +03:00
|
|
|
return field.Set(value, reflectV.Elem().Interface())
|
2020-06-03 03:44:13 +03:00
|
|
|
}
|
2020-05-24 17:52:16 +03:00
|
|
|
} else {
|
2020-08-13 07:05:55 +03:00
|
|
|
if valuer, ok := v.(driver.Valuer); ok {
|
|
|
|
v, _ = valuer.Value()
|
2020-02-15 19:37:59 +03:00
|
|
|
}
|
2020-08-13 07:05:55 +03:00
|
|
|
|
|
|
|
err = field.ReflectValueOf(value).Addr().Interface().(sql.Scanner).Scan(v)
|
2020-02-15 14:45:27 +03:00
|
|
|
}
|
2020-02-15 19:37:59 +03:00
|
|
|
return
|
2020-02-15 14:45:27 +03:00
|
|
|
}
|
|
|
|
} else {
|
2020-02-18 17:56:37 +03:00
|
|
|
field.Set = func(value reflect.Value, v interface{}) (err error) {
|
2020-06-02 17:13:53 +03:00
|
|
|
return fallbackSetter(value, v, field.Set)
|
2020-02-15 11:04:21 +03:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|