Congegni/sintonia
7
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

adding zend project folders into old campcaster.

Browse source
This commit is contained in:
naomiaro 2010-12-07 14:19:27 -05:00
parent 56abfaf28e
commit 7ef0c18b26
4045 changed files with 1054952 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

262
library/propel/generator/lib/behavior/query_cache/QueryCacheBehavior.php Normal file
View file

@ -0,0 +1,262 @@
<?php
/**
* This file is part of the Propel package.
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*
* @license MIT License
*/
/**
* Speeds up queries on a model by caching the query
*
* @author François Zaninotto
* @version $Revision: 1746 $
* @package propel.generator.behavior.cacheable
*/
class QueryCacheBehavior extends Behavior
{
// default parameters value
protected $parameters = array(
'backend' => 'apc',
'lifetime' => 3600,
);
public function queryAttributes($builder)
{
$script = "protected \$queryKey = '';
";
switch ($this->getParameter('backend')) {
case 'backend':
$script .= "protected static \$cacheBackend = array();
";
break;
case 'apc':
break;
case 'custom':
default:
$script .= "protected static \$cacheBackend;
";
break;
}
return $script;
}
public function queryMethods($builder)
{
$this->peerClassname = $builder->getStubPeerBuilder()->getClassname();
$script = '';
$this->addSetQueryKey($script);
$this->addGetQueryKey($script);
$this->addCacheContains($script);
$this->addCacheFetch($script);
$this->addCacheStore($script);
$this->addGetSelectStatement($script);
$this->addGetCountStatement($script);
return $script;
}
protected function addSetQueryKey(&$script)
{
$script .= "
public function setQueryKey(\$key)
{
\$this->queryKey = \$key;
return \$this;
}
";
}
protected function addGetQueryKey(&$script)
{
$script .= "
public function getQueryKey()
{
return \$this->queryKey;
}
";
}
protected function addCacheContains(&$script)
{
$script .= "
public function cacheContains(\$key)
{";
switch ($this->getParameter('backend')) {
case 'apc':
$script .= "
return apc_fetch(\$key);";
break;
case 'array':
$script .= "
return isset(self::\$cacheBackend[\$key]);";
break;
case 'custom':
default:
$script .= "
throw new PropelException('You must override the cacheContains(), cacheStore(), and cacheFetch() methods to enable query cache');";
break;
}
$script .= "
}
";
}
protected function addCacheStore(&$script)
{
$script .= "
public function cacheStore(\$key, \$value, \$lifetime = " .$this->getParameter('lifetime') . ")
{";
switch ($this->getParameter('backend')) {
case 'apc':
$script .= "
apc_store(\$key, \$value, \$lifetime);";
break;
case 'array':
$script .= "
self::\$cacheBackend[\$key] = \$value;";
break;
case 'custom':
default:
$script .= "
throw new PropelException('You must override the cacheContains(), cacheStore(), and cacheFetch() methods to enable query cache');";
break;
}
$script .= "
}
";
}
protected function addCacheFetch(&$script)
{
$script .= "
public function cacheFetch(\$key)
{";
switch ($this->getParameter('backend')) {
case 'apc':
$script .= "
return apc_fetch(\$key);";
break;
case 'array':
$script .= "
return isset(self::\$cacheBackend[\$key]) ? self::\$cacheBackend[\$key] : null;";
break;
case 'custom':
default:
$script .= "
throw new PropelException('You must override the cacheContains(), cacheStore(), and cacheFetch() methods to enable query cache');";
break;
}
$script .= "
}
";
}
protected function addGetSelectStatement(&$script)
{
$script .= "
protected function getSelectStatement(\$con = null)
{
\$dbMap = Propel::getDatabaseMap(" . $this->peerClassname ."::DATABASE_NAME);
\$db = Propel::getDB(" . $this->peerClassname ."::DATABASE_NAME);
if (\$con === null) {
\$con = Propel::getConnection(" . $this->peerClassname ."::DATABASE_NAME, Propel::CONNECTION_READ);
}
if (!\$this->hasSelectClause()) {
\$this->addSelfSelectColumns();
}
\$con->beginTransaction();
try {
\$this->basePreSelect(\$con);
\$key = \$this->getQueryKey();
if (\$key && \$this->cacheContains(\$key)) {
\$params = \$this->getParams();
\$sql = \$this->cacheFetch(\$key);
} else {
\$params = array();
\$sql = BasePeer::createSelectSql(\$this, \$params);
if (\$key) {
\$this->cacheStore(\$key, \$sql);
}
}
\$stmt = \$con->prepare(\$sql);
BasePeer::populateStmtValues(\$stmt, \$params, \$dbMap, \$db);
\$stmt->execute();
\$con->commit();
} catch (PropelException \$e) {
\$con->rollback();
throw \$e;
}
return \$stmt;
}
";
}
protected function addGetCountStatement(&$script)
{
$script .= "
protected function getCountStatement(\$con = null)
{
\$dbMap = Propel::getDatabaseMap(\$this->getDbName());
\$db = Propel::getDB(\$this->getDbName());
if (\$con === null) {
\$con = Propel::getConnection(\$this->getDbName(), Propel::CONNECTION_READ);
}
\$con->beginTransaction();
try {
\$this->basePreSelect(\$con);
\$key = \$this->getQueryKey();
if (\$key && \$this->cacheContains(\$key)) {
\$params = \$this->getParams();
\$sql = \$this->cacheFetch(\$key);
} else {
if (!\$this->hasSelectClause() && !\$this->getPrimaryCriteria()) {
\$this->addSelfSelectColumns();
}
\$params = array();
\$needsComplexCount = \$this->getGroupByColumns()
|| \$this->getOffset()
|| \$this->getLimit()
|| \$this->getHaving()
|| in_array(Criteria::DISTINCT, \$this->getSelectModifiers());
if (\$needsComplexCount) {
if (BasePeer::needsSelectAliases(\$this)) {
if (\$this->getHaving()) {
throw new PropelException('Propel cannot create a COUNT query when using HAVING and duplicate column names in the SELECT part');
}
BasePeer::turnSelectColumnsToAliases(\$this);
}
\$selectSql = BasePeer::createSelectSql(\$this, \$params);
\$sql = 'SELECT COUNT(*) FROM (' . \$selectSql . ') propelmatch4cnt';
} else {
// Replace SELECT columns with COUNT(*)
\$this->clearSelectColumns()->addSelectColumn('COUNT(*)');
\$sql = BasePeer::createSelectSql(\$this, \$params);
}
if (\$key) {
\$this->cacheStore(\$key, \$sql);
}
}
\$stmt = \$con->prepare(\$sql);
BasePeer::populateStmtValues(\$stmt, \$params, \$dbMap, \$db);
\$stmt->execute();
\$con->commit();
} catch (PropelException \$e) {
\$con->rollback();
throw \$e;
}
return \$stmt;
}
";
}
}