Added the command line "migrate" script

Author: byjg

composer.json

@@ -1,19 +1,23 @@
 {
-    "name": "byjg/migration",
-    "description": "A micro framework in PHP for managing a set of database migrations using pure Sql.",
-    "authors": [
-        {
-            "name": "jg",
-            "email": "joao@byjg.com.br"
-        }
-    ],
-    "require": {
-        "byjg/anydataset": "2.1.*"
-    },
-    "autoload": {
-        "psr-4": {
-            "ByJG\\DbMigration\\": "src/"
-        }
-    },
-    "license": "MIT"
+  "name": "byjg/migration",
+  "description": "A micro framework in PHP for managing a set of database migrations using pure Sql.",
+  "authors": [
+    {
+      "name": "jg",
+      "email": "joao@byjg.com.br"
+    }
+  ],
+  "require": {
+    "byjg/anydataset": "2.1.*",
+    "symfony/console": "3.1.*"
+  },
+  "autoload": {
+    "psr-4": {
+      "ByJG\\DbMigration\\": "src/"
+    }
+  },
+  "bin": [
+    "scripts/migrate"
+  ],
+  "license": "MIT"
 }

scripts/migrate

@@ -0,0 +1,20 @@
+#!/usr/bin/env php
+<?php
+
+$autoload = realpath(__DIR__."/../vendor/autoload.php");
+if (!file_exists($autoload)) {
+    $autoload = realpath(__DIR__."/../../../autoload.php");
+    if (!file_exists($autoload)) {
+        throw new \Exception('Autoload not found. Did you run `composer dump-autload`?');
+    }
+}
+require_once($autoload);
+
+
+use Symfony\Component\Console\Application;
+
+$application = new Application('Migrate Script by JG', '1.0.2');
+$application->add(new \ByJG\DbMigration\Console\ResetCommand());
+$application->add(new \ByJG\DbMigration\Console\UpCommand());
+$application->add(new \ByJG\DbMigration\Console\DownCommand());
+$application->run();

src/Console/ConsoleCommand.php

@@ -0,0 +1,92 @@
+<?php
+
+namespace ByJG\DbMigration\Console;
+
+use ByJG\AnyDataset\ConnectionManagement;
+use ByJG\DbMigration\Migration;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Exception\InvalidArgumentException;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Input\InputOption;
+use Symfony\Component\Console\Output\OutputInterface;
+
+abstract class ConsoleCommand extends Command
+{
+    protected function configure()
+    {
+        $this
+            ->addArgument(
+                'connection',
+                InputArgument::OPTIONAL,
+                'The connection string. Ex. mysql://root:password@server/database',
+                getenv('MIGRATE_CONNECTION')
+            )
+            ->addOption(
+                'path',
+                'p',
+                InputOption::VALUE_OPTIONAL,
+                'Define the path where the base.sql resides. If not set assumes the current folder'
+            )
+            ->addOption(
+                'up-to',
+                'u',
+                InputOption::VALUE_OPTIONAL,
+                'Run up to the specified version'
+            )
+            ->addUsage('')
+            ->addUsage('Example: ')
+            ->addUsage('   migrate reset mysql://root:password@server/database')
+            ->addUsage('   migrate up mysql://root:password@server/database')
+            ->addUsage('   migrate down mysql://root:password@server/database')
+            ->addUsage('   migrate up --up-to=10 --path=/somepath mysql://root:password@server/database')
+            ->addUsage('   migrate down --up-to=3 --path=/somepath mysql://root:password@server/database')
+        ;
+    }
+
+    /**
+     * @var Migration
+     */
+    protected $migration;
+
+    protected $upTo;
+
+    protected $connection;
+
+    protected $path;
+
+    protected function initialize(InputInterface $input, OutputInterface $output)
+    {
+        $this->connection = $input->getArgument('connection');
+        if (!$this->connection) {
+            throw new InvalidArgumentException('You need to setup the connection in the argument or setting the environment MIGRATE_CONNECTION');
+        }
+
+        $this->path = $input->getOption('path');
+        if (!$this->path) {
+            $this->path = ".";
+        }
+        $this->path = realpath($this->path);
+
+        $this->upTo = $input->getOption('up-to');
+
+        $connectionObject = new ConnectionManagement($this->connection);
+        $this->migration = new Migration($connectionObject, $this->path);
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        if ($output->getVerbosity() >= OutputInterface::VERBOSITY_VERBOSE) {
+            $output->writeln('Connection String: ' . $this->connection);
+            $output->writeln('Path: ' . $this->path);
+        }
+
+        if ($output->getVerbosity() >= OutputInterface::VERBOSITY_VERY_VERBOSE) {
+            $this->migration->addCallbackProgress(function($command, $version) use ($output) {
+                $output->writeln('Doing: ' . $command . " to " . $version);
+            });
+        }
+    }
+
+
+}

src/Console/DownCommand.php

@@ -0,0 +1,31 @@
+<?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;
+
+class DownCommand extends ConsoleCommand
+{
+    protected function configure()
+    {
+        parent::configure(); 
+        $this
+            ->setName('down')
+            ->setDescription('Migrate down the database version.');
+
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        parent::execute($input, $output);
+        $this->migration->down($this->upTo);
+    }
+
+}

src/Console/ResetCommand.php

@@ -0,0 +1,32 @@
+<?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;
+
+class ResetCommand extends ConsoleCommand
+{
+    protected function configure()
+    {
+        parent::configure(); 
+        $this
+            ->setName('reset')
+            ->setDescription('Create a fresh new database');
+
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        parent::execute($input, $output);
+        $this->migration->prepareEnvironment();
+        $this->migration->reset($this->upTo);
+    }
+
+}

src/Console/UpCommand.php

@@ -0,0 +1,30 @@
+<?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;
+
+class UpCommand extends ConsoleCommand
+{
+    protected function configure()
+    {
+        parent::configure(); 
+        $this
+            ->setName('up')
+            ->setDescription('Migrate Up the database version');
+
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        parent::execute($input, $output);
+        $this->migration->up($this->upTo);
+    }
+}