blob: 599a3ee0785b3f9d28522feb3d0b53c8e8ec5170 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
<?php
namespace gipfl\IcingaWeb2\Zf1\Db;
use gipfl\IcingaWeb2\Data\Paginatable;
use gipfl\ZfDb\Select;
use gipfl\ZfDb\Exception\SelectException;
use Icinga\Application\Benchmark;
use RuntimeException;
use Zend_Db_Select as ZfSelect;
use Zend_Db_Select_Exception as ZfDbSelectException;
class SelectPaginationAdapter implements Paginatable
{
private $query;
private $countQuery;
private $cachedCount;
private $cachedCountQuery;
public function __construct($query)
{
if ($query instanceof Select || $query instanceof ZfSelect) {
$this->query = $query;
} else {
throw new RuntimeException('Got no supported ZF1 Select object');
}
}
public function getCountQuery()
{
if ($this->countQuery === null) {
$this->countQuery = (new CountQuery($this->query))->getQuery();
}
return $this->countQuery;
}
#[\ReturnTypeWillChange]
public function count()
{
$queryString = (string) $this->getCountQuery();
if ($this->cachedCountQuery !== $queryString) {
Benchmark::measure('Running count() for pagination');
$this->cachedCountQuery = $queryString;
$count = $this->query->getAdapter()->fetchOne(
$queryString
);
$this->cachedCount = $count;
Benchmark::measure("Counted $count rows");
}
return $this->cachedCount;
}
public function limit($count = null, $offset = null)
{
$this->query->limit($count, $offset);
}
public function hasLimit()
{
return $this->getLimit() !== null;
}
public function getLimit()
{
return $this->getQueryPart(Select::LIMIT_COUNT);
}
public function setLimit($limit)
{
$this->query->limit(
$limit,
$this->getOffset()
);
}
public function hasOffset()
{
return $this->getOffset() !== null;
}
public function getOffset()
{
return $this->getQueryPart(Select::LIMIT_OFFSET);
}
protected function getQueryPart($part)
{
try {
return $this->query->getPart($part);
} catch (SelectException $e) {
// Will not happen if $part is correct.
throw new RuntimeException($e);
} catch (ZfDbSelectException $e) {
// Will not happen if $part is correct.
throw new RuntimeException($e);
}
}
public function setOffset($offset)
{
$this->query->limit(
$this->getLimit(),
$offset
);
}
}
|
