* * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. */ namespace Snc\RedisBundle\Command; /** * Symfony command to execute redis flushdb * * @author Sebastian Göttschkes */ class RedisFlushdbCommand extends RedisBaseCommand { /** * {@inheritDoc} */ protected function configure() { parent::configure(); $this->setName('redis:flushdb') ->setDescription('Flushes the redis database using the redis flushdb command'); } /** * {@inheritDoc} */ protected function executeRedisCommand() { if ($this->proceedingAllowed()) { $this->flushDbForClient(); } else { $this->output->writeln('Flushing cancelled'); } } /** * Getting the client from cmd option and flush's the db */ private function flushDbForClient() { if ( !($this->redisClient instanceof \IteratorAggregate) || // BC for Predis 1.0 // bug fix https://github.com/nrk/predis/issues/552 !($this->redisClient->getConnection() instanceof \Traversable) ) { $this->redisClient->flushdb(); } else { // flushall in all nodes of cluster foreach ($this->redisClient as $nodeClient) { $nodeClient->flushdb(); } } $this->output->writeln('redis database flushed'); } }