diff --git a/Command/CreateDatabaseDoctrineCommand.php b/Command/CreateDatabaseDoctrineCommand.php index d06306648..3c6b7c946 100644 --- a/Command/CreateDatabaseDoctrineCommand.php +++ b/Command/CreateDatabaseDoctrineCommand.php @@ -59,17 +59,17 @@ protected function execute(InputInterface $input, OutputInterface $output) $driverOptions = $params['driverOptions']; } - if (isset($params['master'])) { - $params = $params['master']; - $params['driverOptions'] = $driverOptions; - } - // Since doctrine/dbal 2.11 master has been replaced by primary if (isset($params['primary'])) { $params = $params['primary']; $params['driverOptions'] = $driverOptions; } + if (isset($params['master'])) { + $params = $params['master']; + $params['driverOptions'] = $driverOptions; + } + // Cannot inject `shard` option in parent::getDoctrineConnection // cause it will try to connect to a non-existing database if (isset($params['shards'])) { diff --git a/Command/DropDatabaseDoctrineCommand.php b/Command/DropDatabaseDoctrineCommand.php index df1bbc411..58c2d1147 100644 --- a/Command/DropDatabaseDoctrineCommand.php +++ b/Command/DropDatabaseDoctrineCommand.php @@ -68,17 +68,17 @@ protected function execute(InputInterface $input, OutputInterface $output) $driverOptions = $params['driverOptions']; } - if (isset($params['master'])) { - $params = $params['master']; - $params['driverOptions'] = $driverOptions; - } - // Since doctrine/dbal 2.11 master has been replaced by primary if (isset($params['primary'])) { $params = $params['primary']; $params['driverOptions'] = $driverOptions; } + if (isset($params['master'])) { + $params = $params['master']; + $params['driverOptions'] = $driverOptions; + } + if (isset($params['shards'])) { $shards = $params['shards']; // Default select global