Класс обертки Mysqli by Koenig (Допилить)

# ValekS (17.08.2013 / 18:51)
Так. Что то я начитался, что теперь вообще ничего не понимаю. Гг
MySQLi можно использовать с БД Джона? Т.Е. если я буду делать запросы через mysqli функции - mysqli_query() и т.д. - это прокатит? Теп

# Saniok (17.08.2013 / 18:58)
Джон, не будет работать если подключить только один этот класс, нужно будет переделывать под него, так как он написан на чистом мускуле. А классы используют для упрощения работы.

# ValekS (17.08.2013 / 18:51)
Так. Что то я начитался, что теперь вообще ничего не понимаю. Гг
MySQLi можно использовать с БД Джона? Т.Е. если я буду делать запросы через mysqli функции - mysqli_query() и т.д. - это прокатит? Теп

/**
* KoeNysqli
* 
* Обертка для Mysqli
* 
* @author Koenig <http://johncms.com/users/profile.php?user=6565>
* @version 1.0
*/

class KoeMysql extends Mysqli
{
   /**
   * limit
   * 
   * @var integer or array 
   */    
  private $limit = false;
   /**
   * условия
   * 
   * @var array
   */
  private $where = array(); 
   /**
   * условия сортировки
   * 
   * @var array 
   */
  private $sort = false;
   /**
   * конструктор
   * 
   * @param string $db_host
   * @param string $db_user
   * @param string $db_pass
   * @param string $db_name
   * @param string $db_charset
   * @param integer $port
   * @return resource
   */
  public function __construct($db_host, $db_user, $db_pass, $db_name, $db_charset, $port = 3306)
  {
    @parent::__construct($db_host, $db_user, $db_pass, $db_name, $port);
    @$this->set_charset($db_charset);
    if ($this->connect_errno) die($this->connect_error);
  }
  /**
  * stmt count params => ?
  * 
  * @return integer
  */
  public function count_params()
  {
    return $this->stmt ? $this->stmt->param_count : die('stmt not started');
  }
  /**
  * stmt count fields in result
  * 
  * @param void
  * @return integer
  */
  public function count_fields()
  {
    return $this->stmt ? $this->stmt->field_count : die('stmt not started');
  }
  /**
  * return yes/no fetch result
  * 
  * @param void
  * @return boolean
  */
  public function is_fetch()
  {
    if ($this->stmt) {
      return preg_match('/select/i', $this->sql) ? true : false;
    }
    else {
      die('Query not execute');
    }
  }
  /**
  * sql query
  * 
  * @param string $sql
  * @param array $placeholders
  * @return result array|integer|string error
  */
  public function sql($sql, $placeholders = null)
  {
    $this->sql = $sql . $this->get_where() . $this->get_sort() . $this->get_limit();
    if (!$this->stmt = $this->prepare($this->sql)) {
      die('error sql <<< ' . $this->sql . ' >>>');
    }
    if ($this->count_params() && $placeholders) {
      if (!$this->set_placeholders($placeholders)) {
        die('Placeholders failed');
      }
    }
    if (!$this->is_fetch()) {
      $this->stmt->execute();
      return $this->stmt->affected_rows;
    }
    else {
      $this->stmt->execute();
      if (!$this->bind_result()) {
        die('Bind result failed');
      }
    }
    $this->limit = false;
    $this->sort = false;
    $this->where = array();
    return $this->fetch_result();
  }
  /**
  * autofetch
  * 
  * @param void
  * @return array|integer|boolean
  */
  public function fetch_result()
  {
    if (!$this->stmt->num_rows) {
      $return = false;
    }
    if ($this->count_fields() == 1) {
      $res = $this->stmt->get_result();
      $row = $res->fetch_row();
      $return = $row[0];
    }
    else {
      $return = array();
      $res = $this->stmt->get_result();
      while ($row = $res->fetch_assoc()) {
        array_push($return, $row);
      }
    }
    return $return;
  }
  /**
  * bind result for placeholders
  * @param void
  * @return mysqli_stmt
  */
  public function bind_result()
  {
    $result = array();
    $binds = array();
    $meta = $this->stmt->result_metadata();
    while ($field = $meta->fetch_field()) {
      $binds[] = & $row[$field->name];
    }
    if (!call_user_func_array(array(
      $this->stmt,
      'bind_result'
    ) , $binds)) {
      die('Not bind result');
    }
    return $this->stmt;
  }
  /**
  * set placeholders
  * 
  * @param array $args
  * @return mysqli_stmt
  */
  public function set_placeholders($args)
  {
    if (!is_array($args)) {
      $args = array(
        $args
      );
    }
    $types = '';
    $newarray = array();
    for ($i = 0; $i < sizeof($args); $i++) {
      $types.= is_numeric($args[$i]) ? 'i' : ((is_double($args[$i]) || is_float($args[$i])) ? 'd' : 's');
      $newarray[] = $args[$i];
    }
    $args = array();
    $args[] = $types;
    foreach($newarray as $k => $v) {
      $args[] = & $newarray[$k];
    }
    if (!call_user_func_array(array(
      $this->stmt,
      'bind_param'
    ) , $args)) {
      die('Not bind params');
    }
    return $this->stmt;
  }
  /**
  * add where
  * 
  * @param string $field
  * @param string $type
  * @param string $value
  */
  public function set_where($field, $type, $value)
  {
    $types = array(
      '=',
      '!=',
      '>',
      '<',
      '<=',
      '>='
    );
    if (!in_array($type, $types)) {
      die('invalid argument');
    }
    $this->where[] = '`' . $field . '`' . $type . (is_int($value) ? $value : ($value == '?' ? $value : "'" . $value . "'"));
  }
  /**
  * set limits
  * 
  * @param array or integer $args
  * @return string @limit 
  */
  public function set_limit($args)
  {
    if (is_array($args) && sizeof($args) == 2) {
      $str = ' LIMIT ' . implode(' ,', array_values($args));
    }
    elseif (is_int($args)) {
      $str = ' LIMIT ' . $args;
    }
    else {
      die('Number of arguments 1 (string) or 2 (array)');
    }
    return $this->limit = $str;
  }
  /**
  * set sort params
  * 
  * @param array $args
  * @return string @sort 
  */
  public function set_sort($args)
  {
    if (is_array($args) && sizeof($args) > 0) {
      $str = ' order by ';
      $x = 1;
      $i = sizeof($args);
      foreach($args as $k => $v) {
        $typesort = $v == 'a' ? 'asc' : 'desc';
        $str.= $k . ' ' . $typesort;
        if ($x != $i) {
          $str.= ', ';
        }
        else {
          $str.= ' ';
        }
        $x++;
      }
    }
    return $this->sort = $str;
  }
  /**
  * get sort
  * 
  * @param void
  * @return string @sort
  */
  public function get_sort()
  {
    return $this->sort;
  }
  /**
  * get limit
  * 
  * @param void
  * @return string @limit
  */  
  public function get_limit()
  {
    return $this->limit;
  }
  /**
  * get where
  * 
  * @param void
  * @return string @where
  */  
  public function get_where()
  {
    return sizeof($this->where) > 0 ? ' WHERE ' .  implode(' AND ', array_values($this->where)) : '';
  }

}

