Method Run

internal/storage/migrator.go:68–116

Run executes all collected migrations sorted by filename. Uses a migrations tracking table to avoid re-running.

()

// Run executes all collected migrations sorted by filename.
// Uses a migrations tracking table to avoid re-running.
func (m *Migrator) Run() error {
	// Create migrations tracking table.
	if _, err := m.db.Exec(`CREATE TABLE IF NOT EXISTS migrations (
		name TEXT PRIMARY KEY,
		module TEXT NOT NULL,
		applied_at DATETIME DEFAULT CURRENT_TIMESTAMP
	)`); err != nil {
		return fmt.Errorf("create migrations table: %w", err)
	}

	// Sort all migrations by name (date-based naming ensures correct order).
	sort.Slice(m.migrations, func(i, j int) bool {
		return m.migrations[i].Name < m.migrations[j].Name
	})

	// Run each migration.
	for _, mig := range m.migrations {
		// Check if already applied.
		var count int
		m.db.QueryRow(`SELECT COUNT(*) FROM migrations WHERE name = ?`, mig.Module+"/"+mig.Name).Scan(&count)
		if count > 0 {
			continue
		}

		slog.Info("running migration", "module", mig.Module, "name", mig.Name)

		// Execute all statements in the migration file.
		stmts := splitStatements(mig.Content)
		for _, stmt := range stmts {
			stmt = strings.TrimSpace(stmt)
			if stmt == "" {
				continue
			}
			if _, err := m.db.Exec(stmt); err != nil {
				return fmt.Errorf("migration %s/%s failed: %w\nSQL: %s", mig.Module, mig.Name, err, stmt)
			}
		}

		// Mark as applied.
		if _, err := m.db.Exec(
			`INSERT INTO migrations (name, module) VALUES (?, ?)`,
			mig.Module+"/"+mig.Name, mig.Module,
		); err != nil {
			return fmt.Errorf("record migration %s/%s: %w", mig.Module, mig.Name, err)
		}
	}

	return nil
}

// splitStatements splits SQL content by semicolons, respecting basic quoting.
func splitStatements(sql string) []string {