handler = DBConnector::getConnect(Env::getParam('db_settings'));
}
/**
* Выполняет запрос и возвращает сырой результат
*
* @param string $sql
* @return resource
*/
function exec($sql)
{
$time = microtime(true);
$res = mysqli_query($this->handler, $sql);
if (mysqli_errno($this->handler)) {
throw new MJException("Query Error:\n".$sql."\nError:\n".mysqli_error($this->handler), 1);
}
if (DEBUG_ENABLE) {
DBConnector::$queries[] = $sql.'; ('.round((microtime(true)-$time)*1000, 1).'ms)';
}
return $res;
}
/**
* Выполняет запрос и возвращает объект результата
*
* @param string $sql
* @return object
*/
function query($sql)
{
$res = $this->exec($sql);
switch (strtolower(substr($sql, 0, 6))) {
case 'select':
case '(selec':
return new ModelSelectResult($res);
case 'insert':
return new ModelInsertResult($this->handler);
default:
return new ModelChangeResult($this->handler);
}
}
/**
* Экранирует строку
*
* @param string $data - строка для экранирования
* @return string
*/
function escape($data)
{
return mysqli_real_escape_string($this->handler, $data);
}
//////////////////////////
function update($id, $data)
{
$sql = '';
foreach ($data as $key => $val) {
$sql .= $key."='".$this->escape($val)."', ";
}
return $this->query('UPDATE '.$this->table.' SET '.rtrim($sql, ', ').' WHERE '.$this->primary_key.'='.(int) $id);
}
function insert($data, $postfix = '')
{
$sql = '';
foreach ($data as $key => $val) {
$sql .= $key.'="'.$this->escape($val).'", ';
}
return $this->query('INSERT '.$this->table.' SET '.rtrim($sql, ', ').' '.$postfix);
}
function delete($id)
{
return $this->query('DELETE FROM '.$this->table.' WHERE '.$this->primary_key.'='.(int) $id);
}
function get($id)
{
return $this->query('SELECT * FROM '.$this->table.' WHERE '.$this->primary_key.'='.(int) $id);
}
function getList($limit = false, $sort = 'ASC')
{
return $this->query('SELECT * FROM '.$this->table.' ORDER BY '.$this->primary_key.' '.($sort == 'ASC' ? 'ASC' : 'DESC').($limit === false ? ' LIMIT '.(int) $limit : ''));
}
}
class ModelResult
{
function __call($name, $args)
{
throw new MJException('Call undeclared method "'.$name.'" in "'.get_class($this).'" class', -1);
}
}
class ModelSelectResult extends ModelResult
{
public $result;
function __construct($res)
{
$this->result = $res;
}
function fetch($class_name = false)
{
return $class_name ? mysqli_fetch_object($this->result, $class_name) : mysqli_fetch_object($this->result);
}
function fetchField($field, $default = false)
{
$row = $this->fetch();
return isset($row->$field) ? $row->$field : $default;
}
function fetchAll($key = false)
{
$array = array();
if ($key) {
while ($row = mysqli_fetch_object($this->result)) {
$array[$row->$key] = $row;
}
} else {
while ($row = mysqli_fetch_object($this->result)) {
$array[] = $row;
}
}
return $array;
}
function count()
{
return mysqli_num_rows($this->result);
}
function free()
{
mysqli_free_result($this->result);
}
function __destruct() {
$this->free();
}
}
class ModelChangeResult extends ModelResult
{
public $affected;
function __construct($resource)
{
$this->affected = mysqli_affected_rows($resource);
}
function count()
{
return $this->affected;
}
}
class ModelInsertResult extends ModelResult
{
public $id;
function __construct($resource)
{
$this->id = mysqli_insert_id($resource);
}
function getId()
{
return $this->id;
}
}
?>