pull latest up to smrtr

bin/up.php

@@ -0,0 +1,12 @@
+<?php
+
+$app = new \Symfony\Component\Console\Application('up');
+
+foreach (\Smrtr\MysqlVersionControl\DbConfig::getEnvironments() as $env) {
+
+    $app->add(
+        new \Smrtr\MysqlVersionControl\UpCommand($env)
+    );
+}
+
+$app->run();

src/Smrtr/MysqlVersionControl/DbConfig.php

@@ -0,0 +1,65 @@
+<?php
+
+namespace Smrtr\MysqlVersionControl;
+use Smrtr\MysqlVersionControlException;
+
+/**
+ * Class DbConfig reads database config from an ini file.
+ *
+ * @package Smrtr\MysqlVersionControl
+ * @author Joe Green
+ */
+class DbConfig
+{
+    public static function getEnvironments()
+    {
+        $config = new \Zend_Config_Ini(self::getConfigFile(), 'environments');
+        $config = $config->toArray();
+        return $config['environments'];
+    }
+
+    public static function getTestingEnvironments()
+    {
+        $config = new \Zend_Config_Ini(self::getConfigFile(), 'environments');
+        $config = $config->toArray();
+        return $config['testing_environments'];
+    }
+
+    public static function getPDO($env, $buildtime = false)
+    {
+        $key = $buildtime ? 'buildtime' : 'runtime';
+        $config = self::getConfig($env);
+        $config = $config[$key];
+
+        $dsn = sprintf('mysql:host=%s;dbname=%s', $config['host'], $config['dbname']);
+        $db = new \PDO($dsn, $config['user'], $config['password']);
+
+        return $db;
+    }
+
+    public static function getConfig($env)
+    {
+        $config = new \Zend_Config_Ini(self::getConfigFile(), $env);
+        return $config->toArray();
+    }
+
+    protected static function getConfigFile()
+    {
+        $configFile = self::getProjectPath() . '/db/db.ini';
+
+        if (!is_readable($configFile)) {
+            throw new MysqlVersionControlException(
+                "Cannot find or open database config; looked in '$configFile'"
+            );
+        }
+
+        return $configFile;
+    }
+
+    protected static function getProjectPath()
+    {
+        $parts = explode('/vendor', __FILE__);
+        array_pop($parts);
+        return implode('/vendor', $parts);
+    }
+}

src/Smrtr/MysqlVersionControl/UpCommand.php

