* @copyright 2007-2011 PrestaShop SA
* @version Release: $Revision: 6626 $
* @license http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0)
* International Registered Trademark & Property of PrestaShop SA
*/
//
// IMPORTANT : don't forget to delete the underscore _ in the file name if you want to use it !
//
class MySQL extends MySQLCore
{
public $count = 0;
public $queries = array();
public $queriesTime = array();
public $tables = array();
public $countTypes = array('getRow' => 0, 'getValue' => 0, 'Execute' => 0, 'ExecuteS' => 0, 'delete' => 0, 'q' => 0);
private function disableCache($query)
{
return preg_replace('/^select /', 'SELECT SQL_NO_CACHE', trim($query));
}
public function getRow($query, $use_cache = 1)
{
$this->count++;
$this->countTypes['getRow']++;
$query2 = preg_replace('/[0-9]+/', 'XX', $query);
if (!isset($this->queries[$query2]))
$this->queries[$query2] = 0;
$this->queries[$query2]++;
preg_match_all('/(from|join)\s+`?'.preg_replace('/[0-9]+/', 'XX', _DB_PREFIX_).'([a-z0-9_-]+)/ui', $query2, $matches);
foreach ($matches[2] as $table)
{
if (!isset($this->tables[$table]))
$this->tables[$table] = 0;
$this->tables[$table]++;
}
$query = $this->disableCache($query);
$t0 = microtime(true);
$return = parent::getRow($query, $use_cache);
if (!isset($this->queriesTime[$query]))
$this->queriesTime[$query] = microtime(true)-$t0;
return $return;
}
public function getValue($query, $use_cache = 1)
{
$this->count++;
$this->countTypes['getValue']++;
$query2 = preg_replace('/[0-9]+/', 'XX', $query);
if (!isset($this->queries[$query2]))
$this->queries[$query2] = 0;
$this->queries[$query2]++;
preg_match_all('/(from|join)\s+`?'.preg_replace('/[0-9]+/', 'XX', _DB_PREFIX_).'([a-z0-9_-]+)/ui', $query2, $matches);
foreach ($matches[2] as $table)
{
if (!isset($this->tables[$table]))
$this->tables[$table] = 0;
$this->tables[$table]++;
}
$query = $this->disableCache($query);
$t0 = microtime(true);
$return = parent::getValue($query, $use_cache);
if (!isset($this->queriesTime[$query]))
$this->queriesTime[$query] = microtime(true)-$t0;
return $return;
}
public function Execute($query, $use_cache = 1)
{
$this->count++;
$this->countTypes['Execute']++;
$query2 = preg_replace('/[0-9]+/', 'XX', $query);
if (!isset($this->queries[$query2]))
$this->queries[$query2] = 0;
$this->queries[$query2]++;
preg_match_all('/(from|join)\s+`?'.preg_replace('/[0-9]+/', 'XX', _DB_PREFIX_).'([a-z0-9_-]+)/ui', $query2, $matches);
foreach ($matches[2] as $table)
{
if (!isset($this->tables[$table]))
$this->tables[$table] = 0;
$this->tables[$table]++;
}
$query = $this->disableCache($query);
$t0 = microtime(true);
$return = parent::Execute($query, $use_cache);
if (!isset($this->queriesTime[$query]))
$this->queriesTime[$query] = microtime(true)-$t0;
return $return;
}
public function ExecuteS($query, $array = true, $use_cache = 1)
{
$this->count++;
$this->countTypes['ExecuteS']++;
$query2 = preg_replace('/[0-9]+/', 'XX', $query);
if (!isset($this->queries[$query2]))
$this->queries[$query2] = 0;
$this->queries[$query2]++;
preg_match_all('/(from|join)\s+`?'.preg_replace('/[0-9]+/', 'XX', _DB_PREFIX_).'([a-z0-9_-]+)/ui', $query2, $matches);
foreach ($matches[2] as $table)
{
if (!isset($this->tables[$table]))
$this->tables[$table] = 0;
$this->tables[$table]++;
}
$query = $this->disableCache($query);
$t0 = microtime(true);
$return = parent::ExecuteS($query, $array, $use_cache);
if (!isset($this->queriesTime[$query]))
$this->queriesTime[$query] = microtime(true)-$t0;
return $return;
}
public function delete($table, $where = false, $limit = false, $use_cache = 1)
{
$this->_result = false;
if ($this->_link)
{
$query = 'DELETE FROM `'.pSQL($table).'`'.($where ? ' WHERE '.$where : '').($limit ? ' LIMIT '.(int)($limit) : '');
$this->count++;
$this->countTypes['delete']++;
$query2 = preg_replace('/[0-9]+/', 'XX', $query);
if (!isset($this->queries[$query2]))
$this->queries[$query2] = 0;
$this->queries[$query2]++;
preg_match_all('/(from|join)\s+`?'.preg_replace('/[0-9]+/', 'XX', _DB_PREFIX_).'([a-z0-9_-]+)/ui', $query2, $matches);
foreach ($matches[2] as $table)
{
if (!isset($this->tables[$table]))
$this->tables[$table] = 0;
$this->tables[$table]++;
}
$query = $this->disableCache($query);
$t0 = microtime(true);
$return = parent::delete($table, $where, $limit, $use_cache);
if (!isset($this->queriesTime[$query]))
$this->queriesTime[$query] = microtime(true)-$t0;
return $return;
}
return false;
}
protected function q($query, $use_cache = 1)
{
$this->count++;
$this->countTypes['q']++;
$query2 = preg_replace('/[0-9]+/', 'XX', $query);
if (!isset($this->queries[$query2]))
$this->queries[$query2] = 0;
$this->queries[$query2]++;
preg_match_all('/(from|join)\s+`?'.preg_replace('/[0-9]+/', 'XX', _DB_PREFIX_).'([a-z0-9_-]+)/ui', $query2, $matches);
foreach ($matches[2] as $table)
{
if (!isset($this->tables[$table]))
$this->tables[$table] = 0;
$this->tables[$table]++;
}
$query = $this->disableCache($query);
$t0 = microtime(true);
$return = parent::q($query, $use_cache);
if (!isset($this->queriesTime[$query]))
$this->queriesTime[$query] = microtime(true)-$t0;
return $return;
}
}