Pulsar\Query

Complexity

Total Complexity

28

Size/Duplication

Total Lines	306
Duplicated Lines	0 %

Coupling/Cohesion

Components	5
Dependencies	3

Importance

Changes	6
Bugs	0	Features	1

17 Methods

Rating	Name	Duplication	Size	Complexity
A	getModel()	0	4	1
A	getLimit()	0	4	1
A	getStart()	0	4	1
A	getSort()	0	4	1
A	getWhere()	0	4	1
A	getJoins()	0	4	1
A	all()	0	4	1
A	__construct()	0	9	1
A	limit()	0	6	1
A	start()	0	6	1
B	sort()	0	25	4
A	where()	0	21	4
A	first()	0	10	3
A	execute()	0	16	2
A	join()	0	6	1
A	set()	0	10	2
A	delete()	0	10	2

<?php

/**
 * @author Jared King <j@jaredtking.com>
 *
 * @link http://jaredtking.com
 *
 * @copyright 2015 Jared King
 * @license MIT
 */
namespace Pulsar;

class Query
{
    const DEFAULT_LIMIT = 100;
    const MAX_LIMIT = 1000;

    /**
     * @var Model
     */
    private $model;

    /**
     * @var array
     */
    private $joins;

    /**
     * @var array
     */
    private $where;

    /**
     * @var int
     */
    private $limit;

    /**
     * @var int
     */
    private $start;

    /**
     * @var array
     */
    private $sort;

    /**
     * @param Model $model model class
     */
    public function __construct(Model $model = null)
    {
        $this->model = $model;
        $this->joins = [];
        $this->where = [];
        $this->start = 0;
        $this->limit = self::DEFAULT_LIMIT;
        $this->sort = [];
    }

    /**
     * Gets the model class associated with this query.
     *
     * @return Model
     */
    public function getModel()
    {
        return $this->model;
    }

    /**
     * Sets the limit for this query.
     *
     * @param int $limit
     *
     * @return self
     */
    public function limit($limit)
    {
        $this->limit = min($limit, self::MAX_LIMIT);

        return $this;
    }

    /**
     * Gets the limit for this query.
     *
     * @return int
     */
    public function getLimit()
    {
        return $this->limit;
    }

    /**
     * Sets the start offset.
     *
     * @param int $start
     *
     * @return self
     */
    public function start($start)
    {
        $this->start = max($start, 0);

        return $this;
    }

    /**
     * Gets the start offset.
     *
     * @return int
     */
    public function getStart()
    {
        return $this->start;
    }

    /**
     * Sets the sort pattern for the query.
     *
     * @param array|string $sort
     *
     * @return self
     */
    public function sort($sort)
    {
        $columns = explode(',', $sort);

        $sortParams = [];
        foreach ($columns as $column) {
            $c = explode(' ', trim($column));

            if (count($c) != 2) {
                continue;
            }

            // validate direction
            $direction = strtolower($c[1]);
            if (!in_array($direction, ['asc', 'desc'])) {
                continue;
            }

            $sortParams[] = [$c[0], $direction];
        }

        $this->sort = $sortParams;

        return $this;
    }

    /**
     * Gets the sort parameters.
     *
     * @return array
     */
    public function getSort()
    {
        return $this->sort;
    }

    /**
     * Sets the where parameters.
     * Accepts the following forms:
     *   i)   where(['name' => 'Bob'])
     *   ii)  where('name', 'Bob')
     *   iii) where('balance', 100, >)
     *   iv)  where('balance > 100').
     *
     * @param array|string $where
     * @param mixed        $value optional value
     * @param 
     *
     * @return self
     */
    public function where($where, $value = null, $condition = null)
    {
        // handles i.
        if (is_array($where)) {
            $this->where = array_merge($this->where, $where);
        } else {
            // handles iii.
            $args = func_num_args();
            if ($args > 2) {
                $this->where[] = [$where, $value, $condition];
            // handles ii.
            } elseif ($args == 2) {
                $this->where[$where] = $value;
            // handles iv.
            } else {
                $this->where[] = $where;
            }
        }

        return $this;
    }

    /**
     * Gets the where parameters.
     *
     * @return array
     */
    public function getWhere()
    {
        return $this->where;
    }

    /**
     * Adds a join to the query. Matches a property on this model
     * to the ID of the model we are joining.
     *
     * @param string $model      model being joined
     * @param string $localKey   name of local property
     * @param string $foreignKey name of foreign property
     *
     * @return self
     */
    public function join($model, $localKey, $foreignKey)
    {
        $this->joins[] = [$model, $localKey, $foreignKey];

        return $this;
    }

    /**
     * Gets the joins.
     *
     * @return array
     */
    public function getJoins()
    {
        return $this->joins;
    }

    /**
     * Executes the query against the model's adapter.
     *
     * @return array results
     */
    public function execute()
    {
        $model = $this->model;

        $adapter = $model::getAdapter();

        $models = [];
        foreach ($adapter->queryModels($this) as $row) {
            // create a model with the retrieved values
            $obj = new $model();
            $obj->refreshWith($row);
            $models[] = $obj;
        }

        return $models;
    }

    /**
     * Creates an iterator for a search.
     *
     * @return Model\Iterator
     */
    public function all()
    {
        return new Iterator($this);
    }

    /**
     * Executes the query against the model's adapter and returns the first result.
     *
     * @param int $limit
     * 
     * @return array|\Pulsar\Model|null when $limit = 1, returns a single model or null, otherwise returns an array
     */
    public function first($limit = 1)
    {
        $models = $this->limit($limit)->execute();

        if ($limit == 1) {
            return (count($models) == 1) ? $models[0] : null;
        }

        return $models;
    }

    /**
     * Updates all of the matched models.
     *
     * @param array $params key-value update parameters
     *
     * @return int # of models updated
     */
    public function set(array $params)
    {
        $n = 0;
        foreach ($this->all() as $model) {
            $model->set($params);
            ++$n;
        }

        return $n;
    }

    /**
     * Deletes all of the matched models.
     *
     * @return int # of models deleted
     */
    public function delete()
    {
        $n = 0;
        foreach ($this->all() as $model) {
            $model->delete();
            ++$n;
        }

        return $n;
    }
}