diff --git a/core/Command/Db/ConvertType.php b/core/Command/Db/ConvertType.php index b26494417ec1a..b5d1b9b9330c0 100644 --- a/core/Command/Db/ConvertType.php +++ b/core/Command/Db/ConvertType.php @@ -155,13 +155,6 @@ protected function readPassword(InputInterface $input, OutputInterface $output) } protected function execute(InputInterface $input, OutputInterface $output): int { - // WARNING: - // Leave in place until #45257 is addressed to prevent data loss (hopefully in time for the next maintenance release) - // - throw new \InvalidArgumentException( - 'This command is temporarily disabled (until the next maintenance release).' - ); - $this->validateInput($input, $output); $this->readPassword($input, $output); @@ -229,7 +222,7 @@ protected function createSchema(Connection $fromDB, Connection $toDB, InputInter protected function getToDBConnection(InputInterface $input, OutputInterface $output) { $type = $input->getArgument('type'); - $connectionParams = $this->connectionFactory->createConnectionParams(); + $connectionParams = $this->connectionFactory->createConnectionParams(type: $type); $connectionParams = array_merge($connectionParams, [ 'host' => $input->getArgument('hostname'), 'user' => $input->getArgument('username'), @@ -243,7 +236,7 @@ protected function getToDBConnection(InputInterface $input, OutputInterface $out } // parse hostname for unix socket - if (preg_match('/^(.+)(:(\d+|[^:]+))?$/', $input->getOption('hostname'), $matches)) { + if (preg_match('/^(.+)(:(\d+|[^:]+))?$/', $input->getArgument('hostname'), $matches)) { $connectionParams['host'] = $matches[1]; if (isset($matches[3])) { if (is_numeric($matches[3])) { diff --git a/lib/private/DB/ConnectionFactory.php b/lib/private/DB/ConnectionFactory.php index 8d662b0508ce3..4d286cb30684e 100644 --- a/lib/private/DB/ConnectionFactory.php +++ b/lib/private/DB/ConnectionFactory.php @@ -108,7 +108,7 @@ public function getConnection(string $type, array $additionalConnectionParams): $normalizedType = $this->normalizeType($type); $eventManager = new EventManager(); $eventManager->addEventSubscriber(new SetTransactionIsolationLevel()); - $connectionParams = $this->createConnectionParams('', $additionalConnectionParams); + $connectionParams = $this->createConnectionParams('', $additionalConnectionParams, $type); switch ($normalizedType) { case 'pgsql': // pg_connect used by Doctrine DBAL does not support URI notation (enclosed in brackets) @@ -175,12 +175,10 @@ public function isValidType($type) { /** * Create the connection parameters for the config - * - * @param string $configPrefix - * @return array */ - public function createConnectionParams(string $configPrefix = '', array $additionalConnectionParams = []) { - $type = $this->config->getValue('dbtype', 'sqlite'); + public function createConnectionParams(string $configPrefix = '', array $additionalConnectionParams = [], ?string $type = null) { + // use provided type or if null use type from config + $type = $type ?? $this->config->getValue('dbtype', 'sqlite'); $connectionParams = array_merge($this->getDefaultConnectionParams($type), [ 'user' => $this->config->getValue($configPrefix . 'dbuser', $this->config->getValue('dbuser', '')), @@ -212,7 +210,7 @@ public function createConnectionParams(string $configPrefix = '', array $additio 'tablePrefix' => $connectionParams['tablePrefix'] ]; - if ($this->config->getValue('mysql.utf8mb4', false)) { + if ($type === 'mysql' && $this->config->getValue('mysql.utf8mb4', false)) { $connectionParams['defaultTableOptions'] = [ 'collate' => 'utf8mb4_bin', 'charset' => 'utf8mb4',