Refactor DataTypeOf for mysql

dialect_mysql.go

@@ -3,7 +3,7 @@ package gorm
 import (
 	"fmt"
 	"reflect"
-	"strconv"
+	"strings"
 	"time"
 )
 
@@ -15,62 +15,71 @@ func (mysql) Quote(key string) string {
 	return fmt.Sprintf("`%s`", key)
 }
 
+// Get Data Type for MySQL Dialect
 func (mysql) DataTypeOf(field *StructField) string {
-	var (
-		size        int
-		dataValue   = reflect.Indirect(reflect.New(field.Struct.Type))
-		tagSettings = field.TagSettings
-	)
-
-	if num, ok := tagSettings["SIZE"]; ok {
-		size, _ = strconv.Atoi(num)
-	}
+	var dataValue, sqlType, size, additionalType = ParseFieldStructForDialect(field)
 
+	if sqlType == "" {
 		switch dataValue.Kind() {
 		case reflect.Bool:
-		return "boolean"
+			sqlType = "boolean"
 		case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32:
-		if _, ok := tagSettings["AUTO_INCREMENT"]; ok {
-			return "int AUTO_INCREMENT"
+			if _, ok := field.TagSettings["AUTO_INCREMENT"]; ok || field.IsPrimaryKey {
+				sqlType = "int AUTO_INCREMENT"
+			} else {
+				sqlType = "int"
 			}
-		return "int"
 		case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uintptr:
-		if _, ok := tagSettings["AUTO_INCREMENT"]; ok {
-			return "int unsigned AUTO_INCREMENT"
+			if _, ok := field.TagSettings["AUTO_INCREMENT"]; ok || field.IsPrimaryKey {
+				sqlType = "int unsigned AUTO_INCREMENT"
+			} else {
+				sqlType = "int unsigned"
 			}
-		return "int unsigned"
 		case reflect.Int64:
-		if _, ok := tagSettings["AUTO_INCREMENT"]; ok {
-			return "bigint AUTO_INCREMENT"
+			if _, ok := field.TagSettings["AUTO_INCREMENT"]; ok || field.IsPrimaryKey {
+				sqlType = "bigint AUTO_INCREMENT"
+			} else {
+				sqlType = "bigint"
 			}
-		return "bigint"
 		case reflect.Uint64:
-		if _, ok := tagSettings["AUTO_INCREMENT"]; ok {
-			return "bigint unsigned AUTO_INCREMENT"
+			if _, ok := field.TagSettings["AUTO_INCREMENT"]; ok || field.IsPrimaryKey {
+				sqlType = "bigint unsigned AUTO_INCREMENT"
+			} else {
+				sqlType = "bigint unsigned"
 			}
-		return "bigint unsigned"
 		case reflect.Float32, reflect.Float64:
-		return "double"
+			sqlType = "double"
 		case reflect.String:
 			if size > 0 && size < 65532 {
-			return fmt.Sprintf("varchar(%d)", size)
+				sqlType = fmt.Sprintf("varchar(%d)", size)
+			} else {
+				sqlType = "longtext"
 			}
-		return "longtext"
 		case reflect.Struct:
 			if _, ok := dataValue.Interface().(time.Time); ok {
-			return "timestamp NULL"
+				sqlType = "timestamp NULL"
 			}
 		default:
 			if _, ok := dataValue.Interface().([]byte); ok {
 				if size > 0 && size < 65532 {
-				return fmt.Sprintf("varbinary(%d)", size)
-			}
-			return "longblob"
+					sqlType = fmt.Sprintf("varbinary(%d)", size)
+				} else {
+					sqlType = "longblob"
 				}
 			}
+		}
+	}
+
+	if sqlType == "" {
 		panic(fmt.Sprintf("invalid sql type %s (%s) for mysql", dataValue.Type().Name(), dataValue.Kind().String()))
 	}
 
+	if strings.TrimSpace(additionalType) == "" {
+		return sqlType
+	}
+	return fmt.Sprintf("%v %v", sqlType, additionalType)
+}
+
 func (s mysql) currentDatabase(scope *Scope) (name string) {
 	s.RawScanString(scope, &name, "SELECT DATABASE()")
 	return

dialect_sqlite3.go

@@ -13,9 +13,7 @@ type sqlite3 struct {
 
 // Get Data Type for Sqlite Dialect
 func (sqlite3) DataTypeOf(field *StructField) string {
-	var (
-		dataValue, sqlType, size, additionalType = ParseFieldStructForDialect(field)
-	)
+	var dataValue, sqlType, size, additionalType = ParseFieldStructForDialect(field)
 
 	if sqlType == "" {
 		switch dataValue.Kind() {