More code for up command

Author: joegreen88

src/Smrtr/MysqlVersionControl/DbConfig.php

@@ -18,6 +18,13 @@ public static function getEnvironments()
         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';

src/Smrtr/MysqlVersionControl/UpCommand.php

@@ -2,12 +2,12 @@
 
 namespace Smrtr\MysqlVersionControl;
 
-use Symfony\Component\Console\Application;
 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
@@ -52,12 +52,194 @@ protected function configure()
      */
     protected function execute(InputInterface $input, OutputInterface $output)
     {
-        Controller::update(
-            $this->env,
-            $output,
-            $this->getHelperSet()->get('dialog'),
-            (bool) $input->getOption('confirm'),
-            $input->getArgument('mysqlbin') ?: 'mysql'
+        $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;
+        }
     }
 }