Skip to content

Commit

Permalink
add some debug information to migrator logs
Browse files Browse the repository at this point in the history
  • Loading branch information
alovak committed May 10, 2021
1 parent 1f7f7dc commit 3954d44
Showing 1 changed file with 21 additions and 0 deletions.
21 changes: 21 additions & 0 deletions database/migrator.go
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,18 @@ func RunMigrations(logger log.Logger, config DatabaseConfig, migrationsSource so
return logger.Fatal().LogErrorf("Error running migration: %w", err).Err()
}

ver, _, err := m.Version()
switch {
case err == migrate.ErrNilVersion:
logger.Info().Log("Clean DB, no migrations")
case err != nil:
return logger.Fatal().LogErrorf("Error getting current migration version: %w", err).Err()
default:
logger.Info().Logf("DB is at version: %d", ver)
}

err = m.Up()

migrationMutex.Unlock()

switch err {
Expand All @@ -57,6 +68,16 @@ func RunMigrations(logger log.Logger, config DatabaseConfig, migrationsSource so
return logger.Fatal().LogErrorf("Error running migrations: %w", err).Err()
}

ver, _, err = m.Version()
switch {
case err == migrate.ErrNilVersion:
logger.Info().Log("Clean DB, no migrations")
case err != nil:
return logger.Fatal().LogErrorf("Error getting current migration version: %w", err).Err()
default:
logger.Info().Logf("DB migrated to version: %d", ver)
}

logger.Info().Log("Migrations complete")

return nil
Expand Down

0 comments on commit 3954d44

Please sign in to comment.