Method Migrate

cli/migrate/migrate.go:599–628

Migrate looks at the currently active migration version, then migrates either up or down to the specified version.

(version uint64, direction string)

// Migrate looks at the currently active migration version,
// then migrates either up or down to the specified version.
func (m *Migrate) Migrate(version uint64, direction string) error {
	var op herrors.Op = "migrate.Migrate.Migrate"
	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)
	}

	ret := make(chan interface{}, m.PrefetchMigrations)
	bar := newProgressBar(applyingMigrationsMessage, m.stderr, m.ProgressBarLogs)
	go m.read(version, direction, ret, bar)
	if m.DryRun {
		if e := m.unlockErr(m.runDryRun(ret)); e != nil {
			return herrors.E(op, e)
		}
		return nil
	} else {
		if e := m.unlockErr(m.runMigrations(ret, bar)); e != nil {
			return herrors.E(op, e)
		}
		return nil
	}
}

func (m *Migrate) QueryWithVersion(version uint64, data io.ReadCloser, skipExecution bool) error {
	var op herrors.Op = "migrate.Migrate.QueryWithVersion"