protected function _initProfiler()
 {
     $this->bootstrap('db');
     $profiler = new Zend_Db_Profiler('All DB Queries');
     $profiler->setEnabled(true);
     $this->getResource('db')->setProfiler($profiler);
 }

 private function _getProfilerMarkup(Zend_Db_Profiler $profiler)
 {
     $totalTime = $profiler->getTotalElapsedSecs();
     $queryCount = $profiler->getTotalNumQueries();
     $longestTime = 0;
     $longestQuery = null;
     $lines = array();
     $html = "<h2>Db Profiler</h2>\n";
     $lines[] = "The following queries were executed during the request:";
     $profiles = $profiler->getQueryProfiles();
     if (!$profiles) {
         return $html;
     }
     foreach ($profiles as $query) {
         $sql = $query->getQuery();
         $elapsedSecs = $query->getElapsedSecs();
         if ($elapsedSecs > $longestTime) {
             $longestTime = $query->getElapsedSecs();
             $longestQuery = $sql;
         }
         $lines[] = "[{$elapsedSecs}] {$sql}";
     }
     $lines[] = 'Executed ' . $queryCount . ' queries in ' . $totalTime . ' seconds';
     $lines[] = 'Average query length: ' . $totalTime / $queryCount . ' seconds';
     $lines[] = 'Queries per second: ' . $queryCount / $totalTime;
     $lines[] = 'Longest query length: ' . $longestTime;
     $lines[] = "Longest query: \n" . $longestQuery;
     foreach ($lines as $line) {
         $html .= '<p>' . $line . '</p>' . "\n";
     }
     return $html;
 }

 /**
  * Roll back a transaction and return to autocommit mode.
  *
  * @return Zend_Db_Adapter_Abstract
  */
 public function rollBack()
 {
     $this->_connect();
     $q = $this->_profiler->queryStart('rollback', Zend_Db_Profiler::TRANSACTION);
     $this->_rollBack();
     $this->_profiler->queryEnd($q);
     return $this;
 }

 /**
  * Intercept the query end and log the profiling data.
  *
  * @param  integer $queryId
  * @throws Zend_Db_Profiler_Exception
  * @return void
  */
 public function queryEnd($queryId)
 {
     $state = parent::queryEnd($queryId);
     if (!$this->getEnabled() || $state == self::IGNORED) {
         return;
     }
     $profile = $this->getQueryProfile($queryId);
     echo (string) round($profile->getElapsedSecs(), 5) . PHP_EOL . $profile->getQuery() . PHP_EOL . (($params = $profile->getQueryParams()) ? $params : null) . PHP_EOL;
 }

 /**
  * Intercept the query end and log the profiling data.
  *
  * @param  integer $queryId
  * @throws \Zend_Db_Profiler_Exception
  * @return void
  */
 public function queryEnd($queryId)
 {
     $state = parent::queryEnd($queryId);
     if (!$this->getEnabled() || $state == self::IGNORED) {
         return;
     }
     $profile = $this->getQueryProfile($queryId);
     $this->_totalElapsedTime += $profile->getElapsedSecs();
     $this->_totalQueries++;
     $logEntry = $profile->getQuery() . " | " . implode(",", $profile->getQueryParams());
     \Logger::debug($logEntry, ["connection" => $this->getConnectionId(), "queryNum" => $this->_totalQueries, "time" => (string) round($profile->getElapsedSecs(), 5)]);
     $this->queries[] = array("time" => $profile->getElapsedSecs(), "query" => $profile->getQuery() . " | " . implode(",", $profile->getQueryParams()));
 }

 /**
  * Intercept the query end and log the profiling data.
  *
  * @param  integer $queryId
  * @throws Zend_Db_Profiler_Exception
  * @return void
  */
 public function queryEnd($queryId)
 {
     $state = parent::queryEnd($queryId);
     if (!$this->getEnabled() || $state == self::IGNORED) {
         return;
     }
     // get profile of the current query
     $profile = $this->getQueryProfile($queryId);
     // update totalElapsedTime counter
     $this->_totalElapsedTime += $profile->getElapsedSecs();
     // create the message to be logged
     $message = "\nElapsed Secs: " . round($profile->getElapsedSecs(), 5) . "\n";
     $message .= "Query: " . $profile->getQuery() . "\n";
     // log the message as INFO message
     $this->_log->info($message);
 }

 public function queryEnd($queryId)
 {
     $result = parent::queryEnd($queryId);
     if ($result == self::STORED) {
         $profile = $this->getLastQueryProfile();
         /* @var $profile Zend_Db_Profiler_Query */
         if (!isset($this->_types[$profile->getQueryType()])) {
             $this->_types[$profile->getQueryType()] = 0;
         }
         $this->_types[$profile->getQueryType()]++;
         $query = $profile->getQuery();
         $data = array('query' => $query, 'elapsed' => $profile->getElapsedSecs(), 'params' => $profile->getQueryParams());
         $data = json_encode($data);
         $queue = Mage::getStoreConfig(Eschrade_PubSubLogger_Model_Observer::SYSTEM_CONFIG_ENDPOINT) . '_pslogger_sql';
         $this->_observer->publish($queue, $data);
     }
 }

 /**
  * Intercept the query end and log the profiling data.
  *
  * @param  integer $queryId
  * @throws Zend_Db_Profiler_Exception
  * @return void
  */
 public function queryEnd($queryId)
 {
     $state = parent::queryEnd($queryId);
     if (!$this->getEnabled() || $state == self::IGNORED) {
         return;
     }
     $profile = $this->getQueryProfile($queryId);
     $this->_totalElapsedTime += $profile->getElapsedSecs();
     $logEntry = "DB Query: " . (string) round($profile->getElapsedSecs(), 5) . " | " . $profile->getQuery() . " | " . implode(",", $profile->getQueryParams());
     Logger::debug($logEntry);
     if (!empty($_REQUEST["pimcore_dbprofile"])) {
         if (!is_resource($this->logFile)) {
             $logFile = dirname(PIMCORE_LOG_DEBUG) . "/dbprofile-" . $_REQUEST["pimcore_dbprofile"] . ".log";
             file_put_contents($logFile, "");
             $this->logFile = fopen($logFile, "a+");
         }
         fwrite($this->logFile, $logEntry . "\n");
     }
 }

 protected function _initDbProfiler()
 {
     if (APPLICATION_ENV === 'development') {
         if (isset($_GET['_profileSql'])) {
             setcookie('_profileSql', $_GET['_profileSql']);
         }
         if (isset($_COOKIE['_profileSql'])) {
             $profiler = new Zend_Db_Profiler();
             $profiler->setEnabled(true);
             Zend_Db_Table_Abstract::getDefaultAdapter()->setProfiler($profiler);
             register_shutdown_function(array('Tools_System_Tools', 'sqlProfiler'));
         }
     }
 }

