diff --git a/migrator/migrator.go b/migrator/migrator.go
index 98e92c96..c0e22ae0 100644
--- a/migrator/migrator.go
+++ b/migrator/migrator.go
@@ -388,9 +388,10 @@ func (m Migrator) MigrateColumn(value interface{}, field *schema.Field, columnTy
 
 func (m Migrator) ColumnTypes(value interface{}) (columnTypes []*sql.ColumnType, err error) {
 	err = m.RunWithValue(value, func(stmt *gorm.Statement) error {
-		rows, err := m.DB.Session(&gorm.Session{}).Raw("select * from ?", clause.Table{Name: stmt.Table}).Rows()
+		rows, err := m.DB.Session(&gorm.Session{}).Raw("select * from ? limit 1", clause.Table{Name: stmt.Table}).Rows()
 		if err == nil {
 			columnTypes, err = rows.ColumnTypes()
+			_ = rows.Close()
 		}
 		return err
 	})