$db_host = 'localhost'; 
$db_user = 'root'; 
$db_pass = ''; 
$db_name = 'test'; 
$db_charset = 'utf-8'; 

$mysqli = new KoeMysql($db_host, $db_user, $db_pass, $db_name, $db_charset);

$sql = "insert into `table` (`name`, `pass`, `time`, `pid`) values (?, ?, ?, ?)";  
$array = array('test', 'qwerty', time(), 213); 
$res = $mysqli->sql($sql, $array);
echo $mysqli->sql;
echo '<pre>'; print_r($res); 
 

$sql = "select * from `table`"; 
$mysqli->set_where('pid', '=', '?');
$mysqli->set_where('name', '=', '?');
$mysqli->set_limit(array(2, 2));
#$mysqli->set_limit(5);
$mysqli->set_sort(array('id' => 'd', 'time' => 'a'));
$placeholders = array(213, 'test');
$res = $mysqli->sql($sql, $placeholders); 
#echo '<pre>'; print_r($mysqli); 
echo '<pre>'; print_r($res); 
#echo $mysqli->sql . '<hr/>';      

$sql = "delete from `table` where `id` < ?";  
$placeholders = 100;
$res = $mysqli->sql($sql, $placeholders); 
#echo '<pre>'; print_r($mysqli); 
echo '<pre>'; print_r($res); 
#echo $mysqli->sql . '<hr/>';

$sql = 'select count(*) from `table`';
$res = $mysqli->sql($sql);
#echo '<pre>'; print_r($mysqli); 
echo '<pre>'; print_r($res); 
#echo $mysqli->sql . '<hr/>';

->where('column_name' = value) // column_name = value
->where('column_name__lte' = value) // column_name <= value
->where('column_name__gt' = value) // column_name > value