{

/**

protected static $_instance;

/**

public static $prefix = '';

/**

protected $_mysqli = array();

/**

protected $_query;

/**

protected $_lastQuery;

/**

protected $_queryOptions = array();

/**

protected $_join = array();

/**

protected $_where = array();

/**

protected $_joinAnd = array();

/**

protected $_having = array();

/**

protected $_orderBy = array();

/**

protected $_groupBy = array();

/**

protected $_tableLocks = array();

/**

protected $_tableLockMethod = "READ";

/**

protected $_bindParams = array(''); // Create the empty 0 index

/**

public $count = 0;

/**

public $totalCount = 0;

/**

protected $_stmtError;

/**

protected $_stmtErrno;

/**

protected $isSubQuery = false;

/**

protected $_lastInsertId = null;

/**

protected $_updateColumns = null;

/**

public $returnType = 'array';

/**

protected $_nestJoin = false;

/**

private $_tableName = '';

/**

protected $_forUpdate = false;

/**

protected $_lockInShareMode = false;

/**

protected $_mapKey = null;

/**

protected $traceStartQ = 0;

protected $traceEnabled = false;

protected $traceStripPrefix = '';

public $trace = array();

/**

public $pageLimit = 20;

/**

public $totalPages = 0;

/**

protected $connectionsSettings = array();

/**

public $defConnectionName = 'default';

public $autoReconnect = true;

protected $autoReconnectCount = 0;

/**

protected $_transaction_in_progress = false;

/**

public function __construct($host = null, $username = null, $password = null, $db = null, $port = null, $charset = 'utf8', $socket = null)

{

$isSubQuery = false;

// if params were passed as array

if (is_array($host)) {

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

$$key = $val;

}

}

$this->addConnection('default', array(

'host' => $host,

'username' => $username,

'password' => $password,

'db' => $db,

'port' => $port,

'socket' => $socket,

'charset' => $charset

));

if ($isSubQuery) {

$this->isSubQuery = true;

return;

}

if (isset($prefix)) {

$this->setPrefix($prefix);

}

self::$_instance = $this;

}

/**

public function connect($connectionName = 'default')

{

if(!isset($this->connectionsSettings[$connectionName]))

throw new Exception('Connection profile not set');

$pro = $this->connectionsSettings[$connectionName];

$params = array_values($pro);

$charset = array_pop($params);

if ($this->isSubQuery) {

return;

}

if (empty($pro['host']) && empty($pro['socket'])) {

throw new Exception('MySQL host or socket is not set');

}

$mysqlic = new ReflectionClass('mysqli');

$mysqli = $mysqlic->newInstanceArgs($params);

if ($mysqli->connect_error) {

throw new Exception('Connect Error ' . $mysqli->connect_errno . ': ' . $mysqli->connect_error, $mysqli->connect_errno);

}

if (!empty($charset)) {

$mysqli->set_charset($charset);

}

$this->_mysqli[$connectionName] = $mysqli;

}

/**

public function disconnectAll()

{

foreach (array_keys($this->_mysqli) as $k) {

$this->disconnect($k);

}

}

/**

public function connection($name)

{

if (!isset($this->connectionsSettings[$name]))

throw new Exception('Connection ' . $name . ' was not added.');

$this->defConnectionName = $name;

return $this;

}

/**

public function disconnect($connection = 'default')

{

if (!isset($this->_mysqli[$connection]))

return;

$this->_mysqli[$connection]->close();

unset($this->_mysqli[$connection]);

}

/**

public function addConnection($name, array $params)

{

$this->connectionsSettings[$name] = array();

foreach (array('host', 'username', 'password', 'db', 'port', 'socket', 'charset') as $k) {

$prm = isset($params[$k]) ? $params[$k] : null;

if ($k == 'host') {

if (is_object($prm))

$this->_mysqli[$name] = $prm;

if (!is_string($prm))

$prm = null;

}

$this->connectionsSettings[$name][$k] = $prm;

}

return $this;

}

/**

public function mysqli()

{

if (!isset($this->_mysqli[$this->defConnectionName])) {

$this->connect($this->defConnectionName);

}

return $this->_mysqli[$this->defConnectionName];

}

/**

public static function getInstance()

{

return self::$_instance;

}

/**

protected function reset()

{

if ($this->traceEnabled) {

$this->trace[] = array($this->_lastQuery, (microtime(true) - $this->traceStartQ), $this->_traceGetCaller());

}

$this->_where = array();

$this->_having = array();

$this->_join = array();

$this->_joinAnd = array();

$this->_orderBy = array();

$this->_groupBy = array();

$this->_bindParams = array(''); // Create the empty 0 index

$this->_query = null;

$this->_queryOptions = array();

$this->returnType = 'array';

$this->_nestJoin = false;

$this->_forUpdate = false;

$this->_lockInShareMode = false;

$this->_tableName = '';

$this->_lastInsertId = null;

$this->_updateColumns = null;

$this->_mapKey = null;

if(!$this->_transaction_in_progress ) {

$this->defConnectionName = 'default';

}

$this->autoReconnectCount = 0;

return $this;

}

/**

public function jsonBuilder()

{

$this->returnType = 'json';

return $this;

}

/**

public function arrayBuilder()

{

$this->returnType = 'array';

return $this;

}

/**

public function objectBuilder()

{

$this->returnType = 'object';

return $this;

}

/**

public function setPrefix($prefix = '')

{

self::$prefix = $prefix;

return $this;

}

/**

private function queryUnprepared($query)

{

// Execute query

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

// Failed?

if ($stmt !== false)

return $stmt;

if ($this->mysqli()->errno === 2006 && $this->autoReconnect === true && $this->autoReconnectCount === 0) {

$this->connect($this->defConnectionName);

$this->autoReconnectCount++;

return $this->queryUnprepared($query);

}

throw new Exception(sprintf('Unprepared Query Failed, ERRNO: %u (%s)', $this->mysqli()->errno, $this->mysqli()->error), $this->mysqli()->errno);

}

/**

public function rawAddPrefix($query){

$query = str_replace(PHP_EOL, '', $query);

$query = preg_replace('/\s+/', ' ', $query);

$query = preg_replace("/(from|into|update|join|describe) [\\'\\´\\`]?([a-zA-Z0-9_-]+)[\\'\\´\\`]?/i", "\$1 `" . self::$prefix . "\$2`", $query);

return $query;

}

/**

public function rawQuery($query, $bindParams = null)

{

$query = $this->rawAddPrefix($query);

$params = array(''); // Create the empty 0 index

$this->_query = $query;

$stmt = $this->_prepareQuery();

if (is_array($bindParams) === true) {

foreach ($bindParams as $prop => $val) {

$params[0] .= $this->_determineType($val);

array_push($params, $bindParams[$prop]);

}

call_user_func_array(array($stmt, 'bind_param'), $this->refValues($params));

}

$stmt->execute();

$this->count = $stmt->affected_rows;

$this->_stmtError = $stmt->error;

$this->_stmtErrno = $stmt->errno;

$this->_lastQuery = $this->replacePlaceHolders($this->_query, $params);

$res = $this->_dynamicBindResults($stmt);

$this->reset();

return $res;

}

/**

public function rawQueryOne($query, $bindParams = null)

{

$res = $this->rawQuery($query, $bindParams);

if (is_array($res) && isset($res[0])) {

return $res[0];

}

return null;

}

/**

public function rawQueryValue($query, $bindParams = null)

{

$res = $this->rawQuery($query, $bindParams);

if (!$res) {

return null;

}

$limit = preg_match('/limit\s+1;?$/i', $query);

$key = key($res[0]);

if (isset($res[0][$key]) && $limit == true) {

return $res[0][$key];

}

$newRes = Array();

for ($i = 0; $i < $this->count; $i++) {

$newRes[] = $res[$i][$key];

}

return $newRes;

}

/**

public function query($query, $numRows = null)

{

$this->_query = $query;

$stmt = $this->_buildQuery($numRows);

$stmt->execute();

$this->_stmtError = $stmt->error;

$this->_stmtErrno = $stmt->errno;

$res = $this->_dynamicBindResults($stmt);

$this->reset();

return $res;

}

/**

public function setQueryOption($options)

{

$allowedOptions = Array('ALL', 'DISTINCT', 'DISTINCTROW', 'HIGH_PRIORITY', 'STRAIGHT_JOIN', 'SQL_SMALL_RESULT',

'SQL_BIG_RESULT', 'SQL_BUFFER_RESULT', 'SQL_CACHE', 'SQL_NO_CACHE', 'SQL_CALC_FOUND_ROWS',

'LOW_PRIORITY', 'IGNORE', 'QUICK', 'MYSQLI_NESTJOIN', 'FOR UPDATE', 'LOCK IN SHARE MODE');

if (!is_array($options)) {

$options = Array($options);

}

foreach ($options as $option) {

$option = strtoupper($option);

if (!in_array($option, $allowedOptions)) {

throw new Exception('Wrong query option: ' . $option);

}

if ($option == 'MYSQLI_NESTJOIN') {

$this->_nestJoin = true;

} elseif ($option == 'FOR UPDATE') {

$this->_forUpdate = true;

} elseif ($option == 'LOCK IN SHARE MODE') {

$this->_lockInShareMode = true;

} else {

$this->_queryOptions[] = $option;

}

}

return $this;

}

/**

public function withTotalCount()

{

$this->setQueryOption('SQL_CALC_FOUND_ROWS');

return $this;

}

/**

public function get($tableName, $numRows = null, $columns = '*')

{

if (empty($columns)) {

$columns = '*';

}

$column = is_array($columns) ? implode(', ', $columns) : $columns;

if (strpos($tableName, '.') === false) {

$this->_tableName = self::$prefix . $tableName;

} else {

$this->_tableName = $tableName;

}

$this->_query = 'SELECT ' . implode(' ', $this->_queryOptions) . ' ' .

$column . " FROM " . $this->_tableName;

$stmt = $this->_buildQuery($numRows);

if ($this->isSubQuery) {

return $this;

}

$stmt->execute();

$this->_stmtError = $stmt->error;

$this->_stmtErrno = $stmt->errno;

$res = $this->_dynamicBindResults($stmt);

$this->reset();

return $res;

}

/**

public function getOne($tableName, $columns = '*')

{

$res = $this->get($tableName, 1, $columns);

if ($res instanceof MysqliDb) {

return $res;

} elseif (is_array($res) && isset($res[0])) {

return $res[0];

} elseif ($res) {

return $res;

}

return null;

}

/**

public function getValue($tableName, $column, $limit = 1)

{

$res = $this->ArrayBuilder()->get($tableName, $limit, "{$column} AS retval");

if (!$res) {

return null;

}

if ($limit == 1) {

if (isset($res[0]["retval"])) {

return $res[0]["retval"];

}

return null;

}

$newRes = Array();

for ($i = 0; $i < $this->count; $i++) {

$newRes[] = $res[$i]['retval'];

}

return $newRes;

}

/**

public function insert($tableName, $insertData)

{

return $this->_buildInsert($tableName, $insertData, 'INSERT');

}

/**

public function insertMulti($tableName, array $multiInsertData,?array $dataKeys = null)

{

// only auto-commit our inserts, if no transaction is currently running

$autoCommit = (isset($this->_transaction_in_progress) ? !$this->_transaction_in_progress : true);

$ids = array();

if($autoCommit) {

$this->startTransaction();

}

foreach ($multiInsertData as $insertData) {

if($dataKeys !== null) {

// apply column-names if given, else assume they're already given in the data

$insertData = array_combine($dataKeys, $insertData);

}

$id = $this->insert($tableName, $insertData);

if(!$id) {

if($autoCommit) {

$this->rollback();

}

return false;

}

$ids[] = $id;

}

if($autoCommit) {

$this->commit();

}

return $ids;

}

/**

public function replace($tableName, $insertData)

{

return $this->_buildInsert($tableName, $insertData, 'REPLACE');

}

/**

public function has($tableName)

{

$this->getOne($tableName, '1');

return $this->count >= 1;

}

/**

public function update($tableName, $tableData, $numRows = null)

{

if ($this->isSubQuery) {

return;

}

$this->_query = "UPDATE " . self::$prefix . $tableName;

$stmt = $this->_buildQuery($numRows, $tableData);

$status = $stmt->execute();

$this->reset();

$this->_stmtError = $stmt->error;

$this->_stmtErrno = $stmt->errno;

$this->count = $stmt->affected_rows;

return $status;

}

/**

public function delete($tableName, $numRows = null)

{

if ($this->isSubQuery) {

throw new Exception('Delete function cannot be used within a subquery context.');

}

$table = self::$prefix . $tableName;

if (count($this->_join)) {

$this->_query = "DELETE " . preg_replace('/.* (.*)/', '$1', $table) . " FROM " . $table;

} else {

$this->_query = "DELETE FROM " . $table;

}

$stmt = $this->_buildQuery($numRows);

// Error handling

if (!$stmt->execute()) {

throw new Exception('Failed to execute delete operation: ' . $this->_stmtError);

}

$this->_stmtError = $stmt->error;

$this->_stmtErrno = $stmt->errno;

$this->count = $stmt->affected_rows;

$this->reset();

return ($stmt->affected_rows >= 0); // anything greater than -1 indicates success

}

/**

public function where($whereProp, $whereValue = 'DBNULL', $operator = '=', $cond = 'AND')

{

if (count($this->_where) == 0) {

$cond = '';

}

$this->_where[] = array($cond, $whereProp, $operator, $whereValue);

return $this;

}

/**