JayaCode\Framework\Core\Database\Query\Query

Complexity

Total Complexity

34

Size/Duplication

Total Lines	360
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

82.11%

Importance

Changes	11
Bugs	0	Features	6

29 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	sql()	0	10	2
A	table()	0	4	1
A	setTable()	0	4	1
A	select()	0	6	1
A	insert()	0	7	1
A	update()	0	7	1
A	delete()	0	5	1
A	whereQ()	0	7	2
A	where()	0	5	1
A	andWhere()	0	4	1
A	orWhere()	0	4	1
A	like()	0	4	1
A	andLike()	0	4	1
A	orLike()	0	4	1
A	between()	0	8	2
A	andBetween()	0	4	1
A	orBetween()	0	4	1
A	sort()	0	9	1
A	asc()	0	4	1
A	desc()	0	4	1
A	limit()	0	7	1
A	build()	0	12	3
A	clear()	0	5	1
A	__get()	0	4	1
A	__set()	0	4	1
A	getType()	0	4	1
A	setType()	0	4	1
A	initColVal()	0	5	1

<?php
namespace JayaCode\Framework\Core\Database\Query;

use JayaCode\Framework\Core\Database\Query\Grammar\Grammar;

/**
 * Class Query
 * @property array where
 * @property array columns
 * @property mixed query
 * @property null params
 * @property array values
 * @property array sort
 * @property array offset
 * @property array limit
 * @package JayaCode\Framework\Core\Database\Query
 */
class Query
{
    /**
     *
     */
    const TYPE_QUERY = 'QUERY';
    /**
     *
     */
    const TYPE_SELECT = 'SELECT';

    /**
     *
     */
    const TYPE_INSERT = 'INSERT';

    /**
     *
     */
    const TYPE_UPDATE = 'UPDATE';

    /**
     *
     */
    const TYPE_DELETE = 'DELETE';

    /**
     * @var string
     */
    public $table;

    /**
     * @var array
     */
    protected $attributes = array(
        'where' => array(),
        'columns' => array()
    );

    /**
     * @var string
     */
    protected $type = "SELECT";

    /**
     * @param null $table
     */
    public function __construct($table = null)
    {
        $this->table = $table;
    }

    /**
     * @param $queryStr
     * @param $params
     * @return Query
     */
    public static function sql($queryStr, $params = null)
    {
        $query = new self();
        if ($params) {
            $query->params = $params;
        }
        $query->setType(self::TYPE_QUERY);
        $query->query = $queryStr;
        return $query;
    }

    /**
     * @param $table
     * @return Query
     */
    public static function table($table)
    {
        return new self($table);
    }

    /**
     * @param $table
     */
    public function setTable($table)
    {
        $this->table = $table;
    }

    /**
     * @param $columns
     * @return $this
     */
    public function select($columns = null)
    {
        $this->attributes['columns'] = $columns;
        $this->type = Query::TYPE_SELECT;
        return $this;
    }

    /**
     * @param array $columnsVal
     * @return $this
     */
    public function insert(array $columnsVal)
    {
        $this->type = Query::TYPE_INSERT;
        $this->initColVal($columnsVal);

        return $this;
    }


    /**
     * @param $columnsVal
     * @return $this
     */
    public function update($columnsVal)
    {
        $this->type = Query::TYPE_UPDATE;
        $this->initColVal($columnsVal);

        return $this;
    }

    /**
     * @return $this
     */
    public function delete()
    {
        $this->type = Query::TYPE_DELETE;
        return $this;
    }

    /**
     * @param $query
     * @param string $type
     * @return Query
     */
    public function whereQ(Query $query, $type = "AND")
    {
        if ($query->getType() == Query::TYPE_QUERY) {
            $this->attributes['where'][] = array($type, $query->query);
        }
        return $this;
    }

    /**
     * @param $column
     * @param $value
     * @param string $operator
     * @param string $type
     * @return Query
     */
    public function where($column, $value, $operator = "=", $type = "AND")
    {
        $this->attributes['where'][] = array($type, array($column, $operator, $value));
        return $this;
    }

    /**
     * @param $column
     * @param $value
     * @param string $operator
     * @return Query
     */
    public function andWhere($column, $value, $operator = "=")
    {
        return $this->where($column, $value, $operator, "AND");
    }

    /**
     * @param $column
     * @param $value
     * @param string $operator
     * @return Query
     */
    public function orWhere($column, $value, $operator = "=")
    {
        return $this->where($column, $value, $operator, "OR");
    }

    /**
     * @param $column
     * @param $value
     * @param string $type
     * @return Query
     */
    public function like($column, $value, $type = "AND")
    {
        return $this->where($column, $value, "LIKE", $type);
    }

    /**
     * @param $column
     * @param $value
     * @return Query
     */
    public function andLike($column, $value)
    {
        return $this->like($column, $value);
    }

    /**
     * @param $column
     * @param $value
     * @return Query
     */
    public function orLike($column, $value)
    {
        return $this->like($column, $value, "OR");
    }

    /**
     * @param $column
     * @param array $value
     * @param string $type
     * @return Query
     */
    public function between($column, $value = array(), $type = "AND")
    {
        if (count($value) != 2) {
            throw new \OutOfBoundsException();
        }

        return $this->where($column, $value, "BETWEEN", $type);
    }

    /**
     * @param $column
     * @param array $value
     * @return Query
     */
    public function andBetween($column, $value = array())
    {
        return $this->between($column, $value);
    }

    /**
     * @param $column
     * @param $value
     * @return Query
     */
    public function orBetween($column, $value)
    {
        return $this->between($column, $value, "OR");
    }

    /**
     * @param $column
     * @param $order
     * @return $this
     */
    public function sort($column, $order)
    {
        $this->attributes['sort'] = array(
            'column' => $column,
            'order' => $order
        );

        return $this;
    }

    /**
     * @param $column
     * @return Query
     */
    public function asc($column)
    {
        return $this->sort($column, "ASC");
    }

    /**
     * @param $column
     * @return Query
     */
    public function desc($column)
    {
        return $this->sort($column, "DESC");
    }

    /**
     * @param $num
     * @param null $offset
     * @return $this
     */
    public function limit($num, $offset = null)
    {
        $this->attributes['limit'] = $num;
        $this->attributes['offset'] = $offset;
        
        return $this;
    }

    /**
     * @param Grammar $grammar
     * @return array
     */
    public function build(Grammar $grammar)
    {
        $grammar->setQuery($this);

        $queryStr = $grammar->build();

        $queryParams = isset($this->attributes['params']) && !empty($this->attributes['params'])?
            $this->attributes['params']
            :$grammar->getParams();

        return [$queryStr, $queryParams];
    }

    /**
     * Clear Query Builder
     */
    public function clear()
    {
        $this->attributes = array();
        $this->params = array();
    }

    /**
     * @param $name
     * @return array
     */
    public function __get($name)
    {
        return arr_get($this->attributes, $name);
    }

    /**
     * @param $name
     * @param $value
     */
    public function __set($name, $value)
    {
        $this->attributes[$name] = $value;
    }

    /**
     * @return string
     */
    public function getType()
    {
        return $this->type;
    }

    /**
     * @param string $type
     */
    public function setType($type)
    {
        $this->type = $type;
    }

    /**
     * init col and val to attributes
     * @param $columnsVal
     */
    public function initColVal($columnsVal)
    {
        $this->attributes['columns'] = array_keys($columnsVal);
        $this->attributes['values'] = array_values($columnsVal);
    }
}