Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Added abstract PDO profiler storage, updated sqlite storage and add…
…ed a mysql storage. - Updated profiler config in framework bundle
- Loading branch information
1 parent
e5fad94
commit d1ebc8d
Showing
6 changed files
with
276 additions
and
125 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
45 changes: 45 additions & 0 deletions
45
src/Symfony/Component/HttpKernel/Profiler/MysqlProfilerStorage.php
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,45 @@ | ||
| <?php | ||
|
|
||
| /* | ||
| * This file is part of the Symfony package. | ||
| * | ||
| * (c) Fabien Potencier <fabien.potencier@symfony-project.com> | ||
| * | ||
| * For the full copyright and license information, please view the LICENSE | ||
| * file that was distributed with this source code. | ||
| */ | ||
|
|
||
| namespace Symfony\Component\HttpKernel\Profiler; | ||
|
|
||
| /** | ||
| * A ProfilerStorage for Mysql | ||
| * | ||
| * @author Jan Schumann <js@schumann-it.com> | ||
| */ | ||
| class MysqlProfilerStorage extends PdoProfilerStorage | ||
| { | ||
| /** | ||
| * {@inheritdoc} | ||
| */ | ||
| protected function initDb() | ||
| { | ||
| if (is_null($this->db)) | ||
| { | ||
| if ('mysql' !== substr($this->dsn, 0, 5)) | ||
| { | ||
| throw new \RuntimeException('Please check your configuration. You are trying to use Mysql with a wrong dsn. "' . $this->dsn . '"'); | ||
| } | ||
|
|
||
| if (!class_exists('PDO') || !in_array('mysql', \PDO::getAvailableDrivers(), true)) { | ||
| throw new \RuntimeException('You need to enable PDO_Mysql extension for the profiler to run properly.'); | ||
| } | ||
|
|
||
| $db = new \PDO($this->dsn, $this->username, $this->password); | ||
| $db->exec('CREATE TABLE IF NOT EXISTS data (token VARCHAR(255) PRIMARY KEY, data LONGTEXT, ip VARCHAR(64), url VARCHAR(255), time INTEGER UNSIGNED, parent VARCHAR(255), created_at INTEGER UNSIGNED, KEY (created_at), KEY (ip), KEY (url), KEY (parent))'); | ||
|
|
||
| $this->db = $db; | ||
| } | ||
|
|
||
| return $this->db; | ||
| } | ||
| } |
194 changes: 194 additions & 0 deletions
194
src/Symfony/Component/HttpKernel/Profiler/PdoProfilerStorage.php
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,194 @@ | ||
| <?php | ||
|
|
||
| /* | ||
| * This file is part of the Symfony package. | ||
| * | ||
| * (c) Fabien Potencier <fabien.potencier@symfony-project.com> | ||
| * | ||
| * For the full copyright and license information, please view the LICENSE | ||
| * file that was distributed with this source code. | ||
| */ | ||
|
|
||
| namespace Symfony\Component\HttpKernel\Profiler; | ||
|
|
||
| use Symfony\Component\HttpKernel\DataCollector\DataCollectorInterface; | ||
|
|
||
| /** | ||
| * Base PDO storage for profiling information in a PDO database. | ||
| * | ||
| * @author Jan Schumann <js@schumann-it.com> | ||
| */ | ||
| abstract class PdoProfilerStorage implements ProfilerStorageInterface | ||
| { | ||
| protected $dsn; | ||
| protected $username; | ||
| protected $password; | ||
| protected $lifetime; | ||
| protected $db; | ||
|
|
||
| /** | ||
| * Constructor. | ||
| * | ||
| * @param string $dsn A data source name | ||
| * @param string $username The username for the database | ||
| * @param string $password The password for the database | ||
| * @param integer $lifetime The lifetime to use for the purge | ||
| */ | ||
| public function __construct($dsn, $username = '', $password = '', $lifetime = 86400) | ||
| { | ||
| $this->dsn = $dsn; | ||
| $this->username = $username; | ||
| $this->password = $password; | ||
| $this->lifetime = (int) $lifetime; | ||
| } | ||
|
|
||
| /** | ||
| * {@inheritdoc} | ||
| */ | ||
| public function find($ip, $url, $limit) | ||
| { | ||
| list($criteria, $args) = $this->buildCriteria($ip, $url, $limit); | ||
|
|
||
| $criteria = $criteria ? 'WHERE '.implode(' AND ', $criteria) : ''; | ||
|
|
||
| $db = $this->initDb(); | ||
| $tokens = $this->fetch($db, 'SELECT token, ip, url, time FROM data '.$criteria.' ORDER BY time DESC LIMIT '.((integer) $limit), $args); | ||
| $this->close($db); | ||
|
|
||
| return $tokens; | ||
| } | ||
|
|
||
| protected function buildCriteria($ip, $url, $limit) | ||
| { | ||
| $criteria = array(); | ||
| $args = array(); | ||
|
|
||
| if ($ip = preg_replace('/[^\d\.]/', '', $ip)) { | ||
| $criteria[] = 'ip LIKE :ip'; | ||
| $args[':ip'] = '%'.$ip.'%'; | ||
| } | ||
|
|
||
| if ($url) { | ||
| $criteria[] = 'url LIKE :url'; | ||
| $args[':url'] = '%'.addcslashes($url, '%_\\').'%'; | ||
| } | ||
|
|
||
| return array($criteria, $args); | ||
| } | ||
|
|
||
| /** | ||
| * {@inheritdoc} | ||
| */ | ||
| public function read($token) | ||
| { | ||
| $db = $this->initDb(); | ||
| $args = array(':token' => $token); | ||
| $data = $this->fetch($db, 'SELECT data, ip, url, time FROM data WHERE token = :token LIMIT 1', $args); | ||
| $this->close($db); | ||
| if (isset($data[0]['data'])) { | ||
| return array($data[0]['data'], $data[0]['ip'], $data[0]['url'], $data[0]['time']); | ||
| } | ||
|
|
||
| return false; | ||
| } | ||
|
|
||
| /** | ||
| * {@inheritdoc} | ||
| */ | ||
| public function write($token, $parent, $data, $ip, $url, $time) | ||
| { | ||
| $db = $this->initDb(); | ||
| $args = array( | ||
| ':token' => $token, | ||
| ':parent' => $parent, | ||
| ':data' => $data, | ||
| ':ip' => $ip, | ||
| ':url' => $url, | ||
| ':time' => $time, | ||
| ':created_at' => time(), | ||
| ); | ||
| try { | ||
| $this->exec($db, 'INSERT INTO data (token, parent, data, ip, url, time, created_at) VALUES (:token, :parent, :data, :ip, :url, :time, :created_at)', $args); | ||
| $this->cleanup(); | ||
| $status = true; | ||
| } catch (\Exception $e) { | ||
| $status = false; | ||
| } | ||
| $this->close($db); | ||
|
|
||
| return $status; | ||
| } | ||
|
|
||
| /** | ||
| * {@inheritdoc} | ||
| */ | ||
| public function purge() | ||
| { | ||
| $db = $this->initDb(); | ||
| $this->exec($db, 'DELETE FROM data'); | ||
| $this->close($db); | ||
| } | ||
|
|
||
| protected function cleanup() | ||
| { | ||
| $db = $this->initDb(); | ||
| $this->exec($db, 'DELETE FROM data WHERE created_at < :time', array(':time' => time() - $this->lifetime)); | ||
| $this->close($db); | ||
| } | ||
|
|
||
| /** | ||
| * @throws \RuntimeException When the requeted database driver is not installed | ||
| */ | ||
| abstract protected function initDb(); | ||
|
|
||
| protected function exec($db, $query, array $args = array()) | ||
| { | ||
| $stmt = $this->prepareStatement($db, $query); | ||
|
|
||
| foreach ($args as $arg => $val) { | ||
| $stmt->bindValue($arg, $val, is_int($val) ? \PDO::PARAM_INT : \PDO::PARAM_STR); | ||
| } | ||
| $success = $stmt->execute(); | ||
| if (!$success) { | ||
| throw new \RuntimeException(sprintf('Error executing query "%s"', $query)); | ||
| } | ||
| } | ||
|
|
||
| protected function prepareStatement($db, $query) | ||
| { | ||
| try { | ||
| $stmt = $db->prepare($query); | ||
| } | ||
| catch (\Exception $e) | ||
| { | ||
| $stmt = false; | ||
| } | ||
|
|
||
| if (false === $stmt) { | ||
| throw new \RuntimeException('The database cannot successfully prepare the statement'); | ||
| } | ||
|
|
||
| return $stmt; | ||
| } | ||
|
|
||
| protected function fetch($db, $query, array $args = array()) | ||
| { | ||
| $return = array(); | ||
| $stmt = $this->prepareStatement($db, $query); | ||
|
|
||
| foreach ($args as $arg => $val) { | ||
| $stmt->bindValue($arg, $val, is_int($val) ? \PDO::PARAM_INT : \PDO::PARAM_STR); | ||
| } | ||
| $stmt->execute(); | ||
| $return = $stmt->fetchAll(\PDO::FETCH_ASSOC); | ||
|
|
||
| return $return; | ||
| } | ||
|
|
||
| protected function close($db) | ||
| { | ||
| if ($db instanceof \SQLite3) { | ||
| $db->close(); | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.