Function executeMigration

backend/migrator/migrator.go:194–234

(ctx context.Context, conn *sql.Conn, statement string, version string)

}

func executeMigration(ctx context.Context, conn *sql.Conn, statement string, version string) error {
	// Get current database context for error reporting
	var currentUser, currentDatabase string
	_ = conn.QueryRowContext(ctx, "SELECT current_user, current_database()").Scan(&currentUser, &currentDatabase)

	txn, err := conn.BeginTx(ctx, nil)
	if err != nil {
		return err
	}
	defer txn.Rollback()

	if _, err := txn.ExecContext(ctx, statement); err != nil {
		// Extract SQLSTATE and provide contextual information
		var sqlState string
		if pqErr, ok := err.(*pq.Error); ok {
			sqlState = string(pqErr.Code)
		}

		// Truncate statement for readability in error message
		stmtPreview, truncated := common.TruncateString(statement, 100)
		if truncated {
			stmtPreview += "..."
		}

		return errors.Errorf("migration %s failed\n"+
			"Statement: %s\n"+
			"User: %s\n"+
			"Database: %s\n"+
			"Error: %v\n"+
			"SQLSTATE: %s",
			version, stmtPreview, currentUser, currentDatabase, err, sqlState)
	}
	if _, err := txn.ExecContext(ctx,
		`INSERT INTO instance_change_history (version) VALUES ($1)`,
		version,
	); err != nil {
		return err
	}

	return txn.Commit()
}

func getLatestDatabaseVersion(ctx context.Context, conn *sql.Conn) (*semver.Version, error) {
	query := `SELECT version FROM instance_change_history ORDER BY id DESC`