mDescription = 'Find registered files with no corresponding file.'; $this->addOption( 'start', 'Starting file name', false, true ); $this->setBatchSize( 200 ); } function execute() { $lastName = $this->getOption( 'start', '' ); $repo = RepoGroup::singleton()->getLocalRepo(); $dbr = $repo->getSlaveDB(); $be = $repo->getBackend(); do { $res = $dbr->select( 'image', 'img_name', array( "img_name >= " . $dbr->addQuotes( $lastName ) ), __METHOD__, array( 'ORDER BY' => 'img_name', 'LIMIT' => $this->mBatchSize ) ); // Check if any of these files are missing... $pathsByName = array(); foreach ( $res as $row ) { $file = $repo->newFile( $row->img_name ); $pathsByName[$row->img_name] = $file->getPath(); $lastName = $row->img_name; } $be->preloadFileStat( array( 'srcs' => $pathsByName ) ); foreach ( $pathsByName as $path ) { if ( $be->fileExists( array( 'src' => $path ) ) === false ) { $this->output( "$path\n" ); } } // Find all missing old versions of any of the files in this batch... if ( count( $pathsByName ) ) { $ores = $dbr->select( 'oldimage', array( 'oi_name', 'oi_archive_name' ), array( 'oi_name' => array_keys( $pathsByName ) ), __METHOD__ ); foreach ( $ores as $row ) { if ( !strlen( $row->oi_archive_name ) ) { continue; // broken row } $file = $repo->newFromArchiveName( $row->oi_name, $row->oi_archive_name ); $path = $file->getPath(); if ( $be->fileExists( array( 'src' => $path ) ) === false ) { $this->output( "$path\n" ); } } } } while ( $res->numRows() >= $this->mBatchSize ); } } $maintClass = 'FindMissingFiles'; require_once RUN_MAINTENANCE_IF_MAIN;