add USING ?::? to AlterColumn (#105)

Co-authored-by: Jinzhu <wosmvp@gmail.com>

Author: warren830

migrator.go

@@ -279,31 +279,35 @@ func (m Migrator) AlterColumn(value interface{}, field string) error {
 				}
 			}
 
-			fileType := clause.Expr{SQL: m.DataTypeOf(field)}
-			if fieldColumnType.DatabaseTypeName() != fileType.SQL {
-				filedColumnAutoIncrement, _ := fieldColumnType.AutoIncrement()
-				if field.AutoIncrement && filedColumnAutoIncrement { // update
-					serialDatabaseType, _ := getSerialDatabaseType(fileType.SQL)
-					if t, _ := fieldColumnType.ColumnType(); t != serialDatabaseType {
-						if err := m.UpdateSequence(m.DB, stmt, field, serialDatabaseType); err != nil {
+			return m.DB.Connection(func(tx *gorm.DB) error {
+				fileType := clause.Expr{SQL: m.DataTypeOf(field)}
+				if fieldColumnType.DatabaseTypeName() != fileType.SQL {
+					filedColumnAutoIncrement, _ := fieldColumnType.AutoIncrement()
+					if field.AutoIncrement && filedColumnAutoIncrement { // update
+						serialDatabaseType, _ := getSerialDatabaseType(fileType.SQL)
+						if t, _ := fieldColumnType.ColumnType(); t != serialDatabaseType {
+							if err := m.UpdateSequence(tx, stmt, field, serialDatabaseType); err != nil {
+								return err
+							}
+						}
+					} else if field.AutoIncrement && !filedColumnAutoIncrement { // create
+						serialDatabaseType, _ := getSerialDatabaseType(fileType.SQL)
+						if err := m.CreateSequence(tx, stmt, field, serialDatabaseType); err != nil {
+							return err
+						}
+					} else if !field.AutoIncrement && filedColumnAutoIncrement { // delete
+						if err := m.DeleteSequence(tx, stmt, field, fileType); err != nil {
+							return err
+						}
+					} else {
+						if err := tx.Exec("ALTER TABLE ? ALTER COLUMN ? TYPE ? USING ?::?",
+							m.CurrentTable(stmt), clause.Column{Name: field.DBName}, fileType, clause.Column{Name: field.DBName}, fileType).Error; err != nil {
 							return err
 						}
-					}
-				} else if field.AutoIncrement && !filedColumnAutoIncrement { // create
-					serialDatabaseType, _ := getSerialDatabaseType(fileType.SQL)
-					if err := m.CreateSequence(m.DB, stmt, field, serialDatabaseType); err != nil {
-						return err
-					}
-				} else if !field.AutoIncrement && filedColumnAutoIncrement { // delete
-					if err := m.DeleteSequence(m.DB, stmt, field, fileType); err != nil {
-						return err
-					}
-				} else {
-					if err := m.DB.Exec("ALTER TABLE ? ALTER COLUMN ? TYPE ?", m.CurrentTable(stmt), clause.Column{Name: field.DBName}, fileType).Error; err != nil {
-						return err
 					}
 				}
-			}
+				return nil
+			})
 
 			if null, _ := fieldColumnType.Nullable(); null == field.NotNull {
 				if field.NotNull {
@@ -691,4 +695,4 @@ func groupByIndexName(indexList []*Index) map[string][]*Index {
 
 func (m Migrator) GetTypeAliases(databaseTypeName string) []string {
 	return typeAliasMap[databaseTypeName]
-}
+}