tyler.durden
/
icingaweb2
mirror of https://github.com/Icinga/icingaweb2.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Implemented conservative count, implemented count 'cache'

This commit is contained in:
Thomas Gelf 2013-08-20 23:15:18 +02:00 committed by Eric Lippmann
parent 0f48d0e2d6
commit 1d1214b8b9
1 changed files with 31 additions and 6 deletions
library/Icinga/Data/Db
Query.php

37
library/Icinga/Data/Db/Query.php
View File

@ -32,6 +32,12 @@ class Query extends AbstractQuery
*/
protected $countColumns;
protected $uglySlowConservativeCount = false;
protected $countCache;
protected $maxCount;
protected function init()
{
$this->db = $this->ds->getConnection()->getDb();
@ -60,7 +66,6 @@ class Query extends AbstractQuery
protected function createQueryObjects()
{
$this->beforeCreatingCountQuery();
$this->beforeCreatingSelectQuery();
$this->selectQuery = clone($this->baseQuery);
$this->selectQuery->columns($this->columns);
@ -74,11 +79,28 @@ class Query extends AbstractQuery
}
}
$this->countQuery = clone($this->baseQuery);
if ($this->countColumns === null) {
$this->countColumns = array('cnt' => 'COUNT(*)');
$this->beforeCreatingCountQuery();
if ($this->uglySlowConservativeCount) {
$query = clone($this->selectQuery);
if ($this->maxCount === null) {
$this->countQuery = $this->db->select()->from(
$query,
'COUNT(*)'
);
} else {
$this->countQuery = $this->db->select()->from(
$query->reset('order')->limit($this->maxCount),
'COUNT(*)'
);
}
} else {
$this->countQuery = clone($this->baseQuery);
if ($this->countColumns === null) {
$this->countColumns = array('cnt' => 'COUNT(*)');
}
$this->countQuery->columns($this->countColumns);
}
$this->countQuery->columns($this->countColumns);
}
protected function beforeCreatingCountQuery()
@ -91,7 +113,10 @@ class Query extends AbstractQuery
public function count()
{
return $this->db->fetchOne($this->getCountQuery());
if ($this->countCache === null) {
$this->countCache = $this->db->fetchOne($this->getCountQuery());
}
return $this->countCache;
}
public function fetchAll()