nextcloud / server

lib/public/Migration/BigIntMigration.php

Indentation +29 added lines, -29 removed lines

@@ -29,38 +29,38 @@
  */
 abstract class BigIntMigration extends SimpleMigrationStep {
 
-	/**
-	 * @return array Returns an array with the following structure
-	 * ['table1' => ['column1', 'column2'], ...]
-	 * @since 13.0.0
-	 */
-	abstract protected function getColumnsByTable();
+    /**
+     * @return array Returns an array with the following structure
+     * ['table1' => ['column1', 'column2'], ...]
+     * @since 13.0.0
+     */
+    abstract protected function getColumnsByTable();
 
-	/**
-	 * @param IOutput $output
-	 * @param \Closure $schemaClosure The `\Closure` returns a `Schema`
-	 * @param array $options
-	 * @return null|Schema
-	 * @since 13.0.0
-	 */
-	public function changeSchema(IOutput $output, \Closure $schemaClosure, array $options) {
-		/** @var Schema $schema */
-		$schema = $schemaClosure();
+    /**
+     * @param IOutput $output
+     * @param \Closure $schemaClosure The `\Closure` returns a `Schema`
+     * @param array $options
+     * @return null|Schema
+     * @since 13.0.0
+     */
+    public function changeSchema(IOutput $output, \Closure $schemaClosure, array $options) {
+        /** @var Schema $schema */
+        $schema = $schemaClosure();
 
-		$tables = $this->getColumnsByTable();
+        $tables = $this->getColumnsByTable();
 
-		foreach ($tables as $tableName => $columns) {
-			$table = $schema->getTable($tableName);
+        foreach ($tables as $tableName => $columns) {
+            $table = $schema->getTable($tableName);
 
-			foreach ($columns as $columnName) {
-				$column = $table->getColumn($columnName);
-				if ($column->getType()->getName() !== Type::BIGINT) {
-					$column->setType(Type::getType(Type::BIGINT));
-					$column->setOptions(['length' => 20]);
-				}
-			}
-		}
+            foreach ($columns as $columnName) {
+                $column = $table->getColumn($columnName);
+                if ($column->getType()->getName() !== Type::BIGINT) {
+                    $column->setType(Type::getType(Type::BIGINT));
+                    $column->setOptions(['length' => 20]);
+                }
+            }
+        }
 
-		return $schema;
-	}
+        return $schema;
+    }
 }

core/Migrations/Version13000Date20170926101637.php

Indentation +27 added lines, -27 removed lines

@@ -11,32 +11,32 @@
  */
 class Version13000Date20170926101637 extends BigIntMigration {
 
-	/**
-	 * @return array Returns an array with the following structure
-	 * ['table1' => ['column1', 'column2'], ...]
-	 * @since 13.0.0
-	 */
-	protected function getColumnsByTable() {
-		return [
-			'admin_settings' => ['id'],
-			'authtoken' => ['id'],
-			'bruteforce_attempts' => ['id'],
-			'comments' => ['id', 'parent_id', 'topmost_parent_id'],
-			'filecache' => ['fileid', 'storage', 'parent', 'mimetype', 'mimepart'],
-			'file_locks' => ['id'],
-			'jobs' => ['id'],
-			'mimetypes' => ['id'],
-			'mounts' => ['id'],
-			'personal_settings' => ['id'],
-			'properties' => ['id'],
-			'share' => ['id', 'parent', 'file_source'],
-			'storages' => ['numeric_id'],
-			'systemtag' => ['id'],
-			'systemtag_group' => ['systemtagid'],
-			'systemtag_object_mapping' => ['systemtagid'],
-			'vcategory' => ['id'],
-			'vcategory_to_object' => ['objid', 'categoryid'],
-		];
-	}
+    /**
+     * @return array Returns an array with the following structure
+     * ['table1' => ['column1', 'column2'], ...]
+     * @since 13.0.0
+     */
+    protected function getColumnsByTable() {
+        return [
+            'admin_settings' => ['id'],
+            'authtoken' => ['id'],
+            'bruteforce_attempts' => ['id'],
+            'comments' => ['id', 'parent_id', 'topmost_parent_id'],
+            'filecache' => ['fileid', 'storage', 'parent', 'mimetype', 'mimepart'],
+            'file_locks' => ['id'],
+            'jobs' => ['id'],
+            'mimetypes' => ['id'],
+            'mounts' => ['id'],
+            'personal_settings' => ['id'],
+            'properties' => ['id'],
+            'share' => ['id', 'parent', 'file_source'],
+            'storages' => ['numeric_id'],
+            'systemtag' => ['id'],
+            'systemtag_group' => ['systemtagid'],
+            'systemtag_object_mapping' => ['systemtagid'],
+            'vcategory' => ['id'],
+            'vcategory_to_object' => ['objid', 'categoryid'],
+        ];
+    }
 
 }

