diff --git a/Command/CreateDatabaseDoctrineCommand.php b/Command/CreateDatabaseDoctrineCommand.php index cc33dba6c..13db5ef29 100644 --- a/Command/CreateDatabaseDoctrineCommand.php +++ b/Command/CreateDatabaseDoctrineCommand.php @@ -60,17 +60,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 a997ab0fd..dd158075f 100644 --- a/Command/DropDatabaseDoctrineCommand.php +++ b/Command/DropDatabaseDoctrineCommand.php @@ -69,17 +69,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