Method Steps

cli/migrate/migrate.go:672–711

Steps looks at the currently active migration version. It will migrate up if n > 0, and down if n < 0.

(n int64)

// Steps looks at the currently active migration version.
// It will migrate up if n > 0, and down if n < 0.
func (m *Migrate) Steps(n int64) error {
	var op herrors.Op = "migrate.Migrate.Steps"
	mode, err := m.databaseDrv.GetSetting("migration_mode")
	if err != nil {
		return herrors.E(op, err)
	}

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

	if n == 0 {
		return herrors.E(op, ErrNoChange)
	}

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

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

	if n > 0 {
		go m.readUp(n, ret, bar)
	} else {
		go m.readDown(-n, 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
	}
}

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