apps/twofactor_backupcodes/lib/Migration/Version1002Date20170926101419.php

Indentation +10 added lines, -10 removed lines

@@ -11,15 +11,15 @@
  */
 class Version1002Date20170926101419 extends BigIntMigration {
 
-	/**
-	 * @return array Returns an array with the following structure
-	 * ['table1' => ['column1', 'column2'], ...]
-	 * @since 13.0.0
-	 */
-	protected function getColumnsByTable() {
-		return [
-			'twofactor_backupcodes' => ['id'],
-		];
-	}
+    /**
+     * @return array Returns an array with the following structure
+     * ['table1' => ['column1', 'column2'], ...]
+     * @since 13.0.0
+     */
+    protected function getColumnsByTable() {
+        return [
+            'twofactor_backupcodes' => ['id'],
+        ];
+    }
 
 }

apps/dav/lib/Migration/Version1004Date20170926103422.php

Indentation +20 added lines, -20 removed lines

@@ -11,25 +11,25 @@
  */
 class Version1004Date20170926103422 extends BigIntMigration {
 
-	/**
-	 * @return array Returns an array with the following structure
-	 * ['table1' => ['column1', 'column2'], ...]
-	 * @since 13.0.0
-	 */
-	protected function getColumnsByTable() {
-		return [
-			'addressbooks' => ['id'],
-			'addressbookchanges' => ['id', 'addressbookid'],
-			'calendars' => ['id'],
-			'calendarchanges' => ['id', 'calendarid'],
-			'calendarobjects' => ['id', 'calendarid'],
-			'calendarobjects_props' => ['id', 'calendarid', 'objectid'],
-			'calendarsubscriptions' => ['id'],
-			'cards' => ['id', 'addressbookid'],
-			'cards_properties' => ['id', 'addressbookid', 'cardid'],
-			'dav_shares' => ['id', 'resourceid'],
-			'schedulingobjects' => ['id'],
-		];
-	}
+    /**
+     * @return array Returns an array with the following structure
+     * ['table1' => ['column1', 'column2'], ...]
+     * @since 13.0.0
+     */
+    protected function getColumnsByTable() {
+        return [
+            'addressbooks' => ['id'],
+            'addressbookchanges' => ['id', 'addressbookid'],
+            'calendars' => ['id'],
+            'calendarchanges' => ['id', 'calendarid'],
+            'calendarobjects' => ['id', 'calendarid'],
+            'calendarobjects_props' => ['id', 'calendarid', 'objectid'],
+            'calendarsubscriptions' => ['id'],
+            'cards' => ['id', 'addressbookid'],
+            'cards_properties' => ['id', 'addressbookid', 'cardid'],
+            'dav_shares' => ['id', 'resourceid'],
+            'schedulingobjects' => ['id'],
+        ];
+    }
 
 }

lib/private/DB/OCPostgreSqlPlatform.php

Indentation +59 added lines, -59 removed lines

