Multiple databases

src/Phinx/Config/Config.php

@@ -175,6 +175,36 @@ public function getEnvironment($name)
         return null;
     }
 
+    /**
+     * {@inheritdoc}
+     */
+    public function getStorageConfigs(array $envOptions)
+    {
+
+        $configs = [];
+
+        if (isset($envOptions['default_database'])) {
+            unset($envOptions['default_database']);
+        }
+
+        if (isset($envOptions['default_migration_table'])) {
+            unset($envOptions['default_migration_table']);
+        }
+
+        if (count($envOptions) > 0) {
+            foreach ($envOptions as $dbRef => $adapterOptions) {
+                if (!is_array($adapterOptions)) {
+                    $configs [$dbRef]= $envOptions;
+                    break;
+                } else {
+                    $configs [$dbRef]= array_merge($adapterOptions, ['dbRef' => $dbRef]);
+                }
+            }
+        }
+
+        return $configs;
+    }
+
     /**
      * {@inheritdoc}
      */
@@ -243,16 +273,59 @@ public function getConfigFilePath()
     /**
      * {@inheritdoc}
      */
-    public function getMigrationPaths()
+    public function getMigrationPaths($environment = null, $dbReference = null)
     {
+        $paths = [];
+
         if (!isset($this->values['paths']['migrations'])) {
-            throw new \UnexpectedValueException('Migrations path missing from config file');
+            throw new \UnexpectedValueException('Default migrations path missing from config file');
         }
 
         if (is_string($this->values['paths']['migrations'])) {
             $this->values['paths']['migrations'] = [$this->values['paths']['migrations']];
         }
 
+        if ($environment !== null && $dbReference !== null) {
+            $environment = $this->getEnvironment($environment);
+            if (isset($environment[$dbReference]['paths']['migrations'])) {
+                if (!is_array($environment[$dbReference]['paths']['migrations'])) {
+                    return [$environment[$dbReference]['paths']['migrations']];
+                } else {
+                    foreach ($environment[$dbReference]['paths']['migrations'] as $namespace => $migrationPath) {
+                        $paths[$namespace]= $migrationPath;
+                    }
+                    if (count($paths) > 0) {
+                        $this->values['paths']['migrations']= $paths;
+                    }
+                }
+            }
+        } elseif (is_null($environment) && is_null($dbReference)) {
+            if (isset($this->values['environments']) && is_array($this->values['environments'])) {
+                $environments = array_keys($this->values['environments']);
+
+                foreach ($environments as $env) {
+                    if (is_array($this->values['environments'][$env])) {
+                        foreach ($this->values['environments'][$env] as $dbReference => $properties) {
+                            if (!is_array($properties)) {
+                                continue;
+                            }
+
+                            if (!is_array($this->values['environments'][$env][$dbReference]['paths']['migrations'])) {
+                                $paths []= $this->values['environments'][$env][$dbReference]['paths']['migrations'];
+                            } else {
+                                foreach ($this->values['environments'][$env][$dbReference]['paths']['migrations'] as $namespace => $migrationPath) {
+                                    $paths[$namespace]= $migrationPath;
+                                }
+                            }
+                        }
+                    }
+                }
+                if (count($paths) > 0) {
+                    $this->values['paths']['migrations']= $paths;
+                }
+            }
+        }
+
         return $this->values['paths']['migrations'];
     }
 
@@ -272,8 +345,11 @@ public function getMigrationBaseClassName($dropNamespace = true)
     /**
      * {@inheritdoc}
      */
-    public function getSeedPaths()
+    public function getSeedPaths($environment = null, $dbReference = null)
     {
+
+        $paths = [];
+
         if (!isset($this->values['paths']['seeds'])) {
             throw new \UnexpectedValueException('Seeds path missing from config file');
         }
@@ -282,6 +358,46 @@ public function getSeedPaths()
             $this->values['paths']['seeds'] = [$this->values['paths']['seeds']];
         }
 
