Query.php

Go to the documentation of this file.

<?php

namespace Rsi\Object;

/**
 *  Simple query builder.
 */
class Query extends \Rsi\Thing{

  protected $_select = [];
  protected $_tables = [];
  protected $_where = [];
  protected $_group = [];
  protected $_having = [];
  protected $_order = [];
  protected $_limit = null;
  protected $_offset = null;
  protected $_args = [];

  public function __construct($table){
    $this->_tables[] = $table;
  }

  public function select($column){
    $this->_select[] = $column;
    return $this;
  }

  public function join($join,$outer = false){
    $this->_tables[] = ($outer ? 'left ' : '') . 'join ' . $join;
    return $this;
  }

  public function where($condition){
    $this->_where[] = is_array($condition) ? '(' . implode(' or ',$condition) . ')' : $condition;
    return $this;
  }

  public function group($group){
    $this->_group[] = $group;
    return $this;
  }

  public function having($condition){
    $this->_having[] = $condition;
    return $this;
  }

  public function order($order){
    $this->_order[] = $order;
    return $this;
  }

  public function limit($limit,$offset = 0){
    $this->_limit = $limit;
    $this->_offset = $offset;
    return $this;
  }

  public function arg($key,$value){
    $this->_args[$key] = $value;
    return $this;
  }

  public function args($values = null){
    $this->_args = array_merge($this->_args,$values);
    return $this;
  }

  protected function getArgs(){
    return $this->_args;
  }

  protected function setArgs($value){
    $this->args($value);
  }

  protected function getSql(){
    return
      'select ' . ($this->_select ? implode(',',$this->_select) : '*') .
      "\nfrom " . implode("\n  ",$this->_tables) .
      ($this->_where ? "\nwhere " . implode("\n  and ",$this->_where) : '') .
      ($this->_group ? "\ngroup by " . implode(',',$this->_group) : '') .
      ($this->_having ? "\nhaving " . implode(' and ',$this->_having) : '') .
      ($this->_order ? "\norder by " . implode(',',$this->_order) : '') .
      ($this->_limit ? "\nlimit {$this->_offset},{$this->_limit}" : '');
  }

  protected function _set($key,$value){
    $this->arg($key,$value);
  }

  protected function _get($key){
    return \Rsi\Record::get($this->_args,$key,false);
  }

  public function __toString(){
    return $this->getSql();
  }

}