Function createMigrationsTable

migrations.go:283–323

(db *sqlx.DB)

	if err != nil {
		return fmt.Errorf("failed to get applied migrations: %w", err)
	}

	// Apply missing migrations
	sourceMigrations := make(map[int]string, len(migrations))
	for _, migration := range migrations {
		sourceMigrations[migration.ID] = migration.Name
		if appliedName, ok := applied[migration.ID]; ok && appliedName != migration.Name {
			log.Warn().
				Int("migration_id", migration.ID).
				Str("database_name", appliedName).
				Str("binary_name", migration.Name).
				Msg("Database migration ID has a different name in this binary")
		}
	}
	for id, appliedName := range applied {
		if _, ok := sourceMigrations[id]; !ok {
			log.Warn().
				Int("migration_id", id).
				Str("database_name", appliedName).
				Msg("Database contains a migration unknown to this binary")
		}
	}

	pending := 0
	for _, migration := range migrations {
		if _, ok := applied[migration.ID]; !ok {
			pending++
		}
	}
	log.Info().
		Str("driver", db.DriverName()).
		Int("applied", len(applied)).
		Int("pending", pending).
		Msg("Database migration status")

	for _, migration := range migrations {
		if _, ok := applied[migration.ID]; !ok {
			log.Info().
				Int("migration_id", migration.ID).
				Str("migration_name", migration.Name).
				Msg("Applying database migration")
			if err := applyMigration(db, migration); err != nil {
				return fmt.Errorf("failed to apply migration %d: %w", migration.ID, err)
			}