Spiral\Database\Entities\Query\CachedResult

Complexity

Total Complexity

6

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	3

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	15	1
A	queryString()	0	4	1
A	flushCache()	0	5	1
A	jsonSerialize()	0	4	1
A	__debugInfo()	0	12	2

<?php
/**
 * Spiral Framework.
 *
 * @license   MIT
 * @author    Anton Titov (Wolfy-J)
 */

namespace Spiral\Database\Entities\Query;

use Spiral\Cache\StoreInterface;
use Spiral\Database\Helpers\QueryInterpolator;

/**
 * CacheResult is almost identical to QueryResult by it's functionality, but used to represent query
 * result stored in cache storage.
 */
class CachedResult extends ArrayResult implements \JsonSerializable
{
    /**
     * Limits after which no records will be dumped in __debugInfo.
     */
    const DUMP_LIMIT = 500;

    /**
     * @var StoreInterface
     */
    protected $store = null;

    /**
     * @var string
     */
    protected $key = '';

    /**
     * Query string (not interpolated).
     *
     * @var string
     */
    protected $queryString = '';

    /**
     * @var array
     */
    protected $parameters = [];

    /**
     * @param array          $data
     * @param array          $parameters
     * @param string         $queryString
     * @param string         $key
     * @param StoreInterface $store
     */
    public function __construct(
        array $data = [],
        array $parameters = [],
        string $queryString,
        string $key,
        StoreInterface $store
    ) {
        parent::__construct($data);

        $this->parameters = $parameters;
        $this->queryString = $queryString;

        $this->key = $key;
        $this->store = $store;
    }

    /**
     * {@inheritdoc}
     */
    public function queryString(): string
    {
        return QueryInterpolator::interpolate($this->queryString, $this->parameters);
    }

    /**
     * Flush results stored in CacheStore and CachedResult.
     */
    public function flushCache()
    {
        $this->store->delete($this->key);
        $this->key = null;
    }

    /**
     * @return array
     */
    public function jsonSerialize(): array
    {
        return $this->fetchAll();
    }

    /**
     * @return array
     */
    public function __debugInfo()
    {
        return [
            //Cache part
            'key'   => $this->key,
            'store' => get_class($this->store),

            'query' => $this->queryString(),
            'count' => $this->count(),
            'data'  => $this->count() > self::DUMP_LIMIT ? '[TOO MANY ROWS]' : $this->fetchAll()
        ];
    }
}