forked from vergnet/site-accueil-insa
135 lines
No EOL
3.6 KiB
PHP
135 lines
No EOL
3.6 KiB
PHP
<?php
|
|
/**
|
|
* Matomo - free/libre analytics platform
|
|
*
|
|
* @link https://matomo.org
|
|
* @license http://www.gnu.org/licenses/gpl-3.0.html GPL v3 or later
|
|
*
|
|
*/
|
|
|
|
namespace Piwik\DataAccess;
|
|
|
|
use Piwik\Config;
|
|
use Piwik\Db\AdapterInterface;
|
|
use Piwik\DbHelper;
|
|
use Psr\Log\LoggerInterface;
|
|
use Exception;
|
|
|
|
class ArchivingDbAdapter
|
|
{
|
|
/**
|
|
* @var AdapterInterface|\Zend_Db_Adapter_Abstract
|
|
*/
|
|
private $wrapped;
|
|
|
|
/**
|
|
* @var LoggerInterface
|
|
*/
|
|
private $logger;
|
|
|
|
/**
|
|
* @var int
|
|
*/
|
|
private $maxExecutionTime;
|
|
|
|
public function __construct($wrapped, LoggerInterface $logger = null)
|
|
{
|
|
$this->wrapped = $wrapped;
|
|
$this->logger = $logger;
|
|
$this->maxExecutionTime = (float) Config::getInstance()->General['archiving_query_max_execution_time'];
|
|
}
|
|
|
|
public function __call($name, $arguments)
|
|
{
|
|
return call_user_func_array([$this->wrapped, $name], $arguments);
|
|
}
|
|
|
|
public function exec($sql)
|
|
{
|
|
$sql = DbHelper::addMaxExecutionTimeHintToQuery($sql, $this->maxExecutionTime);
|
|
$this->logSql($sql);
|
|
|
|
return call_user_func_array([$this, "callFunction"], array_merge([__FUNCTION__], func_get_args()));
|
|
}
|
|
|
|
public function query($sql)
|
|
{
|
|
$sql = DbHelper::addMaxExecutionTimeHintToQuery($sql, $this->maxExecutionTime);
|
|
$this->logSql($sql);
|
|
|
|
return call_user_func_array([$this, "callFunction"], array_merge([__FUNCTION__], func_get_args()));
|
|
}
|
|
|
|
public function fetchAll($sql)
|
|
{
|
|
$sql = DbHelper::addMaxExecutionTimeHintToQuery($sql, $this->maxExecutionTime);
|
|
$this->logSql($sql);
|
|
|
|
return call_user_func_array([$this, "callFunction"], array_merge([__FUNCTION__], func_get_args()));
|
|
}
|
|
|
|
public function fetchRow($sql)
|
|
{
|
|
$sql = DbHelper::addMaxExecutionTimeHintToQuery($sql, $this->maxExecutionTime);
|
|
$this->logSql($sql);
|
|
|
|
return call_user_func_array([$this, "callFunction"], array_merge([__FUNCTION__], func_get_args()));
|
|
}
|
|
|
|
public function fetchOne($sql)
|
|
{
|
|
$sql = DbHelper::addMaxExecutionTimeHintToQuery($sql, $this->maxExecutionTime);
|
|
$this->logSql($sql);
|
|
|
|
return call_user_func_array([$this, "callFunction"], array_merge([__FUNCTION__], func_get_args()));
|
|
}
|
|
|
|
public function fetchAssoc($sql)
|
|
{
|
|
$sql = DbHelper::addMaxExecutionTimeHintToQuery($sql, $this->maxExecutionTime);
|
|
$this->logSql($sql);
|
|
|
|
return call_user_func_array([$this, "callFunction"], array_merge([__FUNCTION__], func_get_args()));
|
|
}
|
|
|
|
/**
|
|
* Test error number
|
|
*
|
|
* @param Exception $e
|
|
* @param string $errno
|
|
* @return bool
|
|
*/
|
|
public function isErrNo($e, $errno)
|
|
{
|
|
return $this->wrapped->isErrNo($e, $errno);
|
|
}
|
|
|
|
private function logSql($sql)
|
|
{
|
|
// Log on DEBUG level all SQL archiving queries
|
|
if ($this->logger) {
|
|
$this->logger->debug($sql);
|
|
}
|
|
}
|
|
|
|
private function callFunction($function) {
|
|
|
|
$args = func_get_args();
|
|
unset($args[0]);
|
|
|
|
try {
|
|
return call_user_func_array([$this->wrapped, $function], $args);
|
|
} catch (\Exception $e) {
|
|
if ($this->isErrNo($e, \Piwik\Updater\Migration\Db::ERROR_CODE_MAX_EXECUTION_TIME_EXCEEDED_QUERY_INTERRUPTED) ||
|
|
$this->isErrNo($e, \Piwik\Updater\Migration\Db::ERROR_CODE_MAX_EXECUTION_TIME_EXCEEDED_SORT_ABORTED)
|
|
)
|
|
{
|
|
$this->logger->warning('Archiver query exceeded maximum execution time: {details}',
|
|
['details' => json_encode($args, true)]);
|
|
|
|
}
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
} |