ByJG\MicroOrm\Query

Complexity

Total Complexity

29

Size/Duplication

Total Lines	249
Duplicated Lines	0 %

Coupling/Cohesion

Components	3
Dependencies	0

Test Coverage

Coverage

77.08%

Importance

Changes

0

16 Methods

Rating	Name	Duplication	Size	Complexity
A	fields()	0	6	1
A	table()	0	6	1
A	join()	0	5	1
A	where()	0	5	1
A	groupBy()	0	6	1
A	orderBy()	0	6	1
A	limit()	0	6	1
A	top()	0	6	1
A	forUpdate()	0	6	1
A	getFields()	0	8	2
A	getJoin()	0	8	2
A	getWhere()	0	16	3
B	getSelect()	0	27	5
A	getInsert()	0	14	2
B	getUpdate()	0	22	4
A	getDelete()	0	12	2

<?php
/**
 * Created by PhpStorm.
 * User: jg
 * Date: 21/06/16
 * Time: 12:01
 */

namespace ByJG\MicroOrm;


class Query
{
    protected $fields = [];
    protected $table = "";
    protected $where = [];
    protected $groupBy = [];
    protected $orderBy = [];
    protected $join = [];
    
    protected $limitStart = null;
    protected $limitEnd = null;
    protected $top = null;
    protected $forUpdate = false;

    /**
     * Example:
     *   $query->fields(['name', 'price']);
     * 
     * @param array $fields
     * @return $this
     */
    public function fields(array $fields)
    {
        $this->fields = array_merge($this->fields, $fields);
        
        return $this;
    }

    /**
     * Example
     *    $query->table('product');
     * 
     * @param string $table
     * @return $this
     */
    public function table($table) 
    {
        $this->table = $table;

        return $this;
    }

    /**
     * Example:
     *    $query->join('sales', 'product.id = sales.id');
     * 
     * @param string $table
     * @param string $filter
     * @return $this
     */
    public function join($table, $filter)
    {
        $this->join[] = [ 'table'=>$table, 'filter'=>$filter];
        return $this;
    }

    /**
     * Example:
     *    $query->filter('price > [[amount]]', [ 'amount' => 1000] );
     * 
     * @param string $filter
     * @param array $params
     * @return $this
     */
    public function where($filter, array $params = [])
    {
        $this->where[] = [ 'filter' => $filter, 'params' => $params  ];
        return $this;
    }

    /**
     * Example:
     *    $query->groupBy(['name']);
     * 
     * @param array $fields
     * @return $this
     */
    public function groupBy(array $fields)
    {
        $this->groupBy = array_merge($this->groupBy, $fields);
    
        return $this;
    }

    /**
     * Example:
     *     $query->orderBy(['price desc']);
     * 
     * @param array $fields
     * @return $this
     */
    public function orderBy(array $fields)
    {
        $this->orderBy = array_merge($this->orderBy, $fields);

        return $this;
    }

    public function limit($start, $end)
    {
        $this->limitStart = $start;
        $this->limitEnd = $end;
        return $this;
    }

    public function top($top)
    {
        $this->top = $top;

        return $this;
    }
    
    public function forUpdate()
    {
        $this->forUpdate = true;
        
        return $this;
    }
    
    protected function getFields()
    {
        if (empty($this->fields)) {
            return ' * ';
        }

        return ' ' . implode(', ', $this->fields) . ' ';
    }
    
    protected function getJoin()
    {
        $join = $this->table;
        foreach ($this->join as $item) {
            $join .= ' INNER JOIN ' . $item['table'] . ' ON ' . $item['filter'];
        }
        return $join;
    }
    
    protected function getWhere() 
    {
        $where = [];
        $params = [];

        foreach ($this->where as $item) {
            $where[] = $item['filter'];
            $params = array_merge($params, $item['params']);
        }
        
        if (empty($where)) {
            return null;
        }
        
        return [ implode(' AND ', $where), $params ];
    }

    /**
     * @return array
     */
    public function getSelect()
    {
        $sql = "SELECT " .
            $this->getFields() . 
            "FROM " . $this->getJoin();
        
        $where = $this->getWhere();
        $params = null;
        if (!is_null($where)) {
            $sql .= ' WHERE ' . $where[0];
            $params = $where[1];
        }
        
        if (!empty($this->groupBy)) {
            $sql .= ' GROUP BY ' . implode(', ', $this->groupBy);
        }

        if (!empty($this->orderBy)) {
            $sql .= ' ORDER BY ' . implode(', ', $this->orderBy);
        }
        
        if ($this->forUpdate) {
            $sql .= ' FOR UPDATE ';
        } 
        
        return [ 'sql' => $sql, 'params' => $params ];
    }

    /**
     * @return string
     * @throws \Exception
     */
    public function getInsert()
    {
        if (empty($this->fields)) {
            throw new \Exception('You must specifiy the fields for insert');
        }
        
        $sql = 'INSERT INTO '
            . $this->table
            . '( ' . implode(', ', $this->fields) . ' ) '
            . ' values '
            . '( [[' . implode(']], [[', $this->fields) . ']] ) ';
        
        return $sql;
    }

    /**
     * @return array
     * @throws \Exception
     */
    public function getUpdate()
    {
        if (empty($this->fields)) {
            throw new \Exception('You must specifiy the fields for insert');
        }
        
        $fields = [];
        foreach ($this->fields as $field) {
            $fields[] = "$field = [[$field]] ";
        }
        
        $where = $this->getWhere();
        if (is_null($where)) {
            throw new \Exception('You must specifiy a where clause');
        }

        $sql = 'UPDATE ' . $this->table . ' SET '
            . implode(', ', $fields)
            . ' WHERE ' . $where[0];

        return [ 'sql' => $sql, 'params' => $where[1] ];
    }

    /**
     * @return array
     * @throws \Exception
     */
    public function getDelete()
    {
        $where = $this->getWhere();
        if (is_null($where)) {
            throw new \Exception('You must specifiy a where clause');
        }

        $sql = 'DELETE FROM ' . $this->table
            . ' WHERE ' . $where[0];

        return [ 'sql' => $sql, 'params' => $where[1] ];
    }

}