<?php
class Database extends Generaldb{
    public static function connection(){
        mysql_connect("localhost", "root", "");
        mysql_select_db("united_bike");
    }
    
    private $column = "*";
    private $table;
    private $cond;
    private $order;
    private $group;
    private $limit;
    private $setColumnInsert;
    private $setColumnUpdate;
    private $setWhere = "";

    public static function build(){
        return new Database;
    }

    public function setTable($table){
        $this->table = $table;
        return $this;
    }
    
    public function setColumn($col){
        if(empty($col)){
            $this->column = "*";
        }else{
            $this->column = $col;
        }
        return $this;
    }

    public function setCond($cond = ''){
        if(empty($cond)){
            $where = "";
        }else{
            $where = "WHERE " . $cond;
        }
        $this->cond = $where;
        return $this;
    }
    
    public function setOrder($sort){
        if(empty($sort)){
            $sortby = "";
        }else{
            $sortby = "ORDER BY " . $sort;
        }
        $this->order = $sortby;
        return $this;
    }
    
    public function setGroupBy($group){
        if(empty($group)){
            $groupby = "";
        }else{
            $groupby = "GROUP BY " . $group;
        }
        $this->group = $groupby;
        return $this;
    }
    
    public function setLimit($limit = 0, $offset = 1){
        $this->limit = "LIMIT " . $limit . ", " . $offset. " ";
        return $this;
    }
    
    public function debugQuery() {
        $query = "SELECT " . $this->column . " FROM " . $this->table . " " . $this->cond . " " . $this->group . " " . $this->order . " " . $this->limit . " ";
        return $query;
    }

    public function executeArr(){
        $query = "SELECT " . $this->column . " FROM " . $this->table . " " . $this->cond . " " . $this->group . " " . $this->order . " " . $this->limit . " ";
    
        $arrData = array();
        $result = mysql_query($query);
        $i = 0;
        while($rowData = mysql_fetch_assoc($result)){
            foreach($rowData as $key=>$val){
               $arrData[$i][$key] = $val;
            }
         $i++;
        }
        return $arrData;
    }

    public function getSelect($sql){
        if(empty($sql)){
            echo "Please select query";
        }else{
            $arrData = array();
            $query = mysql_query($sql);
            $i = 0;
            while($rowData = mysql_fetch_assoc($query)){
                foreach($rowData as $key=>$val){
                    $arrData[$i][$key] = $val;
                }
                $i++;
            }
            return $arrData;
        }
    }
    
    public function getCount($table, $cond = ''){
        if(empty($table)){
            echo "Please select query";
        }else{
            $where = empty($cond)?'':' WHERE ' . $cond;
            $query = "SELECT COUNT(1) as TOTAL FROM " . $table . " " . $where . "";
            $result = mysql_query($query);
            $rowData = mysql_fetch_assoc($result);
            return $rowData['TOTAL'];
        }
    }
    
    public function setInsert($mapping, $post){
        //$this->setColumnInsert
        $column = "";
        $value  = "";
        foreach($mapping as $key => $val){
            $column     .= ',`'.$key.'`';
            if(strtolower($post[$val]) == "now()") {
                $value      .= ',' . $post[$val] . '';
            }else{
                $value      .= ',"' . $post[$val] . '"';
            }
        }
        $column = substr($column,1);
        $value  = substr($value,1);
        $this->setColumnInsert = "(" . $column . ") VALUE (" . $value . ")" ;
        return $this;        
    }
    
    public function insert($table){
        $sql    = "INSERT INTO " . $table . " " . $this->setColumnInsert . "";
        $result = mysql_query($sql);
        return mysql_insert_id();
    }
    
    public function setWhere($cond){
        $this->setWhere = !empty($cond) ? 'WHERE ' . $cond : '';
        return $this;
    }


    public function setUpdate($mapping, $post) {
        $setUpdate  = "";
        foreach($mapping as $key => $val){
            if(strtolower($post[$val]) == "now()") {
                $setUpdate      .= ','.$key.' = ' . $post[$val] . '';
            }else{
                $setUpdate      .= ','.$key.' = "' . $post[$val] . '"';
            }
        }
        $setUpdate  = substr($setUpdate,1);
        $this->setColumnUpdate = $setUpdate ;
        return $this;
    }
        
    public function update($table){
        $sql = "UPDATE " . $table. " SET " . $this->setColumnUpdate. " " . $this->setWhere . " ";
        $result = mysql_query($sql);
        return mysql_insert_id();
    }
    
    public function delete($table, $data){
        echo "delete";
    }
}