Method runMigrations

cli/migrate/migrate.go:1287–1326

runMigrations reads *Migration and error from a channel. Any other type sent on this channel will result in a panic. Each migration is then proxied to the database driver and run against the database. Before running a newly received migration it will check if it's supposed to stop execution because

(ret <-chan interface{}, bar *pb.ProgressBar)

// to stop execution because it might have received a stop signal on the
// GracefulStop channel.
func (m *Migrate) runMigrations(ret <-chan interface{}, bar *pb.ProgressBar) error {
	var op herrors.Op = "migrate.Migrate.runMigrations"
	startProgressBar(bar)
	setWidthProgressBar(bar, m.ProgressBarLogs)
	defer finishProgressBar(bar)
	for r := range ret {
		if m.stop() {
			return nil
		}

		switch r := r.(type) {
		case error:
			// Clear Migration query
			m.databaseDrv.ResetQuery()
			return herrors.E(op, r)
		case *Migration:
			if r.Body != nil {
				if !m.SkipExecution {
					m.Logger.Debugf("applying migration: %s", r.FileName)
					if err := m.databaseDrv.Run(r.BufferedBody, r.FileType, r.FileName, m.NoTransaction); err != nil {
						return herrors.E(op, err)
					}
				}
				incrementProgressBar(bar)
				version := int64(r.Version)
				// Insert Version number into the table
				if err := m.databaseDrv.SetVersion(version, false); err != nil {
					return herrors.E(op, err)
				}
				if version != r.TargetVersion {
					// Delete Version number from the table
					if err := m.databaseDrv.RemoveVersion(version); err != nil {
						return herrors.E(op, err)
					}
				}
			}
		}
	}
	return nil
}

func (m *Migrate) runDryRun(ret <-chan interface{}) error {
	var op herrors.Op = "migrate.Migrate.runDryRun"