Method QueryWithVersion

cli/migrate/migrate.go:630–668

(version uint64, data io.ReadCloser, skipExecution bool)

}

func (m *Migrate) QueryWithVersion(version uint64, data io.ReadCloser, skipExecution bool) error {
	var op herrors.Op = "migrate.Migrate.QueryWithVersion"
	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)
	}

	if !skipExecution {
		if err := m.databaseDrv.Run(data, "meta", "", false); err != nil {
			m.databaseDrv.ResetQuery()
			if e := m.unlockErr(err); e != nil {
				return herrors.E(op, e)
			}
			return nil
		}
	}

	if version != 0 {
		if err := m.databaseDrv.SetVersion(int64(version), false); err != nil {
			m.databaseDrv.ResetQuery()
			if e := m.unlockErr(err); e != nil {
				return herrors.E(op, e)
			}
			return nil
		}
	}
	if err := m.unlockErr(nil); err != nil {
		return herrors.E(op, err)
	}
	return nil
}

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