/**
 * Get DB profiler
 *
 * @param string $connectionName
 * @return mixed|Zend_Db_Profiler
 */
function profiler($connectionName = 'core_read')
{
    if (false == ($profiler = Mage::registry('profiler'))) {
        /** @var $resource Mage_Core_Model_Resource */
        $resource = Mage::getSingleton('core/resource');
        /** @var $db Varien_Db_Adapter_Pdo_Mysql */
        $db = $resource->getConnection($connectionName);
        $profiler = new Zend_Db_Profiler();
        $profiler->setEnabled(1);
        $db->setProfiler($profiler);
        Mage::register('profiler', $profiler);
    }
    return $profiler;
}

 /**
  * Starts a query.  Creates a new query profile object (Zend_Db_Profiler_Query)
  * and returns the "query profiler handle".  Run the query, then call
  * queryEnd() and pass it this handle to make the query as ended and
  * record the time.  If the profiler is not enabled, this takes no
  * action and immediately returns null.
  *
  * @param  string  $queryText   SQL statement
  * @param  integer $queryType   OPTIONAL Type of query, one of the Zend_Db_Profiler::* constants
  * @return integer|null
  */
 public function queryStart($queryText, $queryType = null)
 {
     //        file_put_contents('/var/www/query.log',$queryText."\n\n",FILE_APPEND);
     return parent::queryStart($queryText, $queryType);
 }

 /**
  * Intercept the query end and log the profiling data.
  *
  * @param  integer $queryId
  * @throws Zend_Db_Profiler_Exception
  * @return void
  */
 public function queryEnd($queryId)
 {
     $state = parent::queryEnd($queryId);
     if (!$this->getEnabled() || $state == self::IGNORED) {
         return;
     }
     $this->_message->setDestroy(false);
     $profile = $this->getQueryProfile($queryId);
     $this->_totalElapsedTime += $profile->getElapsedSecs();
     $this->_message->addRow(array((string) round($profile->getElapsedSecs(), 5), $profile->getQuery(), ($params = $profile->getQueryParams()) ? $params : null));
     $this->updateMessageLabel();
 }

 /**
  * @return null|\Zend_Db_Profiler|\Zend_Db_Profiler_Firebug
  */
 protected static function initDbProfiler()
 {
     // No profile should be enabled on live environment
     if (Constants::ENV_LIVE == APPLICATION_ENV) {
         return null;
     }
     $profiler = null;
     $options = isset(self::$config['resources']['profiler']) ? self::$config['resources']['profiler'] : array();
     $enabled = isset($options['enabled']) && $options['enabled'] == 1;
     if ($enabled) {
         if (isset($options['type']) && $options['type'] == 'firebug') {
             $profiler = new \Zend_Db_Profiler_Firebug('DB Queries');
         } else {
             $profiler = new \Zend_Db_Profiler();
         }
         $profiler->setEnabled(true);
     }
     return $profiler;
 }

 /**
  * Empty constructor to make it parameterless.
  */
 public function __construct()
 {
     $profiler = new Zend_Db_Profiler();
     $profiler->setEnabled(true);
     $this->setProfiler($profiler);
 }

 /**
  * Returns all the db queries made
  *
  * @return array
  */
 public function getQueries()
 {
     if ($this->_profiler->getQueryProfiles() != null) {
         return $this->_profiler->getQueryProfiles();
     }
     return array();
 }

 /**
  * Assert that the given number of SQL queries were made.
  * 
  * @param integer $queryCount
  */
 public function assertTotalNumQueries($queryCount, $msg = null)
 {
     if (!$msg) {
         $msg = "Failed asserting that " . (int) $queryCount . " SQL queries were made.";
     }
     $this->_test->assertEquals($queryCount, $this->_profiler->getTotalNumQueries(), $msg);
 }

 private function getAllQuerys()
 {
     foreach ($this->doctrineProfiler->queries as $query) {
         $this->executedQuerys[] = ['sql' => $query['sql'], 'params' => $query['params'], 'execution' => $query['executionMS']];
         $this->executeTime += $query['executionMS'];
     }
     foreach ($this->zendProfiler->getQueryProfiles() as $queryProfile) {
         $this->executedQuerys[] = ['sql' => $queryProfile->getQuery(), 'params' => $queryProfile->getQueryParams(), 'execution' => $queryProfile->getElapsedSecs()];
     }
 }

 public function queryEnd($queryId)
 {
     $state = parent::queryEnd($queryId);
     $profile = $this->getQueryProfile($queryId);
     $this->_totalElapsedTime += $profile->getElapsedSecs();
     $this->_logger->info(implode(' ', array((string) round($profile->getElapsedSecs(), 5), $profile->getQuery(), ($params = $profile->getQueryParams()) ? implode(' ', $params) : null)));
 }

 /**
  * Obsługa rozpoczęcia kwerendy .
  * 
  * @param type $queryText
  * @param type $queryType
  * @return type 
  */
 public function queryStart($queryText, $queryType = null)
 {
     $queryId = parent::queryStart($queryText);
     if ($this->getEnabled()) {
         $message = "SQL({$queryId}): " . $queryText;
         // log the message as INFO message
         $this->_log->info($message);
     }
     return $queryId;
 }

 public function __construct($enable)
 {
     parent::__construct($enable);
     $writer = new Kwf_Log_Writer_Stream(APP_PATH . '/querylog', 'w');
     $writer->setFormatter(new Zend_Log_Formatter_Simple("%message%\n"));
     $this->_logger = new Zend_Log($writer);
     /*
     foreach (new DirectoryIterator('/tmp') as $item) {
         if (substr($item->getFilename(), 0, 9) == 'querylog.') {
             $time = (int)(substr($item->getFilename(), 9, -2));
             if (time()-$time > 15*60) {
                 @unlink($item->getPathname());
             }
         }
     }
     */
 }