Method checkForUnknownMigrations

pkg/session/migrations.go:90–111

checkForUnknownMigrations checks if the database has migrations that this binary doesn't know about, which indicates the database was created by a newer version. This produces a clear error instead of cryptic SQL failures from schema mismatches.

(ctx context.Context)

// doesn't know about, which indicates the database was created by a newer version.
// This produces a clear error instead of cryptic SQL failures from schema mismatches.
func (m *MigrationManager) checkForUnknownMigrations(ctx context.Context) error {
	if len(m.migrations) == 0 {
		return nil
	}
	maxKnownID := m.migrations[len(m.migrations)-1].ID

	var maxAppliedID int
	err := m.db.QueryRowContext(ctx, "SELECT COALESCE(MAX(id), 0) FROM migrations").Scan(&maxAppliedID)
	if err != nil {
		return fmt.Errorf("failed to check applied migrations: %w", err)
	}

	if maxAppliedID > maxKnownID {
		return fmt.Errorf(
			"%w: you are running docker-agent %s which supports migrations up to %d, "+
				"but the session database has migration %d from a newer version; "+
				"please upgrade docker-agent to the latest version",
			ErrNewerDatabase, version.Version, maxKnownID, maxAppliedID)
	}

	return nil
}

// RunPendingMigrations executes all migrations that haven't been applied yet
func (m *MigrationManager) RunPendingMigrations(ctx context.Context) error {