Implement restore command

Author: raphaelvigee

Command/RestoreCommand.php

@@ -0,0 +1,39 @@
+<?php
+
+namespace RaphaelVigee\GitDoctrineMigrationBundle\Command;
+
+use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+class RestoreCommand extends ContainerAwareCommand
+{
+ protected function configure()
+ {
+ $this
+ // the name of the command (the part after "bin/console")
+ ->setName('git:restore')
+ // the short description shown while running "php bin/console list"
+ ->setDescription('Restore DB dump')
+ // the full command description shown when running the command with
+ // the "--help" option
+ ->setHelp('This command allows you to restore DB dump');
+ }
+
+ protected function execute(InputInterface $input, OutputInterface $output)
+ {
+ $container = $this->getContainer();
+ $dumper = $container->get('raphael_vigee_git_doctrine_migration.mysql.dumper');
+ $git = $container->get('raphael_vigee_git_doctrine_migration.git.service');
+
+ $currentHash = $git->getCurrentHash();
+
+ if (!$dumper->dumpExists($currentHash)) {
+ throw new \Exception(sprintf("Dump file missing for hash %s", $currentHash));
+ }
+
+ $dumpPath = $dumper->getDumpPath($currentHash);
+
+ $dumper->restore($dumpPath, true);
+ }
+}

Dumper/MySQLDumper.php

@@ -42,6 +42,24 @@ public function __construct(EntityManagerInterface $em, GitService $git, $kernel
  $this->fs = new Filesystem();
  }
 
+ public function getDumpPath($hash)
+ {
+ $outFolder = sprintf('%s/../var/git-doctrine-migration', $this->kernelRootDir);
+
+ if (!$this->fs->exists($outFolder)) {
+ $this->fs->mkdir($outFolder, 0700);
+ }
+
+ $outPath = sprintf('%s/%s.sql', $outFolder, $hash);
+
+ return $outPath;
+ }
+
+ public function dumpExists($hash)
+ {
+ return $this->fs->exists($this->getDumpPath($hash));
+ }
+
  /**
  * Dump
  */
@@ -55,13 +73,7 @@ public function dump()
 
  $currentHash = $this->git->getCurrentHash();
 
- $outFolder = sprintf('%s/../var/git-doctrine-migration', $this->kernelRootDir);
-
- if (!$this->fs->exists($outFolder)) {
- $this->fs->mkdir($outFolder, 0700);
- }
-
- $outPath = sprintf('%s/%s.sql', $outFolder, $currentHash);
+ $outPath = $this->getDumpPath($currentHash);
 
  $command = sprintf(
  'mysqldump --user="%s" --password="%s" --host="%s" "%s" > "%s"',
@@ -84,7 +96,7 @@ public function restore($filePath, $force = true)
  $database = $connection->getDatabase();
 
  $command = sprintf(
- 'mysql -u "%s" -p "%s" -h "%s" %s "%s" < "%s"',
+ 'mysql --user="%s" --password="%s" --host="%s" %s "%s" < "%s"',
  $user,
  $password,
  $host,
@@ -93,8 +105,6 @@ public function restore($filePath, $force = true)
  $filePath
  );
 
- die(dump($command));
-
  exec($command);
  }
 }