Ubuntu

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; } } }