AOEpeople /
crawler
| 1 | <?php |
||
| 707 | ) |
||
| 708 | ->execute(); |
||
| 709 | |||
| 710 | while ($row = $statement->fetch()) { |
||
|
|
|||
| 711 | $configurationsForBranch[] = $row['name']; |
||
| 712 | } |
||
| 713 | return $configurationsForBranch; |
||
| 845 | $statement = $queryBuilder->execute(); |
||
| 846 | |||
| 847 | $rows = []; |
||
| 848 | while ($row = $statement->fetch()) { |
||
| 849 | $rows[$row[$fieldName]] = $row; |
||
| 850 | } |
||
| 851 | |||
| 932 | */ |
||
| 933 | public function getLogEntriesForPageId($id, QueueFilter $queueFilter, $doFlush = false, $doFullFlush = false, $itemsPerPage = 10) |
||
| 934 | { |
||
| 935 | $queryBuilder = GeneralUtility::makeInstance(ConnectionPool::class)->getQueryBuilderForTable($this->tableName); |
||
| 936 | $queryBuilder |
||
| 937 | ->select('*') |
||
| 938 | ->from($this->tableName) |
||
| 939 | ->where( |
||
| 940 | $queryBuilder->expr()->eq('page_id', $queryBuilder->createNamedParameter($id, PDO::PARAM_INT)) |
||
| 941 | ) |
||
| 942 | ->orderBy('scheduled', 'DESC'); |
||
| 943 | |||
| 944 | $expressionBuilder = GeneralUtility::makeInstance(ConnectionPool::class) |
||
| 945 | ->getConnectionForTable($this->tableName) |
||
| 946 | ->getExpressionBuilder(); |
||
| 947 | $query = $expressionBuilder->andX(); |
||
| 948 | // PHPStorm adds the highlight that the $addWhere is immediately overwritten, |
||
| 981 | */ |
||
| 982 | public function getLogEntriesForSetId(int $set_id, string $filter = '', bool $doFlush = false, bool $doFullFlush = false, int $itemsPerPage = 10) |
||
| 983 | { |
||
| 984 | $queryBuilder = GeneralUtility::makeInstance(ConnectionPool::class)->getQueryBuilderForTable($this->tableName); |
||
| 985 | $queryBuilder |
||
| 986 | ->select('*') |
||
| 987 | ->from($this->tableName) |
||
| 988 | ->where( |
||
| 989 | $queryBuilder->expr()->eq('set_id', $queryBuilder->createNamedParameter($set_id, PDO::PARAM_INT)) |
||
| 990 | ) |
||
| 991 | ->orderBy('scheduled', 'DESC'); |
||
| 992 | |||
| 993 | $expressionBuilder = GeneralUtility::makeInstance(ConnectionPool::class) |
||
| 994 | ->getConnectionForTable($this->tableName) |
||
| 995 | ->getExpressionBuilder(); |
||
| 996 | $query = $expressionBuilder->andX(); |
||
| 997 | // PHPStorm adds the highlight that the $addWhere is immediately overwritten, |
||
| 1182 | { |
||
| 1183 | $queryBuilder = GeneralUtility::makeInstance(ConnectionPool::class)->getQueryBuilderForTable(QueueRepository::TABLE_NAME); |
||
| 1184 | $ret = 0; |
||
| 1185 | $this->logger->debug('crawler-readurl start ' . microtime(true)); |
||
| 1186 | |||
| 1187 | $queryBuilder |
||
| 1188 | ->select('*') |
||
| 1708 | */ |
||
| 1709 | public function CLI_releaseProcesses($releaseIds) |
||
| 1710 | { |
||
| 1711 | $queryBuilder = GeneralUtility::makeInstance(ConnectionPool::class)->getQueryBuilderForTable($this->tableName); |
||
| 1712 | |||
| 1713 | if (! is_array($releaseIds)) { |
||
| 1714 | $releaseIds = [$releaseIds]; |
||
| 1810 | { |
||
| 1811 | $realWhere = strlen((string) $where) > 0 ? $where : '1=1'; |
||
| 1812 | |||
| 1813 | $queryBuilder = $this->getQueryBuilder($this->tableName); |
||
| 1814 | |||
| 1815 | $groups = $queryBuilder |
||
| 1816 | ->selectLiteral('DISTINCT set_id') |
||
| 1817 | ->from($this->tableName) |
||
| 1818 | ->where($realWhere) |
||
| 1819 | ->execute() |
||
| 1820 | ->fetchAll(); |
||
| 1821 | if (is_array($groups)) { |
||
| 1822 | foreach ($groups as $group) { |
||
| 1823 | $subSet = $queryBuilder |
||
| 1824 | ->select('qid', 'set_id') |
||
| 1825 | ->from($this->tableName) |
||
| 1826 | ->where( |
||
| 1827 | $realWhere, |
||
| 1828 | $queryBuilder->expr()->eq('set_id', $group['set_id']) |
||
| 1840 | } |
||
| 1841 | |||
| 1842 | $queryBuilder |
||
| 1843 | ->delete($this->tableName) |
||
| 1844 | ->where($realWhere) |
||
| 1845 | ->execute(); |
||
| 1846 | } |
||
| 1862 | |||
| 1863 | $currentTime = $this->getCurrentTime(); |
||
| 1864 | |||
| 1865 | $queryBuilder = GeneralUtility::makeInstance(ConnectionPool::class)->getQueryBuilderForTable($this->tableName); |
||
| 1866 | $queryBuilder |
||
| 1867 | ->select('qid') |
||
| 1868 | ->from(QueueRepository::TABLE_NAME); |
||
| 1979 |
Tomas Norre Mikkelsen
Tizian Schmidlin
Tomas Norre Mikkelsen
Benni Mack
Tomas Votruba
Loading history...
This function has been deprecated. The supplier of the function has supplied an explanatory message.
The explanatory message should give you some clue as to whether and when the function will be removed and what other function to use instead.