*/ class VersionsMapper extends QBMapper { public function __construct(IDBConnection $db) { parent::__construct($db, 'files_versions', VersionEntity::class); } /** * @return VersionEntity[] */ public function findAllVersionsForFileId(int $fileId): array { $qb = $this->db->getQueryBuilder(); $qb->select('*') ->from($this->getTableName()) ->where($qb->expr()->eq('file_id', $qb->createNamedParameter($fileId))); return $this->findEntities($qb); } /** * @return VersionEntity */ public function findCurrentVersionForFileId(int $fileId): VersionEntity { $qb = $this->db->getQueryBuilder(); $qb->select('*') ->from($this->getTableName()) ->where($qb->expr()->eq('file_id', $qb->createNamedParameter($fileId))) ->orderBy('timestamp', 'DESC') ->setMaxResults(1); return $this->findEntity($qb); } public function findVersionForFileId(int $fileId, int $timestamp): VersionEntity { $qb = $this->db->getQueryBuilder(); $qb->select('*') ->from($this->getTableName()) ->where($qb->expr()->eq('file_id', $qb->createNamedParameter($fileId))) ->andWhere($qb->expr()->eq('timestamp', $qb->createNamedParameter($timestamp))); return $this->findEntity($qb); } public function deleteAllVersionsForFileId(int $fileId): int { $qb = $this->db->getQueryBuilder(); return $qb->delete($this->getTableName()) ->where($qb->expr()->eq('file_id', $qb->createNamedParameter($fileId))) ->executeStatement(); } public function deleteAllVersionsForUser(int $storageId, ?string $path = null): void { $fileIdsGenerator = $this->getFileIdsGenerator($storageId, $path); $versionEntitiesDeleteQuery = $this->db->getQueryBuilder(); $versionEntitiesDeleteQuery->delete($this->getTableName()) ->where($versionEntitiesDeleteQuery->expr()->in('file_id', $versionEntitiesDeleteQuery->createParameter('file_ids'))); foreach ($fileIdsGenerator as $fileIds) { $versionEntitiesDeleteQuery->setParameter('file_ids', $fileIds, IQueryBuilder::PARAM_INT_ARRAY); $versionEntitiesDeleteQuery->executeStatement(); } } private function getFileIdsGenerator(int $storageId, ?string $path): \Generator { $offset = 0; do { $filesIdsSelect = $this->db->getQueryBuilder(); $filesIdsSelect->select('fileid') ->from('filecache') ->where($filesIdsSelect->expr()->eq('storage', $filesIdsSelect->createNamedParameter($storageId, IQueryBuilder::PARAM_STR))) ->andWhere($filesIdsSelect->expr()->like('path', $filesIdsSelect->createNamedParameter('files' . ($path ? '/' . $this->db->escapeLikeParameter($path) : '') . '/%', IQueryBuilder::PARAM_STR))) ->andWhere($filesIdsSelect->expr()->gt('fileid', $filesIdsSelect->createParameter('offset'))) ->setMaxResults(1000) ->orderBy('fileid', 'ASC'); $filesIdsSelect->setParameter('offset', $offset, IQueryBuilder::PARAM_INT); $result = $filesIdsSelect->executeQuery(); $fileIds = $result->fetchAll(\PDO::FETCH_COLUMN); $offset = end($fileIds); yield $fileIds; } while (!empty($fileIds)); } }