(rollbacks []rollbackEntry, dbVersion int)
| 334 | } |
| 335 | |
| 336 | func contiguousFromTop(rollbacks []rollbackEntry, dbVersion int) bool { |
| 337 | expected := dbVersion |
| 338 | for _, rb := range rollbacks { |
| 339 | if rb.version != expected { |
| 340 | return false |
| 341 | } |
| 342 | expected-- |
| 343 | } |
| 344 | return true |
| 345 | } |
| 346 | |
| 347 | func applyRollback(ctx context.Context, db *sql.DB, rb rollbackEntry) error { |
| 348 | tx, err := db.BeginTx(ctx, nil) |