Пагинация данных в PHP: объектный подход для работы с внешними источниками

Расширенные примеры использования пагинации в PHP с ООП

Ниже представлены дополнительные сценарии, которые демонстрируют гибкость объектно-ориентированного подхода при работе с пагинированными данными.

Пример 1. Итерация по всем страницам внешнего API с помощью ApiPaginator

$paginator = new ApiPaginator('https://api.example.com/users', 50, ['Authorization: Bearer token123']);
$allUsers = [];
do {
    $users = $paginator->fetch();
    if ($users !== null) {
        $allUsers = array_merge($allUsers, $users);
    }
} while ($paginator->nextPage());

echo 'Получено пользователей: ' . count($allUsers);
// Результат: 'Получено пользователей: 120'

Пример 2. Рендеринг нумерации страниц на основе данных SqlPaginator

$pdo = new PDO('mysql:host=localhost;dbname=blog', 'user', 'pass');
$paginator = new SqlPaginator($pdo, 'SELECT * FROM posts WHERE status = "published" ORDER BY created_at DESC', [], 10);
$currentPage = 1;
$totalPages = ceil($paginator->getTotal() / 10);

echo '';

Пример 3. Обработка API, который использует ссылки rel="next" (RFC 5988)

Некоторые REST-API возвращают заголовок Link с rel="next". Класс LinkHeaderPaginator извлекает URL следующей страницы из заголовка.

class LinkHeaderPaginator {
    private string $currentUrl;
    private ?string $nextUrl = null;
    private array $headers;

    public function __construct(string $initialUrl, array $headers = []) {
        $this->currentUrl = $initialUrl;
        $this->headers = $headers;
        $this->nextUrl = $initialUrl; // первая итерация
    }

    public function fetch(): ?array {
        if ($this->nextUrl === null) return null;
        $response = $this->httpGet($this->nextUrl);
        if (!$response) return null;
        $this->parseLinks($response['headers'] ?? '');
        return json_decode($response['body'], true);
    }

    private function parseLinks(string $headerValue): void {
        preg_match('/<([^>]+)>; rel="next"/', $headerValue, $matches);
        $this->nextUrl = $matches[1] ?? null;
    }

    private function httpGet(string $url): ?array {
        $ch = curl_init($url);
        curl_setopt_array($ch, [
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_HEADER         => true,
            CURLOPT_HTTPHEADER     => $this->headers
        ]);
        $response = curl_exec($ch);
        $headerSize = curl_getinfo($ch, CURLINFO_HEADER_SIZE);
        $headers = substr($response, 0, $headerSize);
        $body = substr($response, $headerSize);
        curl_close($ch);
        return ['headers' => $headers, 'body' => $body];
    }
}

// Пример использования:
$paginator = new LinkHeaderPaginator('https://api.github.com/repos/owner/repo/issues?page=1');
$page1 = $paginator->fetch();
$page2 = $paginator->fetch(); // получаем вторую страницу

Пример 4. Пагинация с использованием GuzzleHttp и обработкой ошибок

Если проект использует Guzzle, можно создать обёртку с автоматическим повторением при таймаутах.

use GuzzleHttp\Client;
use GuzzleHttp\Exception\ClientException;

class GuzzlePaginator {
    private Client $client;
    private string $endpoint;
    private array $queryDefaults;

    public function __construct(Client $client, string $endpoint) {
        $this->client = $client;
        $this->endpoint = $endpoint;
        $this->queryDefaults = ['page' => 1, 'limit' => 20];
    }

    public function fetch(int $page = null): array {
        $params = $this->queryDefaults;
        if ($page !== null) $params['page'] = $page;
        try {
            $response = $this->client->get($this->endpoint, ['query' => $params]);
            $body = json_decode($response->getBody(), true);
            return [
                'data'       => $body['data'] ?? [],
                'total_pages'=> $body['total_pages'] ?? 1,
                'current'    => $body['page'] ?? 1
            ];
        } catch (ClientException $e) {
            // логирование и возврат пустого массива
            return ['data' => [], 'total_pages' => 0, 'current' => 0];
        }
    }
}

Пример 5. Комбинирование пагинации с кэшированием результатов

Для ускорения повторных запросов к API полезно кэшировать ответы страниц. Ниже пример с использованием файлового кэша.

class CachedApiPaginator extends ApiPaginator {
    private string $cacheDir;
    private int $ttl;

    public function __construct(string $baseUrl, int $perPage, array $headers, string $cacheDir, int $ttl = 300) {
        parent::__construct($baseUrl, $perPage, $headers);
        $this->cacheDir = rtrim($cacheDir, '/');
        $this->ttl = $ttl;
        if (!is_dir($this->cacheDir)) {
            mkdir($this->cacheDir, 0755, true);
        }
    }

    public function fetch(): ?array {
        $cacheKey = md5($this->buildUrl());
        $cacheFile = $this->cacheDir . '/' . $cacheKey . '.json';
        if (file_exists($cacheFile) && (time() - filemtime($cacheFile) < $this->ttl)) {
            $this->parseResponse(file_get_contents($cacheFile));
            return $this->payload['data'] ?? null;
        }
        $data = parent::fetch();
        if ($data !== null && $this->payload) {
            file_put_contents($cacheFile, json_encode($this->payload));
        }
        return $data;
    }
}

Результат: при повторном обращении к одной и той же странице в течение TTL запрос к API не выполняется, данные берутся из кэша.