package orm import ( "fmt" "reflect" "time" ) // get table alias. func getDbAlias(name string) *alias { if al, ok := dataBaseCache.get(name); ok { return al } else { panic(fmt.Errorf("unknown DataBase alias name %s", name)) } } // get pk column info. func getExistPk(mi *modelInfo, ind reflect.Value) (column string, value interface{}, exist bool) { fi := mi.fields.pk v := ind.Field(fi.fieldIndex) if fi.fieldType&IsPostiveIntegerField > 0 { vu := v.Uint() exist = vu > 0 value = vu } else if fi.fieldType&IsIntegerField > 0 { vu := v.Int() exist = vu > 0 value = vu } else { vu := v.String() exist = vu != "" value = vu } column = fi.column return } // get fields description as flatted string. func getFlatParams(fi *fieldInfo, args []interface{}, tz *time.Location) (params []interface{}) { outFor: for _, arg := range args { val := reflect.ValueOf(arg) if arg == nil { params = append(params, arg) continue } kind := val.Kind() if kind == reflect.Ptr { val = val.Elem() kind = val.Kind() arg = val.Interface() } switch kind { case reflect.String: v := val.String() if fi != nil { if fi.fieldType == TypeDateField || fi.fieldType == TypeDateTimeField { var t time.Time var err error if len(v) >= 19 { s := v[:19] t, err = time.ParseInLocation(format_DateTime, s, DefaultTimeLoc) } else { s := v if len(v) > 10 { s = v[:10] } t, err = time.ParseInLocation(format_Date, s, tz) } if err == nil { if fi.fieldType == TypeDateField { v = t.In(tz).Format(format_Date) } else { v = t.In(tz).Format(format_DateTime) } } } } arg = v case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64: arg = val.Int() case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64: arg = val.Uint() case reflect.Float32: arg, _ = StrTo(ToStr(arg)).Float64() case reflect.Float64: arg = val.Float() case reflect.Bool: arg = val.Bool() case reflect.Slice, reflect.Array: if _, ok := arg.([]byte); ok { continue outFor } var args []interface{} for i := 0; i < val.Len(); i++ { v := val.Index(i) var vu interface{} if v.CanInterface() { vu = v.Interface() } if vu == nil { continue } args = append(args, vu) } if len(args) > 0 { p := getFlatParams(fi, args, tz) params = append(params, p...) } continue outFor case reflect.Struct: if v, ok := arg.(time.Time); ok { if fi != nil && fi.fieldType == TypeDateField { arg = v.In(tz).Format(format_Date) } else { arg = v.In(tz).Format(format_DateTime) } } else { typ := val.Type() name := getFullName(typ) var value interface{} if mmi, ok := modelCache.getByFN(name); ok { if _, vu, exist := getExistPk(mmi, val); exist { value = vu } } arg = value if arg == nil { panic(fmt.Errorf("need a valid args value, unknown table or value `%s`", name)) } } } params = append(params, arg) } return }