+        if ($environment !== null && $dbReference !== null) {
+            $environment = $this->getEnvironment($environment);
+            if (isset($environment[$dbReference]['paths']['seeds'])) {
+                if (!is_array($environment[$dbReference]['paths']['seeds'])) {
+                    return [$environment[$dbReference]['paths']['seeds']];
+                } else {
+                    foreach ($environment[$dbReference]['paths']['seeds'] as $namespace => $seedPath) {
+                        $paths[$namespace]= $seedPath;
+                    }
+                    if (count($paths) > 0) {
+                        $this->values['paths']['seeds']= $paths;
+                    }
+                }
+            }
+        } elseif (is_null($environment) && is_null($dbReference)) {
+            if (isset($this->values['environments']) && is_array($this->values['environments'])) {
+                $environments = array_keys($this->values['environments']);
+                foreach ($environments as $env) {
+                    if (is_array($this->values['environments'][$env])) {
+                        foreach ($this->values['environments'][$env] as $dbReference => $properties) {
+                            if (!is_array($properties)) {
+                                continue;
+                            }
+
+                            if (!is_array($this->values['environments'][$env][$dbReference]['paths']['seeds'])) {
+                                $paths []= $this->values['environments'][$env][$dbReference]['paths']['seeds'];
+                            } else {
+                                foreach ($this->values['environments'][$env][$dbReference]['paths']['seeds'] as $namespace => $migrationPath) {
+                                    $paths[$namespace]= $migrationPath;
+                                }
+                            }
+                        }
+                    }
+                }
+            }
+            if (count($paths) > 0) {
+                $this->values['paths']['seeds']= $paths;
+            }
+        }
+
         return $this->values['paths']['seeds'];
     }
 

src/Phinx/Config/ConfigInterface.php

@@ -56,6 +56,14 @@ public function getEnvironments();
      */
     public function getEnvironment($name);
 
+    /**
+     * Takes combined envOptions and flattens
+     *
+     * @param array $envOptions
+     * @return array
+     */
+    public function getStorageConfigs(array $envOptions);
+
     /**
      * Does the specified environment exist in the configuration file?
      *
@@ -91,16 +99,18 @@ public function getConfigFilePath();
     /**
      * Gets the paths to search for migration files.
      *
+     * @param string $environment
+     * @param string $dbReference
      * @return string[]
      */
-    public function getMigrationPaths();
+    public function getMigrationPaths($environment = null, $dbReference = null);
 
     /**
      * Gets the paths to search for seed files.
      *
      * @return string[]
      */
-    public function getSeedPaths();
+    public function getSeedPaths($environment = null, $dbReference = null);
 
     /**
      * Get the template file name.

src/Phinx/Console/Command/AbstractCommand.php

@@ -343,6 +343,44 @@ protected function verifySeedDirectory($path)
         }
     }
 
+    /**
+     * Output the database information
+     *
+     * @param array $info
+     * @param OutputInterface $output
+     * @return null|int
+     */
+    public function outputEnvironmentInfo(array $info, OutputInterface $output)
+    {
+
+        if (isset($info['adapter'])) {
+            $output->writeln('<info>using adapter</info> ' . $info['adapter']);
+        }
+
+        if (isset($info['wrapper'])) {
+            $output->writeln('<info>using wrapper</info> ' . $info['wrapper']);
+        }
+
+        if (isset($info['id'])) {
+            $output->writeln('<info>using name</info> ' . $info['id']);
+        }
+
+        if (isset($info['name'])) {
+            $output->writeln('<info>using database</info> ' . $info['name']);
+        } else {
+            $output->writeln('<error>Could not determine database name! Please specify a database name in your config file.</error>');
+
+            return 1;
+        }
+
+        if (isset($info['table_prefix'])) {
+            $output->writeln('<info>using table prefix</info> ' . $info['table_prefix']);
+        }
+        if (isset($info['table_suffix'])) {
+            $output->writeln('<info>using table suffix</info> ' . $info['table_suffix']);
+        }
+    }
+
     /**
      * Returns the migration template filename.
      *

src/Phinx/Console/Command/Migrate.php

@@ -70,6 +70,7 @@ protected function configure()
      */
     protected function execute(InputInterface $input, OutputInterface $output)
     {
+
         $this->bootstrap($input, $output);
 
         $version = $input->getOption('target');
@@ -84,38 +85,27 @@ protected function execute(InputInterface $input, OutputInterface $output)
         }
 
         $envOptions = $this->getConfig()->getEnvironment($environment);
