. */ namespace Doctrine\ODM\MongoDB\Tools\Console\Command\Schema; use Doctrine\ODM\MongoDB\SchemaManager; use Symfony\Component\Console\Input\InputInterface; use Symfony\Component\Console\Input\InputOption; use Symfony\Component\Console\Output\OutputInterface; /** * @author Chris Jones * @author Michał Dąbrowski */ class UpdateCommand extends AbstractCommand { private $dropOrder = array(self::INDEX, self::COLLECTION, self::DB); private $timeout; protected function configure() { $this ->setName('odm:schema:update') ->addOption('class', 'c', InputOption::VALUE_OPTIONAL, 'Document class to process (default: all classes)') ->addOption('timeout', 't', InputOption::VALUE_OPTIONAL, 'Timeout (ms) for acknowledged index creation') ->setDescription('Update indexes for your documents') ; } /** * @param InputInterface $input * @param OutputInterface $output * @return int|null|void */ protected function execute(InputInterface $input, OutputInterface $output) { $class = $input->getOption('class'); $timeout = $input->getOption('timeout'); $this->timeout = isset($timeout) ? (int) $timeout : null; $sm = $this->getSchemaManager(); try { if (isset($class)) { $this->processDocumentIndex($sm, $class); $output->writeln(sprintf('Updated index(es) for %s', $class)); } else { $this->processIndex($sm); $output->writeln('Updated indexes for all classes'); } } catch (\Exception $e) { $output->writeln('' . $e->getMessage() . ''); } } /** * @param SchemaManager $sm * @param object $document */ protected function processDocumentIndex(SchemaManager $sm, $document) { $sm->updateDocumentIndexes($document, $this->timeout); } /** * @param SchemaManager $sm */ protected function processIndex(SchemaManager $sm) { $sm->updateIndexes($this->timeout); } /** * @param SchemaManager $sm * @param object $document * @throws \BadMethodCallException */ protected function processDocumentCollection(SchemaManager $sm, $document) { throw new \BadMethodCallException('Cannot update a document collection'); } /** * @param SchemaManager $sm * @throws \BadMethodCallException */ protected function processCollection(SchemaManager $sm) { throw new \BadMethodCallException('Cannot update a collection'); } /** * @param SchemaManager $sm * @param object $document * @throws \BadMethodCallException */ protected function processDocumentDb(SchemaManager $sm, $document) { throw new \BadMethodCallException('Cannot update a document database'); } /** * @param SchemaManager $sm * @throws \BadMethodCallException */ protected function processDb(SchemaManager $sm) { throw new \BadMethodCallException('Cannot update a database'); } }