@@ -28,67 +28,67 @@
 
 class OCPostgreSqlPlatform extends PostgreSqlPlatform {
 
-	/**
-	 * {@inheritDoc}
-	 */
-	public function getAlterTableSQL(TableDiff $diff){
-		$queries = parent::getAlterTableSQL($diff);
-		foreach ($queries as $index => $sql){
-			// BIGSERIAL could not be used in statements altering column type
-			// That's why we replace it with BIGINT 
-			// see https://github.com/owncloud/core/pull/28364#issuecomment-315006853
-			if (preg_match('|(ALTER TABLE\s+\S+\s+ALTER\s+\S+\s+TYPE\s+)(BIGSERIAL)|i', $sql, $matches)) {
-				$alterTable = $matches[1];
-				$queries[$index] = $alterTable . 'BIGINT';
-			}
+    /**
+     * {@inheritDoc}
+     */
+    public function getAlterTableSQL(TableDiff $diff){
+        $queries = parent::getAlterTableSQL($diff);
+        foreach ($queries as $index => $sql){
+            // BIGSERIAL could not be used in statements altering column type
+            // That's why we replace it with BIGINT 
+            // see https://github.com/owncloud/core/pull/28364#issuecomment-315006853
+            if (preg_match('|(ALTER TABLE\s+\S+\s+ALTER\s+\S+\s+TYPE\s+)(BIGSERIAL)|i', $sql, $matches)) {
+                $alterTable = $matches[1];
+                $queries[$index] = $alterTable . 'BIGINT';
+            }
 
-			// Changing integer to bigint kills next autoincrement value
-			// see https://github.com/owncloud/core/pull/28364#issuecomment-315006853
-			if (preg_match('|ALTER TABLE\s+(\S+)\s+ALTER\s+(\S+)\s+DROP DEFAULT|i', $sql, $matches)) {
-				$queryColumnName = $matches[2];
-				$columnDiff = $this->findColumnDiffByName($diff, $queryColumnName);
-				if ($columnDiff && $this->shouldSkipDropDefault($columnDiff)) {
-					unset($queries[$index]);
-					continue;
-				}
-			}
-		}
+            // Changing integer to bigint kills next autoincrement value
+            // see https://github.com/owncloud/core/pull/28364#issuecomment-315006853
+            if (preg_match('|ALTER TABLE\s+(\S+)\s+ALTER\s+(\S+)\s+DROP DEFAULT|i', $sql, $matches)) {
+                $queryColumnName = $matches[2];
+                $columnDiff = $this->findColumnDiffByName($diff, $queryColumnName);
+                if ($columnDiff && $this->shouldSkipDropDefault($columnDiff)) {
+                    unset($queries[$index]);
+                    continue;
+                }
+            }
+        }
 		
-		return $queries;
-	}
+        return $queries;
+    }
 
-	/**
-	 * We should NOT drop next sequence value if
-	 * - type was changed from INTEGER to BIGINT
-	 * - column keeps an autoincrement
-	 * - default value is kept NULL
-	 *
-	 * @param ColumnDiff $columnDiff
-	 * @return bool
-	 */
-	private function shouldSkipDropDefault(ColumnDiff $columnDiff) {
-		$column = $columnDiff->column;
-		$fromColumn = $columnDiff->fromColumn;
-		return $fromColumn->getType()->getName() === Type::INTEGER
-				&& $column->getType()->getName() === Type::BIGINT
-				&& $fromColumn->getDefault() === null
-				&& $column->getDefault() === null
-				&& $fromColumn->getAutoincrement()
-				&& $column->getAutoincrement();
-	}
+    /**
+     * We should NOT drop next sequence value if
+     * - type was changed from INTEGER to BIGINT
+     * - column keeps an autoincrement
+     * - default value is kept NULL
+     *
+     * @param ColumnDiff $columnDiff
+     * @return bool
+     */
+    private function shouldSkipDropDefault(ColumnDiff $columnDiff) {
+        $column = $columnDiff->column;
+        $fromColumn = $columnDiff->fromColumn;
+        return $fromColumn->getType()->getName() === Type::INTEGER
+                && $column->getType()->getName() === Type::BIGINT
+                && $fromColumn->getDefault() === null
+                && $column->getDefault() === null
+                && $fromColumn->getAutoincrement()
+                && $column->getAutoincrement();
+    }
 
-	/**
-	 * @param TableDiff $diff
-	 * @param string $name
-	 * @return  ColumnDiff | false
-	 */
-	private function findColumnDiffByName(TableDiff $diff, $name) {
-		foreach ($diff->changedColumns as $columnDiff) {
-			$oldColumnName = $columnDiff->getOldColumnName()->getQuotedName($this);
-			if ($oldColumnName === $name) {
-				return $columnDiff;
-			}
-		}
-		return false;
-	}
+    /**
+     * @param TableDiff $diff
+     * @param string $name
+     * @return  ColumnDiff | false
+     */
+    private function findColumnDiffByName(TableDiff $diff, $name) {
+        foreach ($diff->changedColumns as $columnDiff) {
+            $oldColumnName = $columnDiff->getOldColumnName()->getQuotedName($this);
+            if ($oldColumnName === $name) {
+                return $columnDiff;
+            }
+        }
+        return false;
+    }
 }

