2014-04-12 05:18:18 +00:00
|
|
|
// Beego (http://beego.me/)
|
2014-07-03 15:40:21 +00:00
|
|
|
//
|
2014-04-12 05:18:18 +00:00
|
|
|
// @description beego is an open-source, high-performance web framework for the Go programming language.
|
2014-07-03 15:40:21 +00:00
|
|
|
//
|
2014-04-12 05:18:18 +00:00
|
|
|
// @link http://github.com/astaxie/beego for the canonical source repository
|
2014-07-03 15:40:21 +00:00
|
|
|
//
|
2014-04-12 05:18:18 +00:00
|
|
|
// @license http://github.com/astaxie/beego/blob/master/LICENSE
|
2014-07-03 15:40:21 +00:00
|
|
|
//
|
2014-06-25 02:39:37 +00:00
|
|
|
// @authors astaxie, slene
|
2013-07-30 12:32:38 +00:00
|
|
|
package orm
|
|
|
|
|
|
|
|
import (
|
2014-02-28 03:53:35 +00:00
|
|
|
"database/sql"
|
2013-07-30 12:32:38 +00:00
|
|
|
"fmt"
|
|
|
|
"reflect"
|
|
|
|
"strings"
|
|
|
|
"time"
|
|
|
|
)
|
|
|
|
|
2014-01-17 15:28:54 +00:00
|
|
|
// get reflect.Type name with package path.
|
2013-08-09 12:14:18 +00:00
|
|
|
func getFullName(typ reflect.Type) string {
|
|
|
|
return typ.PkgPath() + "." + typ.Name()
|
|
|
|
}
|
|
|
|
|
2014-01-17 15:28:54 +00:00
|
|
|
// get table name. method, or field name. auto snaked.
|
2013-08-09 12:14:18 +00:00
|
|
|
func getTableName(val reflect.Value) string {
|
2013-07-30 12:32:38 +00:00
|
|
|
ind := reflect.Indirect(val)
|
|
|
|
fun := val.MethodByName("TableName")
|
|
|
|
if fun.IsValid() {
|
|
|
|
vals := fun.Call([]reflect.Value{})
|
|
|
|
if len(vals) > 0 {
|
|
|
|
val := vals[0]
|
|
|
|
if val.Kind() == reflect.String {
|
|
|
|
return val.String()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return snakeString(ind.Type().Name())
|
|
|
|
}
|
|
|
|
|
2014-01-17 15:28:54 +00:00
|
|
|
// get table engine, mysiam or innodb.
|
2013-09-16 01:48:04 +00:00
|
|
|
func getTableEngine(val reflect.Value) string {
|
|
|
|
fun := val.MethodByName("TableEngine")
|
|
|
|
if fun.IsValid() {
|
|
|
|
vals := fun.Call([]reflect.Value{})
|
|
|
|
if len(vals) > 0 {
|
|
|
|
val := vals[0]
|
|
|
|
if val.Kind() == reflect.String {
|
|
|
|
return val.String()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return ""
|
|
|
|
}
|
|
|
|
|
2014-01-17 15:28:54 +00:00
|
|
|
// get table index from method.
|
2013-08-22 13:19:58 +00:00
|
|
|
func getTableIndex(val reflect.Value) [][]string {
|
|
|
|
fun := val.MethodByName("TableIndex")
|
|
|
|
if fun.IsValid() {
|
|
|
|
vals := fun.Call([]reflect.Value{})
|
|
|
|
if len(vals) > 0 {
|
|
|
|
val := vals[0]
|
|
|
|
if val.CanInterface() {
|
|
|
|
if d, ok := val.Interface().([][]string); ok {
|
|
|
|
return d
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
2014-01-17 15:28:54 +00:00
|
|
|
// get table unique from method
|
2013-08-22 13:19:58 +00:00
|
|
|
func getTableUnique(val reflect.Value) [][]string {
|
|
|
|
fun := val.MethodByName("TableUnique")
|
|
|
|
if fun.IsValid() {
|
|
|
|
vals := fun.Call([]reflect.Value{})
|
|
|
|
if len(vals) > 0 {
|
|
|
|
val := vals[0]
|
|
|
|
if val.CanInterface() {
|
|
|
|
if d, ok := val.Interface().([][]string); ok {
|
|
|
|
return d
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
2014-01-17 15:28:54 +00:00
|
|
|
// get snaked column name
|
2013-07-30 12:32:38 +00:00
|
|
|
func getColumnName(ft int, addrField reflect.Value, sf reflect.StructField, col string) string {
|
2013-11-06 14:05:10 +00:00
|
|
|
column := col
|
|
|
|
if col == "" {
|
2013-07-30 12:32:38 +00:00
|
|
|
column = snakeString(sf.Name)
|
|
|
|
}
|
|
|
|
switch ft {
|
|
|
|
case RelForeignKey, RelOneToOne:
|
2013-11-06 14:05:10 +00:00
|
|
|
if len(col) == 0 {
|
|
|
|
column = column + "_id"
|
|
|
|
}
|
2013-07-30 12:32:38 +00:00
|
|
|
case RelManyToMany, RelReverseMany, RelReverseOne:
|
|
|
|
column = sf.Name
|
|
|
|
}
|
|
|
|
return column
|
|
|
|
}
|
|
|
|
|
2014-01-17 15:28:54 +00:00
|
|
|
// return field type as type constant from reflect.Value
|
2013-07-30 12:32:38 +00:00
|
|
|
func getFieldType(val reflect.Value) (ft int, err error) {
|
|
|
|
elm := reflect.Indirect(val)
|
2014-03-13 15:31:47 +00:00
|
|
|
switch elm.Kind() {
|
|
|
|
case reflect.Int8:
|
2013-08-13 09:16:12 +00:00
|
|
|
ft = TypeBitField
|
2014-03-13 15:31:47 +00:00
|
|
|
case reflect.Int16:
|
2013-07-30 12:32:38 +00:00
|
|
|
ft = TypeSmallIntegerField
|
2014-03-13 15:31:47 +00:00
|
|
|
case reflect.Int32, reflect.Int:
|
2013-07-30 12:32:38 +00:00
|
|
|
ft = TypeIntegerField
|
2014-03-13 15:31:47 +00:00
|
|
|
case reflect.Int64:
|
2013-07-30 12:32:38 +00:00
|
|
|
ft = TypeBigIntegerField
|
2014-03-13 15:31:47 +00:00
|
|
|
case reflect.Uint8:
|
2013-08-19 14:37:39 +00:00
|
|
|
ft = TypePositiveBitField
|
2014-03-13 15:31:47 +00:00
|
|
|
case reflect.Uint16:
|
2013-07-30 12:32:38 +00:00
|
|
|
ft = TypePositiveSmallIntegerField
|
2014-03-13 15:31:47 +00:00
|
|
|
case reflect.Uint32, reflect.Uint:
|
2013-07-30 12:32:38 +00:00
|
|
|
ft = TypePositiveIntegerField
|
2014-03-13 15:31:47 +00:00
|
|
|
case reflect.Uint64:
|
2013-07-30 12:32:38 +00:00
|
|
|
ft = TypePositiveBigIntegerField
|
2014-03-13 15:31:47 +00:00
|
|
|
case reflect.Float32, reflect.Float64:
|
2013-07-30 12:32:38 +00:00
|
|
|
ft = TypeFloatField
|
2014-03-13 15:31:47 +00:00
|
|
|
case reflect.Bool:
|
2013-07-30 12:32:38 +00:00
|
|
|
ft = TypeBooleanField
|
2014-03-13 15:31:47 +00:00
|
|
|
case reflect.String:
|
2013-08-16 14:24:10 +00:00
|
|
|
ft = TypeCharField
|
2013-07-30 12:32:38 +00:00
|
|
|
default:
|
2014-08-08 05:16:51 +00:00
|
|
|
if elm.Interface() == nil {
|
2014-08-07 05:09:09 +00:00
|
|
|
panic(fmt.Errorf("%s is nil pointer, may be miss setting tag", val))
|
|
|
|
}
|
2014-03-13 15:31:47 +00:00
|
|
|
switch elm.Interface().(type) {
|
|
|
|
case sql.NullInt64:
|
|
|
|
ft = TypeBigIntegerField
|
|
|
|
case sql.NullFloat64:
|
|
|
|
ft = TypeFloatField
|
|
|
|
case sql.NullBool:
|
|
|
|
ft = TypeBooleanField
|
|
|
|
case sql.NullString:
|
|
|
|
ft = TypeCharField
|
|
|
|
case time.Time:
|
|
|
|
ft = TypeDateTimeField
|
2013-07-30 12:32:38 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
if ft&IsFieldType == 0 {
|
|
|
|
err = fmt.Errorf("unsupport field type %s, may be miss setting tag", val)
|
|
|
|
}
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
2014-01-17 15:28:54 +00:00
|
|
|
// parse struct tag string
|
2013-07-30 12:32:38 +00:00
|
|
|
func parseStructTag(data string, attrs *map[string]bool, tags *map[string]string) {
|
|
|
|
attr := make(map[string]bool)
|
|
|
|
tag := make(map[string]string)
|
2013-09-09 14:33:41 +00:00
|
|
|
for _, v := range strings.Split(data, defaultStructTagDelim) {
|
2013-07-30 12:32:38 +00:00
|
|
|
v = strings.TrimSpace(v)
|
|
|
|
if supportTag[v] == 1 {
|
|
|
|
attr[v] = true
|
|
|
|
} else if i := strings.Index(v, "("); i > 0 && strings.Index(v, ")") == len(v)-1 {
|
|
|
|
name := v[:i]
|
|
|
|
if supportTag[name] == 2 {
|
|
|
|
v = v[i+1 : len(v)-1]
|
|
|
|
tag[name] = v
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
*attrs = attr
|
|
|
|
*tags = tag
|
|
|
|
}
|