Method Up

cli/migrate/migrate.go:715–754

Up looks at the currently active migration version and will migrate all the way up (applying all up migrations).

()

// Up looks at the currently active migration version
// and will migrate all the way up (applying all up migrations).
func (m *Migrate) Up() error {
	var op herrors.Op = "migrate.Migrate.Up"
	mode, err := m.databaseDrv.GetSetting("migration_mode")
	if err != nil {
		return herrors.E(op, err)
	}

	if mode != "true" {
		return herrors.E(op, ErrNoMigrationMode)
	}

	if err := m.lock(); err != nil {
		return herrors.E(op, err)
	}

	curVersion, dirty, err := m.databaseDrv.Version()
	if err != nil {
		return herrors.E(op, err)
	}

	if dirty {
		return herrors.E(op, ErrDirty{curVersion})
	}

	ret := make(chan interface{}, m.PrefetchMigrations)
	bar := newProgressBar(applyingMigrationsMessage, m.stderr, m.ProgressBarLogs)
	go m.readUp(-1, ret, bar)

	if m.DryRun {
		if err := m.unlockErr(m.runDryRun(ret)); err != nil {
			return herrors.E(op, err)
		}
		return nil
	} else {
		if err := m.unlockErr(m.runMigrations(ret, bar)); err != nil {
			return herrors.E(op, err)
		}
		return nil
	}
}

// Down looks at the currently active migration version
// and will migrate all the way down (applying all down migrations).