RetailCRM-Mirror/doctrine2
1
0
Fork 0
mirror of synced 2025-04-03 13:23:37 +03:00
Code Issues Projects Releases Wiki Activity

Browse source
This commit is contained in:
zYne 2007-02-08 22:06:03 +00:00
parent 880422ca88
commit 6f4c3c20c7
2 changed files with 73 additions and 52 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

101
lib/Doctrine/Cache.php
View file

@ -35,12 +35,12 @@ class Doctrine_Cache extends Doctrine_Db_EventListener implements Countable, Ite
/** /**
* @var array $_options an array of general caching options * @var array $_options an array of general caching options
*/ */
protected $_options = array('size' => 1000, protected $_options = array('size' => 1000,
'lifeTime' => 3600, 'lifeTime' => 3600,
'statsPropability' => 0.75, 'addStatsPropability' => 0.25,
'savePropability' => 0.10, 'savePropability' => 0.10,
'cleanPropability' => 0.01, 'cleanPropability' => 0.01,
'statsFile' => '../data/stats.cache', 'statsFile' => '../data/stats.cache',
); );
/** /**
* @var array $_queries query stack * @var array $_queries query stack
@ -211,50 +211,63 @@ class Doctrine_Cache extends Doctrine_Db_EventListener implements Countable, Ite
* *
* @return boolean * @return boolean
*/ */
public function processAll() public function clean()
{ {
$content = file_get_contents($this->_statsFile); $rand = (mt_rand() / mt_getrandmax());
$queries = explode("\n", $content);
$stats = array(); if ($rand <= $this->_options['cleanPropability']) {
$content = file_get_contents($this->_statsFile);
$queries = explode("\n", $content);
foreach ($queries as $query) { $stats = array();
if (is_array($query)) {
$query = $query[0]; foreach ($queries as $query) {
if (is_array($query)) {
$query = $query[0];
}
if (isset($stats[$query])) {
$stats[$query]++;
} else {
$stats[$query] = 1;
}
} }
if (isset($stats[$query])) { sort($stats);
$stats[$query]++;
} else { $i = $this->_options['size'];
$stats[$query] = 1;
while ($i--) {
$element = next($stats);
$query = key($stats);
if (is_array($query)) {
$hash = md5(serialize($query));
} else {
$hash = md5($query);
}
$this->_driver->delete($hash);
} }
} }
sort($stats);
$i = $this->_options['size'];
while ($i--) {
$element = next($stats);
$query = key($stats);
$conn = Doctrine_Manager::getConnection($element[1]);
$data = $conn->fetchAll($query);
$this->_driver->save(serialize($data), $query, $this->_options['lifetime']);
}
} }
/** /**
* flush * appendStats
* *
* adds all queries to stats file * adds all queries to stats file
* @return void * @return void
*/ */
public function flush() public function appendStats()
{ {
if ($this->_options['statsFile'] !== false) { if ($this->_options['statsFile'] !== false) {
if ( ! file_exists($this->_options['statsFile'])) { if ( ! file_exists($this->_options['statsFile'])) {
throw new Doctrine_Cache_Exception("Couldn't save cache statistics. Cache statistics file doesn't exists!"); throw new Doctrine_Cache_Exception("Couldn't save cache statistics. Cache statistics file doesn't exists!");
} }
$rand = (mt_rand() / mt_getrandmax());
file_put_contents($this->_options['statsFile'], implode("\n", $this->_queries)); if ($rand <= $this->_options['addStatsPropability']) {
file_put_contents($this->_options['statsFile'], implode("\n", $this->_queries));
}
} }
} }
/** /**
@ -281,10 +294,10 @@ class Doctrine_Cache extends Doctrine_Db_EventListener implements Countable, Ite
$this->success = ($data) ? true : false; $this->success = ($data) ? true : false;
if ( ! $data) { if ( ! $data) {
$rand = (rand(1, 10000) / (10000 * 100)); $rand = (mt_rand() / mt_getrandmax());
if ($rand < $this->_options['savePropability']) { if ($rand < $this->_options['savePropability']) {
$stmt = $event->getInvoker()->query($query); $stmt = $event->getInvoker()->getAdapter()->query($query);
$data = $stmt->fetchAll(Doctrine::FETCH_ASSOC); $data = $stmt->fetchAll(Doctrine::FETCH_ASSOC);
@ -349,10 +362,13 @@ class Doctrine_Cache extends Doctrine_Db_EventListener implements Countable, Ite
$this->success = ($data) ? true : false; $this->success = ($data) ? true : false;
if ( ! $data) { if ( ! $data) {
$rand = (rand(1, 10000) / (10000 * 100)); $rand = (mt_rand() / mt_getrandmax());
if ($rand < $this->_options['savePropability']) { if ($rand <= $this->_options['savePropability']) {
$stmt = $event->getInvoker()->execute($event->getParams());
$stmt = $event->getInvoker()->getStatement();
$stmt->execute($event->getParams());
$data = $stmt->fetchAll(Doctrine::FETCH_ASSOC); $data = $stmt->fetchAll(Doctrine::FETCH_ASSOC);
@ -367,17 +383,4 @@ class Doctrine_Cache extends Doctrine_Db_EventListener implements Countable, Ite
} }
return (bool) $data; return (bool) $data;
} }
/**
* processStats
*
* @return void
*/
public function processStats()
{
$rand = (rand(1, 10000) / (10000 * 100));
if($rand > $this->_options['statSlamDefense']) {
$this->flush();
}
}
} }

24
lib/Doctrine/Cache/Array.php
View file

@ -31,7 +31,7 @@
* @version $Revision$ * @version $Revision$
* @author Konsta Vesterinen <kvesteri@cc.hut.fi> * @author Konsta Vesterinen <kvesteri@cc.hut.fi>
*/ */
class Doctrine_Cache_Array class Doctrine_Cache_Array implements Countable
{ {
/** /**
* @var array $data an array of cached data * @var array $data an array of cached data
@ -74,7 +74,7 @@ class Doctrine_Cache_Array
* @param int $lifeTime if != false, set a specific lifetime for this cache record (null => infinite lifeTime) * @param int $lifeTime if != false, set a specific lifetime for this cache record (null => infinite lifeTime)
* @return boolean true if no problem * @return boolean true if no problem
*/ */
public function save($id, $data, $lifeTime = false) public function save($id, $data, $lifeTime = false)
{ {
$this->data[$id] = $data; $this->data[$id] = $data;
} }
@ -86,6 +86,24 @@ class Doctrine_Cache_Array
*/ */
public function delete($id) public function delete($id)
{ {
unset($this->data[$id]); unset($this->data[$id]);
}
/**
* Remove all cache record
*
* @return boolean true if no problem
*/
public function deleteAll()
{
$this->data = array();
}
/**
* count
*
* @return integer
*/
public function count()
{
return count($this->data);
} }
} }