| @@ 152-166 (lines=15) @@ | ||
| 149 | * |
|
| 150 | * @return Tick[] |
|
| 151 | */ |
|
| 152 | public function getTicksByStatus(string $status): array { |
|
| 153 | ||
| 154 | $ticks = []; |
|
| 155 | ||
| 156 | $qb = $this->getTickSelectSql(); |
|
| 157 | $this->limitToStatus($qb, $status); |
|
| 158 | ||
| 159 | $cursor = $qb->execute(); |
|
| 160 | while ($data = $cursor->fetch()) { |
|
| 161 | $ticks[] = $this->parseTickSelectSql($data); |
|
| 162 | } |
|
| 163 | $cursor->closeCursor(); |
|
| 164 | ||
| 165 | return $ticks; |
|
| 166 | } |
|
| 167 | ||
| 168 | ||
| 169 | /** |
|
| @@ 174-186 (lines=13) @@ | ||
| 171 | * |
|
| 172 | * @return Tick[] |
|
| 173 | */ |
|
| 174 | public function getTicksBySource(string $source): array { |
|
| 175 | $qb = $this->getTickSelectSql(); |
|
| 176 | $this->limitToSource($qb, $source); |
|
| 177 | ||
| 178 | $ticks = []; |
|
| 179 | $cursor = $qb->execute(); |
|
| 180 | while ($data = $cursor->fetch()) { |
|
| 181 | $ticks[] = $this->parseTickSelectSql($data); |
|
| 182 | } |
|
| 183 | $cursor->closeCursor(); |
|
| 184 | ||
| 185 | return $ticks; |
|
| 186 | } |
|
| 187 | ||
| 188 | ||
| 189 | } |
|