@@ -0,0 +1,245 @@
+<?php
+
+namespace Smrtr\MysqlVersionControl;
+
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Input\InputOption;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Process\Process;
+
+/**
+ * Class UpCommand
+ * @package Smrtr\MysqlVersionControl
+ * @author Joe Green
+ */
+class UpCommand extends Command
+{
+    protected $env;
+
+    public function __construct($env)
+    {
+        $this->env = $env;
+        parent::__construct();
+    }
+
+    protected function configure()
+    {
+        $this
+            ->setName($this->env)
+            ->setDescription('Install the '.$this->env.' versions')
+            ->addArgument(
+                'mysqlbin',
+                InputArgument::OPTIONAL,
+                'Where is the MySQL binary located?'
+            )
+            ->addOption(
+                'confirm',
+                null,
+                InputOption::VALUE_NONE,
+                'If set, the command will bypass the confirmation prompt'
+            )
+        ;
+    }
+
+    /**
+     * Load a few settings then run the installer.
+     *
+     * @param InputInterface $input
+     * @param OutputInterface $output
+     * @return int|null|void
+     */
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        $mysqlbin = $input->getArgument('mysqlbin') ?: 'mysql';
+        $buildConf = DbConfig::getPDO($this->env, true);
+        $runConf = DbConfig::getPDO($this->env);
+
+        // 1. Make sure that db_config table is present
+
+        $output->writeln('');
+        $output->writeln('Checking database status... ');
+        $output->writeln('');
+
+
+        if (!$buildConf instanceof \PDO) {
+            $output->writeln('<error>Failed: unable to obtain a database connection.</error>');
+            return false;
+        }
+
+        if ($buildConf->query("SHOW TABLES LIKE 'db_config'")->rowCount()) {
+
+            $output->writeln('<info>Database version control is already installed.</info>');
+            self::$checkList['db-schema'] = true;
+            return true;
+
+        } else {
+
+            $output->writeln('Installing version control...');
+
+            $result = $buildConf->query(
+"CREATE TABLE `db_config`
+(
+    `key` VARCHAR(50) COLLATE 'utf8_general_ci' NOT NULL,
+    `value` TEXT,
+    `created_at` DATETIME,
+    `updated_at` DATETIME,
+    PRIMARY KEY (`key`),
+    UNIQUE INDEX `db_config_U_1` (`key`)
+) ENGINE=MyISAM;"
+            )
+            ->execute();
+
+            if (!$result) {
+                $output->writeln('<error>Installing version control failed.</error>');
+                return false;
+            }
+
+            $output->writeln('<info>Installed version control successfully.</info>');
+        }
+
+        // 2. Check for current version and available version
+
+        // what is the current version?
+        $query = $runConf->query("SELECT `value` FROM `db_config` WHERE `key`='version'");
+        if ($query->rowCount()) {
+            $versionRow = $query->fetch(\PDO::FETCH_ASSOC);
+            $currentVersion = (int) $versionRow['value'];
+        } else {
+            $currentVersion = 0;
+        }
+
+        // what is the available version?
+        $availableVersion = 0;
+        $versionsPath = realpath(dirname(__FILE__).'/../../../../../../db/versions');
+        foreach (scandir($versionsPath) as $path) {
+            if (preg_match("/^(\\d)+$/", $path) && (int) $path > $availableVersion) {
+                $availableVersion = (int) $path;
+            }
+        }
+
+        if ($currentVersion >= $availableVersion) {
+            $output->writeln('<info>Database version is already up to date.</info>');
+            return true;
+        }
+
+        $noun = ($availableVersion - $currentVersion > 1) ? 'updates' : 'update';
+        $output->writeln(
+            "Installing database $noun (Current version: $currentVersion, Available version: $availableVersion)..."
+        );
+
+        // go from current to latest version, building stack of SQL files
+        $filesToLookFor = [];
+        $filesToLookFor[] = 'schema.sql';           // structural changes, alters, creates, drops
+        $filesToLookFor[] = 'data.sql';             // core data, inserts, replaces, updates, deletes
+        if (in_array($this->env, DbConfig::getTestingEnvironments())) {
+            $filesToLookFor[] = 'testing.sql';      // extra data on top of data.sql for the testing environment(s)
+        }
+        $filesToLookFor[] = 'runme.php';            // custom php hook
+
+        $stack = array();
+        for ($i = $currentVersion + 1; $i <= $availableVersion; $i++) {
+
+            $path = $versionsPath.DIRECTORY_SEPARATOR.$i;
+            if (!is_dir($path) || !is_readable($path)) {
+                continue;
+            }
+
+            foreach ($filesToLookFor as $file) {
+                if (is_readable($path.DIRECTORY_SEPARATOR.$file)) {
+                    $stack[$i][$file] = $path.DIRECTORY_SEPARATOR.$file;
+                }
+            }
+        }
+
+        $s = '\\' == DIRECTORY_SEPARATOR ? "%s" : "'%s'"; // Windows doesn't like quoted params
+        $cmdMySQL = "$mysqlbin -h $s --user=$s --password=$s --database=$s < %s";
+
+        // loop sql file stack and execute on mysql CLI
+
+        $dbConf = DbConfig::getConfig($this->env);
+
+        $previousVersion = $currentVersion;
+        $result = true;
+        foreach ($stack as $version => $files) {
+
+            $output->write($previousVersion." -> $version ");
+
+            if (!$result) {
+                $output->write('skipped');
+                continue;
+            }
+
+            foreach ($files as $file) {
+
+                if ('schema.sql' === $file) {
+                    $conf = $dbConf['buildtime'];
+                } else {
+                    $conf = $dbConf['runtime'];
+                }
+                $host = $conf['host'];
+                $user = $conf['user'];
+                $pass = $conf['password'];
+                $name = $conf['database'];
+
+                if ('.sql' === substr($file, -4)) {
+
+                    $command = sprintf(
+                        $cmdMySQL,
+                        $host,
+                        $user,
+                        $pass,
+                        $name,
+                        $file
+                    );
+
+                    $process = new Process($command);
+                    $process->run();
+
+                    if (!$process->isSuccessful()) {
+                        $result = false;
+                        break;
+                    }
+
+                    continue;
+                }
+
+                if ('.php' === substr($file, -4)) {
+
+                    $feedback = require_once $file;
+                }
+            }
+
+            if ($result) {
+                $result = $buildConf->query(
+                    "REPLACE INTO `db_config` (`key`, `value`, `updated_at`) VALUES ('version', $version, now())"
+                )->execute();
+            }
+
+            $statusMsg = $result ? '<info>OK</info>' : '<error>Failed</error>';
+            $output->write($statusMsg, true);
+
+            if (isset($feedback) && is_string($feedback) && strlen($feedback)) {
+                $output->write($feedback);
+                unset($feedback);
+            }
+
+            if (!$result) {
+                $output->write('<error>'.$process->getErrorOutput().'</error>');
+            }
+
+            $previousVersion = $version;
+        }
+
+        if ($result) {
+            $output->writeln('<info>Database updates installed successfully.</info>');
+            self::$checkList['db-update'] = true;
+            return true;
+
+        } else {
+            $output->writeln('<error>Installing database updates failed.</error>');
+            return false;
+        }
+    }
+}

src/Smrtr/MysqlVersionControlException.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Smrtr;
+
+/**
+ * Class MysqlVersionControlException
+ * @package Smrtr
+ * @author Joe Green
+ */
+class MysqlVersionControlException extends \Exception
+{
+    // Intentionally empty
+}