diff options
Diffstat (limited to 'apps/files/lib/Command/DeleteOrphanedFiles.php')
| -rw-r--r-- | apps/files/lib/Command/DeleteOrphanedFiles.php | 38 |
1 files changed, 37 insertions, 1 deletions
diff --git a/apps/files/lib/Command/DeleteOrphanedFiles.php b/apps/files/lib/Command/DeleteOrphanedFiles.php index 4b7179271f5..1b5727ae546 100644 --- a/apps/files/lib/Command/DeleteOrphanedFiles.php +++ b/apps/files/lib/Command/DeleteOrphanedFiles.php @@ -24,9 +24,11 @@ */ namespace OCA\Files\Command; +use OCP\DB\QueryBuilder\IQueryBuilder; use OCP\IDBConnection; use Symfony\Component\Console\Command\Command; use Symfony\Component\Console\Input\InputInterface; +use Symfony\Component\Console\Input\InputOption; use Symfony\Component\Console\Output\OutputInterface; /** @@ -44,7 +46,8 @@ class DeleteOrphanedFiles extends Command { protected function configure(): void { $this ->setName('files:cleanup') - ->setDescription('cleanup filecache'); + ->setDescription('cleanup filecache') + ->addOption('skip-filecache-extended', null, InputOption::VALUE_NONE, 'don\'t remove orphaned entries from filecache_extended'); } public function execute(InputInterface $input, OutputInterface $output): int { @@ -75,11 +78,44 @@ class DeleteOrphanedFiles extends Command { $output->writeln("$deletedEntries orphaned file cache entries deleted"); + if (!$input->getOption('skip-filecache-extended')) { + $deletedFileCacheExtended = $this->cleanupOrphanedFileCacheExtended(); + $output->writeln("$deletedFileCacheExtended orphaned file cache extended entries deleted"); + } + + $deletedMounts = $this->cleanupOrphanedMounts(); $output->writeln("$deletedMounts orphaned mount entries deleted"); return self::SUCCESS; } + private function cleanupOrphanedFileCacheExtended(): int { + $deletedEntries = 0; + + $query = $this->connection->getQueryBuilder(); + $query->select('fce.fileid') + ->from('filecache_extended', 'fce') + ->leftJoin('fce', 'filecache', 'fc', $query->expr()->eq('fce.fileid', 'fc.fileid')) + ->where($query->expr()->isNull('fc.fileid')) + ->setMaxResults(self::CHUNK_SIZE); + + $deleteQuery = $this->connection->getQueryBuilder(); + $deleteQuery->delete('filecache_extended') + ->where($deleteQuery->expr()->in('fileid', $deleteQuery->createParameter('idsToDelete'))); + + $result = $query->executeQuery(); + while ($result->rowCount() > 0) { + $idsToDelete = $result->fetchAll(\PDO::FETCH_COLUMN); + + $deleteQuery->setParameter('idsToDelete', $idsToDelete, IQueryBuilder::PARAM_INT_ARRAY); + $deletedEntries += $deleteQuery->executeStatement(); + + $result = $query->executeQuery(); + } + + return $deletedEntries; + } + private function cleanupOrphanedMounts(): int { $deletedEntries = 0; |