Function applyMigration

server/src/db/migrate.ts:124–151

* Apply a single migration

(migration: Migration)

 * Apply a single migration
 */
async function applyMigration(migration: Migration): Promise<void> {
  const pool = getPool();
  const client = await pool.connect();

  try {
    await client.query("BEGIN");
    await client.query("SET LOCAL statement_timeout = 0");

    // Execute migration SQL
    await client.query(migration.sql);

    // Record migration
    await client.query(
      "INSERT INTO schema_migrations (version, filename) VALUES ($1, $2)",
      [migration.version, migration.filename]
    );

    await client.query("COMMIT");

    console.log(`✓ Applied migration: ${migration.filename}`);
  } catch (error) {
    await client.query("ROLLBACK");
    console.error(`✗ Failed to apply migration: ${migration.filename}`);
    throw error;
  } finally {
    client.release();
  }
}

/**
 * Run all pending migrations