{

/**

const MODE_STRICT = 1;

/**

const MODE_TRANSFORM = 2;

/**

protected $type_mode = self::MODE_TRANSFORM;

protected $server;

protected $user;

protected $password;

protected $port;

protected $socket;

/**

protected $database_name;

/**

protected $mysqli;

/**

private $original_query;

/**

private $query;

/**

private $queries = array();

/**

private $store_queries = true;

/**

public static function create($server, $username, $password, $port=null, $socket=null)

{

return new self($server, $username, $password, $port, $socket);

}

/**

public function setCharset($charset)

{

if (!$this->mysqli->set_charset($charset)) {

throw new Database_Mysql_Exception(__METHOD__ . ': ' . $this->mysqli->error);

}

return $this;

}

/**

public function getCharset()

{

return $this->mysqli->character_set_name();

}

/**

public function setDatabaseName($database_name)

{

if (!$database_name) {

throw new Database_Mysql_Exception(__METHOD__ . ': Не указано имя базы данных');

}

$this->database_name = $database_name;

if (!$this->mysqli->select_db($this->database_name)) {

throw new Database_Mysql_Exception(__METHOD__ . ': ' . $this->mysqli->error);

}

return $this;

}

/**

public function getDatabaseName()

{

return $this->database_name;

}

/**

public function setTypeMode($value)

{

if (!in_array($value, array(self::MODE_STRICT, self::MODE_TRANSFORM))) {

throw new Database_Mysql_Exception(__METHOD__ . ': Указан неизвестный тип режима');

}

$this->type_mode = $value;

return $this;

}

/**

public function setStoreQueries($value)

{

$this->store_queries = (bool) $value;

return $this;

}

/**

public function query()

{

if (!func_num_args()) {

return false;

}

$args = func_get_args();

$query = $this->original_query = array_shift($args);

$this->query = $this->parse($query, $args);

$result = $this->mysqli->query($this->query);

if ($this->store_queries) {

$this->queries[$this->query] = $this->original_query;

}

if ($result === false) {

throw new Database_Mysql_Exception(__METHOD__ . ': ' . $this->mysqli->error . '; SQL: ' . $this->query);

}

if (is_object($result) && $result instanceof mysqli_result) {

return new Database_Mysql_Statement($result);

}

return $result;

}

/**

public function queryArguments($query, array $arguments=array())

{

array_unshift($arguments, $query);

return call_user_func_array(array($this, 'query'), $arguments);

}

/**

public function prepare()

{

if (!func_num_args()) {

return false;

}

$args = func_get_args();

$query = array_shift($args);

return $this->parse($query, $args);

}

/**

public function getAffectedRows()

{

return $this->mysqli->affected_rows;

}

/**

public function getOriginalQueryString()

{

return $this->original_query;

}

/**

public function getQueryString()

{

return $this->query;

}

/**

public function getQueries()

{

return $this->queries;

}

/**

public function getLastInsertId()

{

return $this->mysqli->insert_id;

}

/**

public function getMysqli()

{

return $this->mysqli;

}

public function __destruct()

{

$this->close();

}

/**

private function __construct($server, $user, $password, $port, $socket)

{

$this->server = $server;

$this->user = $user;

$this->password = $password;

$this->port = $port;

$this->socket = $socket;

$this->connect();

}

/**

private function connect()

{

if (!is_object($this->mysqli) || !$this->mysqli instanceof mysqli) {

$this->mysqli = @new mysqli($this->server, $this->user, $this->password, null, $this->port, $this->socket);

if ($this->mysqli->connect_error) {

throw new Database_Mysql_Exception(__METHOD__ . ': ' . $this->mysqli->connect_error);

}

}

}

/**

private function close()

{

if (is_object($this->mysqli) && $this->mysqli instanceof mysqli) {

@$this->mysqli->close();

}

return $this;

}

/**

private function escapeLike($var, $chars = "%_")

{

$var = str_replace('\\', '\\\\', $var);

$var = $this->mysqlRealEscapeString($var);

if ($chars) {

$var = addCslashes($var, $chars);

}

return $var;

}

/**

private function mysqlRealEscapeString($value)

{

return $this->mysqli->real_escape_string($value);

}

/**

private function createErrorMessage($type, $value, $original_query)

{

return "Попытка указать для заполнителя типа $type значение типа " . gettype($value) . " в шаблоне запроса $original_query";

}

/**

private function parse($query, array $args, $original_query=null)

{

$original_query = $original_query ? $original_query : $query;

$offset = 0;

while (($posQM = mb_strpos($query, '?', $offset)) !== false) {

$offset = $posQM;

$placeholder_type = mb_substr($query, $posQM + 1, 1);

// Любые ситуации с нахождением знака вопроса, который не явялется заполнителем.

if ($placeholder_type == '' || !in_array($placeholder_type, array('i', 'd', 's', 'S', 'n', 'A', 'a', 'f'))) {

$offset += 1;

continue;

}

if (!$args) {

throw new Database_Mysql_Exception(

__METHOD__ . ': количество заполнителей в запросе ' . $original_query .

' не соответствует переданному количеству аргументов'

);

}

$value = array_shift($args);

switch ($placeholder_type) {

// `LIKE` search escaping

case 'S':

$is_like_escaping = true;

// Simple string escaping

// В случае установки MODE_TRANSFORM режима, преобразование происходит согласно правилам php типизации

// http://php.net/manual/ru/language.types.string.php#language.types.string.casting

// для bool, null и numeric типа.

case 's':

$value = $this->getValueStringType($value, $original_query);

$value = !empty($is_like_escaping) ? $this->escapeLike($value) : $this->mysqlRealEscapeString($value);

$query = mb_substr_replace($query, $value, $posQM, 2);

$offset += mb_strlen($value);

break;

// Integer

// В случае установки MODE_TRANSFORM режима, преобразование происходит согласно правилам php типизации

// http://php.net/manual/ru/language.types.integer.php#language.types.integer.casting

// для bool, null и string типа.

case 'i':

$value = $this->getValueIntType($value, $original_query);

$query = mb_substr_replace($query, $value, $posQM, 2);

$offset += mb_strlen($value);

break;

// Floating point

case 'd':

$value = $this->getValueFloatType($value, $original_query);

$query = mb_substr_replace($query, $value, $posQM, 2);

$offset += mb_strlen($value);

break;

// NULL insert

case 'n':

$value = $this->getValueNullType($value, $original_query);

$query = mb_substr_replace($query, $value, $posQM, 2);

$offset += mb_strlen($value);

break;

// field or table name

case 'f':

$value = $this->escapeFieldName($value, $original_query);

$query = mb_substr_replace($query, $value, $posQM, 2);

$offset += mb_strlen($value);

break;

// Парсинг массивов.

// Associative array

case 'A':

$is_associative_array = true;

// Simple array

case 'a':

$value = $this->getValueArrayType($value, $original_query);

$next_char = mb_substr($query, $posQM + 2, 1);

if ($next_char != '' && preg_match('#[sid\[]#u', $next_char, $matches)) {

// Парсим выражение вида ?a[?i, "?s", "?s"]

if ($next_char == '[' and ($close = mb_strpos($query, ']', $posQM+3)) !== false) {

// Выражение между скобками [ и ]

$array_parse = mb_substr($query, $posQM+3, $close - ($posQM+3));

$array_parse = trim($array_parse);

$placeholders = array_map('trim', explode(',', $array_parse));

if (count($value) != count($placeholders)) {

throw new Database_Mysql_Exception('Несовпадение количества аргументов и заполнителей в массиве, запрос ' . $original_query);

}

reset($value);

reset($placeholders);

$replacements = array();

foreach ($placeholders as $placeholder) {

list($key, $val) = each($value);

$replacements[$key] = $this->parse($placeholder, array($val), $original_query);

}

if (!empty($is_associative_array)) {

foreach ($replacements as $key => $val) {

$values[] = $this->escapeFieldName($key, $original_query) . ' = ' . $val;

}

$value = implode(',', $values);

} else {

$value = implode(', ', $replacements);

}

$query = mb_substr_replace($query, $value, $posQM, 4 + mb_strlen($array_parse));

$offset += mb_strlen($value);

}

// Выражение вида ?ai, ?as, ?ap

else if (preg_match('#[sid]#u', $next_char, $matches)) {

$sql = '';

$parts = array();

foreach ($value as $key => $val) {

switch ($matches[0]) {

case 's':

$val = $this->getValueStringType($val, $original_query);

$val = $this->mysqlRealEscapeString($val);

break;

case 'i':

$val = $this->getValueIntType($val, $original_query);

break;

case 'd':

$val = $this->getValueFloatType($val, $original_query);

break;

}

if (!empty($is_associative_array)) {

$parts[] = $this->escapeFieldName($key, $original_query) . ' = "' . $val . '"';

} else {

$parts[] = '"' . $val . '"';

}

}

$value = implode(', ', $parts);

$value = $value !== '' ? $value : 'NULL';

$query = mb_substr_replace($query, $value, $posQM, 3);

$offset += mb_strlen($value);

}

} else {

throw new Database_Mysql_Exception('Попытка воспользоваться заполнителем массива без указания типа данных его элементов');

}

break;

}

}

return $query;

}

/**

private function getValueStringType($value, $original_query)

{

if (!is_string($value) && $this->type_mode == self::MODE_STRICT) {

// Если это числовой string, меняем его тип для вывода в тексте исключения его типа.

if ($this->isInteger($value) || $this->isFloat($value)) {

$value += 0;

}

throw new Database_Mysql_Exception($this->createErrorMessage('string', $value, $original_query));

}

// меняем поведение PHP в отношении приведения bool к string

if (is_bool($value)) {

return (string) (int) $value;

}

if (!is_string($value) && !(is_numeric($value) || is_null($value))) {

throw new Database_Mysql_Exception($this->createErrorMessage('string', $value, $original_query));

}

return (string) $value;

}

/**

private function getValueIntType($value, $original_query)

{

if ($this->isInteger($value)) {

return $value;

}

switch ($this->type_mode) {

case self::MODE_TRANSFORM:

if ($this->isFloat($value) || is_null($value) || is_bool($value)) {

return (int) $value;

}

case self::MODE_STRICT:

// Если это числовой string, меняем его тип для вывода в тексте исключения его типа.

if ($this->isFloat($value)) {

$value += 0;

}

throw new Database_Mysql_Exception($this->createErrorMessage('integer', $value, $original_query));

}

}

/**

private function getValueFloatType($value, $original_query)

{

if ($this->isFloat($value)) {

return $value;

}

switch ($this->type_mode) {

case self::MODE_TRANSFORM:

if ($this->isInteger($value) || is_null($value) || is_bool($value)) {

return (float) $value;

}

case self::MODE_STRICT:

// Если это числовой string, меняем его тип на int для вывода в тексте исключения.

if ($this->isInteger($value)) {

$value += 0;

}

throw new Database_Mysql_Exception($this->createErrorMessage('double', $value, $original_query));

}

}

/**

private function getValueNullType($value, $original_query)

{

if ($value !== null && $this->type_mode == self::MODE_STRICT) {

// Если это числовой string, меняем его тип для вывода в тексте исключения его типа.

if ($this->isInteger($value) || $this->isFloat($value)) {

$value += 0;

}

throw new Database_Mysql_Exception($this->createErrorMessage('NULL', $value, $original_query));

}

return 'NULL';

}

/**

private function getValueArrayType($value, $original_query)

{

if (!is_array($value)) {

throw new Database_Mysql_Exception($this->createErrorMessage('array', $value, $original_query));

}

return $value;

}

/**

private function escapeFieldName($value, $original_query)

{

if (!is_string($value)) {

throw new Database_Mysql_Exception($this->createErrorMessage('field', $value, $original_query));

}

$new_value = '';

$replace = function($value){

return '`' . str_replace("`", "``", $value) . '`';

};

// Признак обнаружения символа текущей базы данных

$dot = false;

if ($values = explode('.', $value)) {

foreach ($values as $value) {

if ($value === '') {

if (!$dot) {

$dot = true;

$new_value .= '.';

} else {

throw new Database_Mysql_Exception('Два символа `.` идущие подряд в имени столбца или таблицы');

}

} else {

$new_value .= $replace($value) . '.';

}

}

return rtrim($new_value, '.');

} else {

return $replace($value);

}

}

/**

private function isInteger($val)

{

if (!is_scalar($val) || is_bool($val)) {

return false;

}

if (is_float($val + 0) && ($val + 0) > PHP_INT_MAX) {

return false;

}

return is_float($val) ? false : preg_match('~^((?:\+|-)?[0-9]+)$~', $val);

}

/**

private function isFloat($val)

{

if (!is_scalar($val)) {

return false;

}

return is_float($val + 0);

}