-        if (isset($envOptions['adapter'])) {
-            $output->writeln('<info>using adapter</info> ' . $envOptions['adapter']);
-        }
+        $databases = $this->getConfig()->getStorageConfigs($envOptions);
 
-        if (isset($envOptions['wrapper'])) {
-            $output->writeln('<info>using wrapper</info> ' . $envOptions['wrapper']);
-        }
+        // run the migrations
+        $start = microtime(true);
+        foreach ($databases as $adapterOptions) {
+            $this->getManager()->setMigrations(null);
 
-        if (isset($envOptions['name'])) {
-            $output->writeln('<info>using database</info> ' . $envOptions['name']);
-        } else {
-            $output->writeln('<error>Could not determine database name! Please specify a database name in your config file.</error>');
+            if (isset($adapterOptions['dbRef'])) {
+                $this->getManager()->setDbRef($adapterOptions['dbRef']);
+            }
 
-            return 1;
-        }
+            $this->outputEnvironmentInfo($adapterOptions, $output);
 
-        if (isset($envOptions['table_prefix'])) {
-            $output->writeln('<info>using table prefix</info> ' . $envOptions['table_prefix']);
-        }
-        if (isset($envOptions['table_suffix'])) {
-            $output->writeln('<info>using table suffix</info> ' . $envOptions['table_suffix']);
+            if ($date !== null) {
+                $this->getManager()->migrateToDateTime($environment, new \DateTime($date));
+            } else {
+                $this->getManager()->migrate($environment, $version);
+            }
         }
 
-        // run the migrations
-        $start = microtime(true);
-        if ($date !== null) {
-            $this->getManager()->migrateToDateTime($environment, new \DateTime($date));
-        } else {
-            $this->getManager()->migrate($environment, $version);
-        }
         $end = microtime(true);
-
         $output->writeln('');
         $output->writeln('<comment>All Done. Took ' . sprintf('%.4fs', $end - $start) . '</comment>');
 

src/Phinx/Console/Command/Rollback.php

@@ -96,32 +96,32 @@ protected function execute(InputInterface $input, OutputInterface $output)
         }
 
         $envOptions = $config->getEnvironment($environment);
-        if (isset($envOptions['adapter'])) {
-            $output->writeln('<info>using adapter</info> ' . $envOptions['adapter']);
-        }
-
-        if (isset($envOptions['wrapper'])) {
-            $output->writeln('<info>using wrapper</info> ' . $envOptions['wrapper']);
-        }
-
-        if (isset($envOptions['name'])) {
-            $output->writeln('<info>using database</info> ' . $envOptions['name']);
-        }
-
-        $versionOrder = $this->getConfig()->getVersionOrder();
-        $output->writeln('<info>ordering by </info>' . $versionOrder . " time");
-
-        // rollback the specified environment
-        if ($date === null) {
-            $targetMustMatchVersion = true;
-            $target = $version;
-        } else {
-            $targetMustMatchVersion = false;
-            $target = $this->getTargetFromDate($date);
+        $databases = $config->getStorageConfigs($envOptions);
+
+        $start = microtime(true);
+
+        foreach ($databases as $adapterOptions) {
+            // rollback the specified environment
+            if ($date === null) {
+                $targetMustMatchVersion = true;
+                $target = $version;
+            } else {
+                $targetMustMatchVersion = false;
+                $target = $this->getTargetFromDate($date);
+            }
+
+            if (isset($adapterOptions['dbRef'])) {
+                $this->getManager()->setDbRef($adapterOptions['dbRef']);
+            }
+
+            $this->outputEnvironmentInfo($adapterOptions, $output);
+
+            $versionOrder = $this->getConfig()->getVersionOrder();
+            $output->writeln('<info>ordering by </info>' . $versionOrder . " time");
+
+            $this->getManager()->rollback($environment, $target, $force, $targetMustMatchVersion);
         }
 
-        $start = microtime(true);
-        $this->getManager()->rollback($environment, $target, $force, $targetMustMatchVersion);
         $end = microtime(true);
 
         $output->writeln('');