Add the UPDATE (the system choose if UP or DOWN the database

Author: byjg

scripts/migrate

@@ -20,4 +20,5 @@ $application->add(new \ByJG\DbMigration\Console\DownCommand());
 $application->add(new \ByJG\DbMigration\Console\CreateCommand());
 $application->add(new \ByJG\DbMigration\Console\DatabaseVersionCommand());
 $application->add(new \ByJG\DbMigration\Console\InstallCommand());
+$application->add(new \ByJG\DbMigration\Console\UpdateCommand());
 $application->run();

src/Console/UpdateCommand.php

@@ -0,0 +1,47 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: jg
+ * Date: 17/06/16
+ * Time: 21:52
+ */
+
+namespace ByJG\DbMigration\Console;
+
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Console\Question\ConfirmationQuestion;
+
+class UpdateCommand extends ConsoleCommand
+{
+    protected function configure()
+    {
+        parent::configure(); 
+        $this
+            ->setName('update')
+            ->setDescription('Migrate Up or Down the database version based on the current database version and the ' .
+                'migration scripts available'
+            );
+
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        $versionInfo = $this->migration->getCurrentVersion();
+        if (strpos($versionInfo['status'], 'partial') !== false) {
+            $helper = $this->getHelper('question');
+            $question = new ConfirmationQuestion(
+                'The database was not fully updated and maybe be unstable. Did you really want migrate the version? (y/N) ',
+                false
+            );
+
+            if (!$helper->ask($input, $output, $question)) {
+                $output->writeln('Aborted.');
+                return;
+            }
+        }
+
+        parent::execute($input, $output);
+        $this->migration->update($this->upTo, true);
+    }
+}

src/Migration.php

@@ -126,6 +126,7 @@ public function getMigrationSql($version, $increment)
                 return $file;
             }
         }
+        return null;
     }
 
     /**
@@ -239,6 +240,23 @@ public function up($upVersion = null, $force = false)
         $this->migrate($upVersion, 1, $force);
     }
 
+    /**
+     * Run all scripts to up or down the database version from current up to latest version or the specified version.
+     *
+     * @param int $upVersion
+     * @param bool $force
+     */
+    public function update($upVersion = null, $force = false)
+    {
+        $versionInfo = $this->getCurrentVersion();
+        $version = intval($versionInfo['version']);
+        $increment = 1;
+        if ($upVersion !== null && $upVersion < $version) {
+            $increment = -1;
+        }
+        $this->migrate($upVersion, $increment, $force);
+    }
+
     /**
      * Run all scripts to down the database version from current version up to the specified version.
      *