sort the reset
Showing
1 changed file
with
9 additions
and
7 deletions
| ... | @@ -174,22 +174,24 @@ func Rollback(name string) error { | ... | @@ -174,22 +174,24 @@ func Rollback(name string) error { |
| 174 | // reset all migration | 174 | // reset all migration |
| 175 | // run all migration's down function | 175 | // run all migration's down function |
| 176 | func Reset() error { | 176 | func Reset() error { |
| 177 | sm := sortMap(migrationMap) | ||
| 177 | i := 0 | 178 | i := 0 |
| 178 | for k, v := range migrationMap { | 179 | for _, v := range sm { |
| 179 | if isRollBack(k) { | 180 | if isRollBack(v.name) { |
| 180 | beego.Info("skip the", k) | 181 | beego.Info("skip the", v.name) |
| 181 | time.Sleep(1 * time.Second) | 182 | time.Sleep(1 * time.Second) |
| 182 | continue | 183 | continue |
| 183 | } | 184 | } |
| 184 | beego.Info("start reset:", k) | 185 | beego.Info("start reset:", v.name) |
| 185 | v.Down() | 186 | v.m.Down() |
| 186 | err := v.Exec(k, "down") | 187 | err := v.m.Exec(v.name, "down") |
| 187 | if err != nil { | 188 | if err != nil { |
| 188 | beego.Error("execute error:", err) | 189 | beego.Error("execute error:", err) |
| 189 | time.Sleep(2 * time.Second) | 190 | time.Sleep(2 * time.Second) |
| 190 | return err | 191 | return err |
| 191 | } | 192 | } |
| 192 | beego.Info("end reset:", k) | 193 | i++ |
| 194 | beego.Info("end reset:", v.name) | ||
| 193 | } | 195 | } |
| 194 | beego.Info("total success reset:", i, " migration") | 196 | beego.Info("total success reset:", i, " migration") |
| 195 | time.Sleep(2 * time.Second) | 197 | time.Sleep(2 * time.Second) | ... | ... |
-
Please register or sign in to post a comment