Spacing +3 added lines, -3 removed lines

@@ -31,15 +31,15 @@
 	/**
 	 * {@inheritDoc}
 	 */
-	public function getAlterTableSQL(TableDiff $diff){
+	public function getAlterTableSQL(TableDiff $diff) {
 		$queries = parent::getAlterTableSQL($diff);
-		foreach ($queries as $index => $sql){
+		foreach ($queries as $index => $sql) {
 			// BIGSERIAL could not be used in statements altering column type
 			// That's why we replace it with BIGINT 
 			// see https://github.com/owncloud/core/pull/28364#issuecomment-315006853
 			if (preg_match('|(ALTER TABLE\s+\S+\s+ALTER\s+\S+\s+TYPE\s+)(BIGSERIAL)|i', $sql, $matches)) {
 				$alterTable = $matches[1];
-				$queries[$index] = $alterTable . 'BIGINT';
+				$queries[$index] = $alterTable.'BIGINT';
 			}
 
 			// Changing integer to bigint kills next autoincrement value

lib/private/DB/ConnectionFactory.php

Indentation +197 added lines, -197 removed lines

@@ -37,201 +37,201 @@
  * Takes care of creating and configuring Doctrine connections.
  */
 class ConnectionFactory {
-	/**
-	 * @var array
-	 *
-	 * Array mapping DBMS type to default connection parameters passed to
-	 * \Doctrine\DBAL\DriverManager::getConnection().
-	 */
-	protected $defaultConnectionParams = [
-		'mysql' => [
-			'adapter' => '\OC\DB\AdapterMySQL',
-			'charset' => 'UTF8',
-			'driver' => 'pdo_mysql',
-			'wrapperClass' => 'OC\DB\Connection',
-		],
-		'oci' => [
-			'adapter' => '\OC\DB\AdapterOCI8',
-			'charset' => 'AL32UTF8',
-			'driver' => 'oci8',
-			'wrapperClass' => 'OC\DB\OracleConnection',
-		],
-		'pgsql' => [
-			'adapter' => '\OC\DB\AdapterPgSql',
-			'driver' => 'pdo_pgsql',
-			'wrapperClass' => 'OC\DB\Connection',
-		],
-		'sqlite3' => [
-			'adapter' => '\OC\DB\AdapterSqlite',
-			'driver' => 'pdo_sqlite',
-			'wrapperClass' => 'OC\DB\Connection',
-		],
-	];
-
-	/** @var SystemConfig */
-	private $config;
-
-	/**
-	 * ConnectionFactory constructor.
-	 *
-	 * @param SystemConfig $systemConfig
-	 */
-	public function __construct(SystemConfig $systemConfig) {
-		$this->config = $systemConfig;
-		if ($this->config->getValue('mysql.utf8mb4', false)) {
-			$this->defaultConnectionParams['mysql']['charset'] = 'utf8mb4';
-		}
-	}
-
-	/**
-	 * @brief Get default connection parameters for a given DBMS.
-	 * @param string $type DBMS type
-	 * @throws \InvalidArgumentException If $type is invalid
-	 * @return array Default connection parameters.
-	 */
-	public function getDefaultConnectionParams($type) {
-		$normalizedType = $this->normalizeType($type);
-		if (!isset($this->defaultConnectionParams[$normalizedType])) {
-			throw new \InvalidArgumentException("Unsupported type: $type");
-		}
-		$result = $this->defaultConnectionParams[$normalizedType];
-		// \PDO::MYSQL_ATTR_FOUND_ROWS may not be defined, e.g. when the MySQL
-		// driver is missing. In this case, we won't be able to connect anyway.
-		if ($normalizedType === 'mysql' && defined('\PDO::MYSQL_ATTR_FOUND_ROWS')) {
-			$result['driverOptions'] = array(
-				\PDO::MYSQL_ATTR_FOUND_ROWS => true,
-			);
-		}
-		return $result;
-	}
-
-	/**
-	 * @brief Get default connection parameters for a given DBMS.
-	 * @param string $type DBMS type
-	 * @param array $additionalConnectionParams Additional connection parameters
-	 * @return \OC\DB\Connection
-	 */
-	public function getConnection($type, $additionalConnectionParams) {
-		$normalizedType = $this->normalizeType($type);
-		$eventManager = new EventManager();
-		switch ($normalizedType) {
-			case 'mysql':
-				$eventManager->addEventSubscriber(
-					new SQLSessionInit("SET SESSION AUTOCOMMIT=1"));
-				break;
-			case 'oci':
-				$eventManager->addEventSubscriber(new OracleSessionInit);
-				// the driverOptions are unused in dbal and need to be mapped to the parameters
-				if (isset($additionalConnectionParams['driverOptions'])) {
-					$additionalConnectionParams = array_merge($additionalConnectionParams, $additionalConnectionParams['driverOptions']);
-				}
-				$host = $additionalConnectionParams['host'];
-				$port = isset($additionalConnectionParams['port']) ? $additionalConnectionParams['port'] : null;
-				$dbName = $additionalConnectionParams['dbname'];
-
-				// we set the connect string as dbname and unset the host to coerce doctrine into using it as connect string
-				if ($host === '') {
-					$additionalConnectionParams['dbname'] = $dbName; // use dbname as easy connect name
-				} else {
-					$additionalConnectionParams['dbname'] = '//' . $host . (!empty($port) ? ":{$port}" : "") . '/' . $dbName;
-				}
-				unset($additionalConnectionParams['host']);
-				break;
-
-			case 'pgsql':
-				$additionalConnectionParams['platform'] = new OCPostgreSqlPlatform();
-				break;
-			case 'sqlite3':
-				$journalMode = $additionalConnectionParams['sqlite.journal_mode'];
-				$additionalConnectionParams['platform'] = new OCSqlitePlatform();
-				$eventManager->addEventSubscriber(new SQLiteSessionInit(true, $journalMode));
-				break;
-		}
-		/** @var Connection $connection */
-		$connection = DriverManager::getConnection(
-			array_merge($this->getDefaultConnectionParams($type), $additionalConnectionParams),
-			new Configuration(),
-			$eventManager
-		);
-		return $connection;
-	}
-
-	/**
-	 * @brief Normalize DBMS type
-	 * @param string $type DBMS type
-	 * @return string Normalized DBMS type
-	 */
-	public function normalizeType($type) {
-		return $type === 'sqlite' ? 'sqlite3' : $type;
-	}
-
-	/**
-	 * Checks whether the specified DBMS type is valid.
-	 *
-	 * @param string $type
-	 * @return bool
-	 */
-	public function isValidType($type) {
-		$normalizedType = $this->normalizeType($type);
-		return isset($this->defaultConnectionParams[$normalizedType]);
-	}
-
-	/**
-	 * Create the connection parameters for the config
-	 *
-	 * @return array
-	 */
-	public function createConnectionParams() {
-		$type = $this->config->getValue('dbtype', 'sqlite');
-
-		$connectionParams = [
-			'user' => $this->config->getValue('dbuser', ''),
-			'password' => $this->config->getValue('dbpassword', ''),
-		];
-		$name = $this->config->getValue('dbname', 'owncloud');
-
-		if ($this->normalizeType($type) === 'sqlite3') {
-			$dataDir = $this->config->getValue("datadirectory", \OC::$SERVERROOT . '/data');
-			$connectionParams['path'] = $dataDir . '/' . $name . '.db';
-		} else {
-			$host = $this->config->getValue('dbhost', '');
-			if (strpos($host, ':')) {
-				// Host variable may carry a port or socket.
-				list($host, $portOrSocket) = explode(':', $host, 2);
-				if (ctype_digit($portOrSocket)) {
-					$connectionParams['port'] = $portOrSocket;
-				} else {
-					$connectionParams['unix_socket'] = $portOrSocket;
-				}
-			}
-			$connectionParams['host'] = $host;
-			$connectionParams['dbname'] = $name;
-		}
-
-		$connectionParams['tablePrefix'] = $this->config->getValue('dbtableprefix', 'oc_');
-		$connectionParams['sqlite.journal_mode'] = $this->config->getValue('sqlite.journal_mode', 'WAL');
-
-		//additional driver options, eg. for mysql ssl
-		$driverOptions = $this->config->getValue('dbdriveroptions', null);
-		if ($driverOptions) {
-			$connectionParams['driverOptions'] = $driverOptions;
-		}
-
-		// set default table creation options
-		$connectionParams['defaultTableOptions'] = [
-			'collate' => 'utf8_bin',
-			'tablePrefix' => $connectionParams['tablePrefix']
-		];
-
-		if ($this->config->getValue('mysql.utf8mb4', false)) {
-			$connectionParams['defaultTableOptions'] = [
-				'collate' => 'utf8mb4_bin',
-				'charset' => 'utf8mb4',
-				'row_format' => 'compressed',
-				'tablePrefix' => $connectionParams['tablePrefix']
-			];
-		}
-
-		return $connectionParams;
-	}
+    /**
+     * @var array
+     *
+     * Array mapping DBMS type to default connection parameters passed to
+     * \Doctrine\DBAL\DriverManager::getConnection().
+     */
+    protected $defaultConnectionParams = [
+        'mysql' => [
+            'adapter' => '\OC\DB\AdapterMySQL',
+            'charset' => 'UTF8',
+            'driver' => 'pdo_mysql',
+            'wrapperClass' => 'OC\DB\Connection',
+        ],
+        'oci' => [
+            'adapter' => '\OC\DB\AdapterOCI8',
+            'charset' => 'AL32UTF8',
+            'driver' => 'oci8',
+            'wrapperClass' => 'OC\DB\OracleConnection',
+        ],
+        'pgsql' => [
+            'adapter' => '\OC\DB\AdapterPgSql',
+            'driver' => 'pdo_pgsql',
+            'wrapperClass' => 'OC\DB\Connection',
+        ],
+        'sqlite3' => [
+            'adapter' => '\OC\DB\AdapterSqlite',
+            'driver' => 'pdo_sqlite',
+            'wrapperClass' => 'OC\DB\Connection',
+        ],
+    ];
+
+    /** @var SystemConfig */
+    private $config;
+
+    /**
+     * ConnectionFactory constructor.
+     *
+     * @param SystemConfig $systemConfig
+     */
+    public function __construct(SystemConfig $systemConfig) {
+        $this->config = $systemConfig;
+        if ($this->config->getValue('mysql.utf8mb4', false)) {
+            $this->defaultConnectionParams['mysql']['charset'] = 'utf8mb4';
+        }
+    }
+
+    /**
+     * @brief Get default connection parameters for a given DBMS.
+     * @param string $type DBMS type
+     * @throws \InvalidArgumentException If $type is invalid
+     * @return array Default connection parameters.
+     */
+    public function getDefaultConnectionParams($type) {
+        $normalizedType = $this->normalizeType($type);
+        if (!isset($this->defaultConnectionParams[$normalizedType])) {
+            throw new \InvalidArgumentException("Unsupported type: $type");
+        }
+        $result = $this->defaultConnectionParams[$normalizedType];
+        // \PDO::MYSQL_ATTR_FOUND_ROWS may not be defined, e.g. when the MySQL
+        // driver is missing. In this case, we won't be able to connect anyway.
+        if ($normalizedType === 'mysql' && defined('\PDO::MYSQL_ATTR_FOUND_ROWS')) {
+            $result['driverOptions'] = array(
+                \PDO::MYSQL_ATTR_FOUND_ROWS => true,
+            );
+        }
+        return $result;
+    }
+
+    /**
+     * @brief Get default connection parameters for a given DBMS.
+     * @param string $type DBMS type
+     * @param array $additionalConnectionParams Additional connection parameters
+     * @return \OC\DB\Connection
+     */
+    public function getConnection($type, $additionalConnectionParams) {
+        $normalizedType = $this->normalizeType($type);
+        $eventManager = new EventManager();
+        switch ($normalizedType) {
+            case 'mysql':
+                $eventManager->addEventSubscriber(
+                    new SQLSessionInit("SET SESSION AUTOCOMMIT=1"));
+                break;
+            case 'oci':
+                $eventManager->addEventSubscriber(new OracleSessionInit);
+                // the driverOptions are unused in dbal and need to be mapped to the parameters
+                if (isset($additionalConnectionParams['driverOptions'])) {
+                    $additionalConnectionParams = array_merge($additionalConnectionParams, $additionalConnectionParams['driverOptions']);
+                }
+                $host = $additionalConnectionParams['host'];
+                $port = isset($additionalConnectionParams['port']) ? $additionalConnectionParams['port'] : null;
+                $dbName = $additionalConnectionParams['dbname'];
+
+                // we set the connect string as dbname and unset the host to coerce doctrine into using it as connect string
+                if ($host === '') {
+                    $additionalConnectionParams['dbname'] = $dbName; // use dbname as easy connect name
+                } else {
+                    $additionalConnectionParams['dbname'] = '//' . $host . (!empty($port) ? ":{$port}" : "") . '/' . $dbName;
+                }
+                unset($additionalConnectionParams['host']);
+                break;
+
+            case 'pgsql':
+                $additionalConnectionParams['platform'] = new OCPostgreSqlPlatform();
+                break;
+            case 'sqlite3':
+                $journalMode = $additionalConnectionParams['sqlite.journal_mode'];
+                $additionalConnectionParams['platform'] = new OCSqlitePlatform();
+                $eventManager->addEventSubscriber(new SQLiteSessionInit(true, $journalMode));
+                break;
+        }
+        /** @var Connection $connection */
+        $connection = DriverManager::getConnection(
+            array_merge($this->getDefaultConnectionParams($type), $additionalConnectionParams),
+            new Configuration(),
+            $eventManager
+        );
+        return $connection;
+    }
+
+    /**
+     * @brief Normalize DBMS type
+     * @param string $type DBMS type
+     * @return string Normalized DBMS type
+     */
+    public function normalizeType($type) {
+        return $type === 'sqlite' ? 'sqlite3' : $type;
+    }
+
+    /**
+     * Checks whether the specified DBMS type is valid.
+     *
+     * @param string $type
+     * @return bool
+     */
+    public function isValidType($type) {
+        $normalizedType = $this->normalizeType($type);
+        return isset($this->defaultConnectionParams[$normalizedType]);
+    }
+
+    /**
+     * Create the connection parameters for the config
+     *
+     * @return array
+     */
+    public function createConnectionParams() {
+        $type = $this->config->getValue('dbtype', 'sqlite');
+
+        $connectionParams = [
+            'user' => $this->config->getValue('dbuser', ''),
+            'password' => $this->config->getValue('dbpassword', ''),
+        ];
+        $name = $this->config->getValue('dbname', 'owncloud');
+
+        if ($this->normalizeType($type) === 'sqlite3') {
+            $dataDir = $this->config->getValue("datadirectory", \OC::$SERVERROOT . '/data');
+            $connectionParams['path'] = $dataDir . '/' . $name . '.db';
+        } else {
+            $host = $this->config->getValue('dbhost', '');
+            if (strpos($host, ':')) {
+                // Host variable may carry a port or socket.
+                list($host, $portOrSocket) = explode(':', $host, 2);
+                if (ctype_digit($portOrSocket)) {
+                    $connectionParams['port'] = $portOrSocket;
+                } else {
+                    $connectionParams['unix_socket'] = $portOrSocket;
+                }
+            }
+            $connectionParams['host'] = $host;
+            $connectionParams['dbname'] = $name;
+        }
+
+        $connectionParams['tablePrefix'] = $this->config->getValue('dbtableprefix', 'oc_');
+        $connectionParams['sqlite.journal_mode'] = $this->config->getValue('sqlite.journal_mode', 'WAL');
+
+        //additional driver options, eg. for mysql ssl
+        $driverOptions = $this->config->getValue('dbdriveroptions', null);
+        if ($driverOptions) {
+            $connectionParams['driverOptions'] = $driverOptions;
+        }
+
+        // set default table creation options
+        $connectionParams['defaultTableOptions'] = [
+            'collate' => 'utf8_bin',
+            'tablePrefix' => $connectionParams['tablePrefix']
+        ];
+
+        if ($this->config->getValue('mysql.utf8mb4', false)) {
+            $connectionParams['defaultTableOptions'] = [
+                'collate' => 'utf8mb4_bin',
+                'charset' => 'utf8mb4',
+                'row_format' => 'compressed',
+                'tablePrefix' => $connectionParams['tablePrefix']
+            ];
+        }
+
+        return $connectionParams;
+    }
 }