nextcloud / server

lib/public/IDBConnection.php

Indentation +364 added lines, -364 removed lines

@@ -24,368 +24,368 @@
  * @since 6.0.0
  */
 interface IDBConnection {
-	/**
-	 * @since 28.0.0
-	 */
-	public const PLATFORM_MYSQL = 'mysql';
-
-	/**
-	 * @since 28.0.0
-	 */
-	public const PLATFORM_ORACLE = 'oracle';
-
-	/**
-	 * @since 28.0.0
-	 */
-	public const PLATFORM_POSTGRES = 'postgres';
-
-	/**
-	 * @since 28.0.0
-	 */
-	public const PLATFORM_SQLITE = 'sqlite';
-
-	/**
-	 * @since 32.0.0
-	 */
-	public const PLATFORM_MARIADB = 'mariadb';
-
-	/**
-	 * Gets the QueryBuilder for the connection.
-	 *
-	 * @return \OCP\DB\QueryBuilder\IQueryBuilder
-	 * @since 8.2.0
-	 */
-	public function getQueryBuilder();
-
-	/**
-	 * Used to abstract the Nextcloud database access away
-	 * @param string $sql the sql query with ? placeholder for params
-	 * @param int|null $limit the maximum number of rows
-	 * @param int|null $offset from which row we want to start
-	 * @return IPreparedStatement The prepared statement.
-	 * @since 6.0.0
-	 * @throws Exception since 21.0.0
-	 *
-	 * @psalm-taint-sink sql $sql
-	 */
-	public function prepare($sql, $limit = null, $offset = null): IPreparedStatement;
-
-	/**
-	 * Executes an, optionally parameterized, SQL query.
-	 *
-	 * If the query is parameterized, a prepared statement is used.
-	 * If an SQLLogger is configured, the execution is logged.
-	 *
-	 * @param string $sql The SQL query to execute.
-	 * @param string[] $params The parameters to bind to the query, if any.
-	 * @param array $types The types the previous parameters are in.
-	 * @return IResult The executed statement.
-	 * @since 8.0.0
-	 * @throws Exception since 21.0.0
-	 *
-	 * @psalm-taint-sink sql $sql
-	 */
-	public function executeQuery(string $sql, array $params = [], $types = []): IResult;
-
-	/**
-	 * Executes an SQL INSERT/UPDATE/DELETE query with the given parameters
-	 * and returns the number of affected rows.
-	 *
-	 * This method supports PDO binding types as well as DBAL mapping types.
-	 *
-	 * @param string $sql The SQL query.
-	 * @param array $params The query parameters.
-	 * @param array $types The parameter types.
-	 * @return int The number of affected rows.
-	 * @since 8.0.0
-	 * @throws Exception since 21.0.0
-	 *
-	 * @deprecated 21.0.0 use executeStatement
-	 *
-	 * @psalm-taint-sink sql $sql
-	 */
-	public function executeUpdate(string $sql, array $params = [], array $types = []): int;
-
-	/**
-	 * Executes an SQL INSERT/UPDATE/DELETE query with the given parameters
-	 * and returns the number of affected rows.
-	 *
-	 * This method supports PDO binding types as well as DBAL mapping types.
-	 *
-	 * @param string $sql The SQL query.
-	 * @param array $params The query parameters.
-	 * @param array $types The parameter types.
-	 * @return int The number of affected rows.
-	 * @since 21.0.0
-	 * @throws Exception since 21.0.0
-	 *
-	 * @psalm-taint-sink sql $sql
-	 */
-	public function executeStatement($sql, array $params = [], array $types = []): int;
-
-	/**
-	 * Used to get the id of the just inserted element
-	 * @param string $table the name of the table where we inserted the item
-	 * @return int the id of the inserted element
-	 * @since 6.0.0
-	 * @throws Exception since 21.0.0
-	 * @deprecated 21.0.0 use \OCP\DB\QueryBuilder\IQueryBuilder::getLastInsertId
-	 */
-	public function lastInsertId(string $table): int;
-
-	/**
-	 * Insert a row if the matching row does not exists. To accomplish proper race condition avoidance
-	 * it is needed that there is also a unique constraint on the values. Then this method will
-	 * catch the exception and return 0.
-	 *
-	 * @param string $table The table name (will replace *PREFIX* with the actual prefix)
-	 * @param array $input data that should be inserted into the table  (column name => value)
-	 * @param array|null $compare List of values that should be checked for "if not exists"
-	 *                            If this is null or an empty array, all keys of $input will be compared
-	 *                            Please note: text fields (clob) must not be used in the compare array
-	 * @return int number of inserted rows
-	 * @throws Exception used to be the removed dbal exception, since 21.0.0 it's \OCP\DB\Exception
-	 * @since 6.0.0 - parameter $compare was added in 8.1.0, return type changed from boolean in 8.1.0
-	 * @deprecated 15.0.0 - use unique index and "try { $db->insert() } catch (UniqueConstraintViolationException $e) {}" instead, because it is more reliable and does not have the risk for deadlocks - see https://github.com/nextcloud/server/pull/12371
-	 */
-	public function insertIfNotExist(string $table, array $input, ?array $compare = null);
-
-
-	/**
-	 *
-	 * Insert a row if the row does not exist. Eventual conflicts during insert will be ignored.
-	 *
-	 * Implementation is not fully finished and should not be used!
-	 *
-	 * @param string $table The table name (will replace *PREFIX* with the actual prefix)
-	 * @param array $values data that should be inserted into the table  (column name => value)
-	 * @return int number of inserted rows
-	 * @since 16.0.0
-	 */
-	public function insertIgnoreConflict(string $table, array $values) : int;
-
-	/**
-	 * Insert or update a row value
-	 *
-	 * @param string $table
-	 * @param array $keys (column name => value)
-	 * @param array $values (column name => value)
-	 * @param array $updatePreconditionValues ensure values match preconditions (column name => value)
-	 * @return int number of new rows
-	 * @throws Exception used to be the removed dbal exception, since 21.0.0 it's \OCP\DB\Exception
-	 * @throws PreConditionNotMetException
-	 * @since 9.0.0
-	 */
-	public function setValues($table, array $keys, array $values, array $updatePreconditionValues = []): int;
-
-	/**
-	 * Create an exclusive read+write lock on a table
-	 *
-	 * Important Note: Due to the nature how locks work on different DBs, it is
-	 * only possible to lock one table at a time. You should also NOT start a
-	 * transaction while holding a lock.
-	 *
-	 * @param string $tableName
-	 * @throws Exception since 21.0.0
-	 * @since 9.1.0
-	 */
-	public function lockTable($tableName): void;
-
-	/**
-	 * Release a previous acquired lock again
-	 *
-	 * @throws Exception since 21.0.0
-	 * @since 9.1.0
-	 */
-	public function unlockTable(): void;
-
-	/**
-	 * Start a transaction
-	 * @since 6.0.0
-	 * @throws Exception since 21.0.0
-	 */
-	public function beginTransaction(): void;
-
-	/**
-	 * Check if a transaction is active
-	 *
-	 * @return bool
-	 * @since 8.2.0
-	 */
-	public function inTransaction(): bool;
-
-	/**
-	 * Commit the database changes done during a transaction that is in progress
-	 * @since 6.0.0
-	 * @throws Exception since 21.0.0
-	 */
-	public function commit(): void;
-
-	/**
-	 * Rollback the database changes done during a transaction that is in progress
-	 * @since 6.0.0
-	 * @throws Exception since 21.0.0
-	 */
-	public function rollBack(): void;
-
-	/**
-	 * Gets the error code and message as a string for logging
-	 * @return string
-	 * @since 6.0.0
-	 * @deprecated 21.0.0 doesn't return anything meaningful
-	 */
-	public function getError(): string;
-
-	/**
-	 * Fetch the SQLSTATE associated with the last database operation.
-	 *
-	 * @return integer The last error code.
-	 * @since 8.0.0
-	 * @deprecated 21.0.0 doesn't return anything anymore
-	 */
-	public function errorCode();
-
-	/**
-	 * Fetch extended error information associated with the last database operation.
-	 *
-	 * @return array The last error information.
-	 * @since 8.0.0
-	 * @deprecated 21.0.0 doesn't return anything anymore
-	 */
-	public function errorInfo();
-
-	/**
-	 * Establishes the connection with the database.
-	 *
-	 * @return bool
-	 * @throws Exception since 21.0.0
-	 * @since 8.0.0
-	 */
-	public function connect(): bool;
-
-	/**
-	 * Close the database connection
-	 * @since 8.0.0
-	 */
-	public function close(): void;
-
-	/**
-	 * Quotes a given input parameter.
-	 *
-	 * @param mixed $input Parameter to be quoted.
-	 * @param int $type Type of the parameter.
-	 * @return mixed The quoted parameter.
-	 * @since 8.0.0
-	 */
-	public function quote($input, $type = IQueryBuilder::PARAM_STR);
-
-	/**
-	 * Gets the DatabasePlatform instance that provides all the metadata about
-	 * the platform this driver connects to.
-	 *
-	 * @return \Doctrine\DBAL\Platforms\AbstractPlatform The database platform.
-	 * @since 8.0.0
-	 * @deprecated 30.0.0 Please use {@see self::getDatabaseProvider()} and compare to self::PLATFORM_* constants
-	 */
-	public function getDatabasePlatform();
-
-	/**
-	 * Drop a table from the database if it exists
-	 *
-	 * @param string $table table name without the prefix
-	 * @throws Exception since 21.0.0
-	 * @since 8.0.0
-	 *
-	 * @psalm-taint-sink sql $table
-	 */
-	public function dropTable(string $table): void;
-
-	/**
-	 * Truncate a table data if it exists
-	 *
-	 * Cascade is not supported on many platforms but would optionally cascade the truncate by
-	 * following the foreign keys.
-	 *
-	 * @param string $table table name without the prefix
-	 * @param bool $cascade whether to truncate cascading
-	 * @throws Exception
-	 * @since 32.0.0
-	 *
-	 * @psalm-taint-sink sql $table
-	 */
-	public function truncateTable(string $table, bool $cascade): void;
-
-	/**
-	 * Check if a table exists
-	 *
-	 * @param string $table table name without the prefix
-	 * @return bool
-	 * @throws Exception since 21.0.0
-	 * @since 8.0.0
-	 */
-	public function tableExists(string $table): bool;
-
-	/**
-	 * Escape a parameter to be used in a LIKE query
-	 *
-	 * @param string $param
-	 * @return string
-	 * @since 9.0.0
-	 */
-	public function escapeLikeParameter(string $param): string;
-
-	/**
-	 * Check whether or not the current database support 4byte wide unicode
-	 *
-	 * @return bool
-	 * @since 11.0.0
-	 */
-	public function supports4ByteText(): bool;
-
-	/**
-	 * Create the schema of the connected database
-	 *
-	 * @return Schema
-	 * @throws Exception since 21.0.0
-	 * @since 13.0.0
-	 */
-	public function createSchema(): Schema;
-
-	/**
-	 * Migrate the database to the given schema
-	 *
-	 * @param Schema $toSchema
-	 * @throws Exception since 21.0.0
-	 * @since 13.0.0
-	 */
-	public function migrateToSchema(Schema $toSchema): void;
-
-	/**
-	 * Returns the database provider name
-	 *
-	 * @link https://github.com/nextcloud/server/issues/30877
-	 *
-	 * @param bool $strict differentiate between database flavors, e.g. MySQL vs MariaDB
-	 * @return self::PLATFORM_MYSQL|self::PLATFORM_ORACLE|self::PLATFORM_POSTGRES|self::PLATFORM_SQLITE|self::PLATFORM_MARIADB
-	 * @since 32.0.0 Optional parameter $strict was added
-	 * @since 28.0.0
-	 */
-	public function getDatabaseProvider(bool $strict = false): string;
-
-	/**
-	 * Get the shard definition by name, if configured
-	 *
-	 * @param string $name
-	 * @return ShardDefinition|null
-	 * @since 30.0.0
-	 */
-	public function getShardDefinition(string $name): ?ShardDefinition;
-
-	/**
-	 * Get a helper class for implementing cross-shard moves
-	 *
-	 * @return CrossShardMoveHelper
-	 * @since 30.0.0
-	 */
-	public function getCrossShardMoveHelper(): CrossShardMoveHelper;
+    /**
+     * @since 28.0.0
+     */
+    public const PLATFORM_MYSQL = 'mysql';
+
+    /**
+     * @since 28.0.0
+     */
+    public const PLATFORM_ORACLE = 'oracle';
+
+    /**
+     * @since 28.0.0
+     */
+    public const PLATFORM_POSTGRES = 'postgres';
+
+    /**
+     * @since 28.0.0
+     */
+    public const PLATFORM_SQLITE = 'sqlite';
+
+    /**
+     * @since 32.0.0
+     */
+    public const PLATFORM_MARIADB = 'mariadb';
+
+    /**
+     * Gets the QueryBuilder for the connection.
+     *
+     * @return \OCP\DB\QueryBuilder\IQueryBuilder
+     * @since 8.2.0
+     */
+    public function getQueryBuilder();
+
+    /**
+     * Used to abstract the Nextcloud database access away
+     * @param string $sql the sql query with ? placeholder for params
+     * @param int|null $limit the maximum number of rows
+     * @param int|null $offset from which row we want to start
+     * @return IPreparedStatement The prepared statement.
+     * @since 6.0.0
+     * @throws Exception since 21.0.0
+     *
+     * @psalm-taint-sink sql $sql
+     */
+    public function prepare($sql, $limit = null, $offset = null): IPreparedStatement;
+
+    /**
+     * Executes an, optionally parameterized, SQL query.
+     *
+     * If the query is parameterized, a prepared statement is used.
+     * If an SQLLogger is configured, the execution is logged.
+     *
+     * @param string $sql The SQL query to execute.
+     * @param string[] $params The parameters to bind to the query, if any.
+     * @param array $types The types the previous parameters are in.
+     * @return IResult The executed statement.
+     * @since 8.0.0
+     * @throws Exception since 21.0.0
+     *
+     * @psalm-taint-sink sql $sql
+     */
+    public function executeQuery(string $sql, array $params = [], $types = []): IResult;
+
+    /**
+     * Executes an SQL INSERT/UPDATE/DELETE query with the given parameters
+     * and returns the number of affected rows.
+     *
+     * This method supports PDO binding types as well as DBAL mapping types.
+     *
+     * @param string $sql The SQL query.
+     * @param array $params The query parameters.
+     * @param array $types The parameter types.
+     * @return int The number of affected rows.
+     * @since 8.0.0
+     * @throws Exception since 21.0.0
+     *
+     * @deprecated 21.0.0 use executeStatement
+     *
+     * @psalm-taint-sink sql $sql
+     */
+    public function executeUpdate(string $sql, array $params = [], array $types = []): int;
+
+    /**
+     * Executes an SQL INSERT/UPDATE/DELETE query with the given parameters
+     * and returns the number of affected rows.
+     *
+     * This method supports PDO binding types as well as DBAL mapping types.
+     *
+     * @param string $sql The SQL query.
+     * @param array $params The query parameters.
+     * @param array $types The parameter types.
+     * @return int The number of affected rows.
+     * @since 21.0.0
+     * @throws Exception since 21.0.0
+     *
+     * @psalm-taint-sink sql $sql
+     */
+    public function executeStatement($sql, array $params = [], array $types = []): int;
+
+    /**
+     * Used to get the id of the just inserted element
+     * @param string $table the name of the table where we inserted the item
+     * @return int the id of the inserted element
+     * @since 6.0.0
+     * @throws Exception since 21.0.0
+     * @deprecated 21.0.0 use \OCP\DB\QueryBuilder\IQueryBuilder::getLastInsertId
+     */
+    public function lastInsertId(string $table): int;
+
+    /**
+     * Insert a row if the matching row does not exists. To accomplish proper race condition avoidance
+     * it is needed that there is also a unique constraint on the values. Then this method will
+     * catch the exception and return 0.
+     *
+     * @param string $table The table name (will replace *PREFIX* with the actual prefix)
+     * @param array $input data that should be inserted into the table  (column name => value)
+     * @param array|null $compare List of values that should be checked for "if not exists"
+     *                            If this is null or an empty array, all keys of $input will be compared
+     *                            Please note: text fields (clob) must not be used in the compare array
+     * @return int number of inserted rows
+     * @throws Exception used to be the removed dbal exception, since 21.0.0 it's \OCP\DB\Exception
+     * @since 6.0.0 - parameter $compare was added in 8.1.0, return type changed from boolean in 8.1.0
+     * @deprecated 15.0.0 - use unique index and "try { $db->insert() } catch (UniqueConstraintViolationException $e) {}" instead, because it is more reliable and does not have the risk for deadlocks - see https://github.com/nextcloud/server/pull/12371
+     */
+    public function insertIfNotExist(string $table, array $input, ?array $compare = null);
+
+
+    /**
+     *
+     * Insert a row if the row does not exist. Eventual conflicts during insert will be ignored.
+     *
+     * Implementation is not fully finished and should not be used!
+     *
+     * @param string $table The table name (will replace *PREFIX* with the actual prefix)
+     * @param array $values data that should be inserted into the table  (column name => value)
+     * @return int number of inserted rows
+     * @since 16.0.0
+     */
+    public function insertIgnoreConflict(string $table, array $values) : int;
+
+    /**
+     * Insert or update a row value
+     *
+     * @param string $table
+     * @param array $keys (column name => value)
+     * @param array $values (column name => value)
+     * @param array $updatePreconditionValues ensure values match preconditions (column name => value)
+     * @return int number of new rows
+     * @throws Exception used to be the removed dbal exception, since 21.0.0 it's \OCP\DB\Exception
+     * @throws PreConditionNotMetException
+     * @since 9.0.0
+     */
+    public function setValues($table, array $keys, array $values, array $updatePreconditionValues = []): int;
+
+    /**
+     * Create an exclusive read+write lock on a table
+     *
+     * Important Note: Due to the nature how locks work on different DBs, it is
+     * only possible to lock one table at a time. You should also NOT start a
+     * transaction while holding a lock.
+     *
+     * @param string $tableName
+     * @throws Exception since 21.0.0
+     * @since 9.1.0
+     */
+    public function lockTable($tableName): void;
+
+    /**
+     * Release a previous acquired lock again
+     *
+     * @throws Exception since 21.0.0
+     * @since 9.1.0
+     */
+    public function unlockTable(): void;
+
+    /**
+     * Start a transaction
+     * @since 6.0.0
+     * @throws Exception since 21.0.0
+     */
+    public function beginTransaction(): void;
+
+    /**
+     * Check if a transaction is active
+     *
+     * @return bool
+     * @since 8.2.0
+     */
+    public function inTransaction(): bool;
+
+    /**
+     * Commit the database changes done during a transaction that is in progress
+     * @since 6.0.0
+     * @throws Exception since 21.0.0
+     */
+    public function commit(): void;
+
+    /**
+     * Rollback the database changes done during a transaction that is in progress
+     * @since 6.0.0
+     * @throws Exception since 21.0.0
+     */
+    public function rollBack(): void;
+
+    /**
+     * Gets the error code and message as a string for logging
+     * @return string
+     * @since 6.0.0
+     * @deprecated 21.0.0 doesn't return anything meaningful
+     */
+    public function getError(): string;
+
+    /**
+     * Fetch the SQLSTATE associated with the last database operation.
+     *
+     * @return integer The last error code.
+     * @since 8.0.0
+     * @deprecated 21.0.0 doesn't return anything anymore
+     */
+    public function errorCode();
+
+    /**
+     * Fetch extended error information associated with the last database operation.
+     *
+     * @return array The last error information.
+     * @since 8.0.0
+     * @deprecated 21.0.0 doesn't return anything anymore
+     */
+    public function errorInfo();
+
+    /**
+     * Establishes the connection with the database.
+     *
+     * @return bool
+     * @throws Exception since 21.0.0
+     * @since 8.0.0
+     */
+    public function connect(): bool;
+
+    /**
+     * Close the database connection
+     * @since 8.0.0
+     */
+    public function close(): void;
+
+    /**
+     * Quotes a given input parameter.
+     *
+     * @param mixed $input Parameter to be quoted.
+     * @param int $type Type of the parameter.
+     * @return mixed The quoted parameter.
+     * @since 8.0.0
+     */
+    public function quote($input, $type = IQueryBuilder::PARAM_STR);
+
+    /**
+     * Gets the DatabasePlatform instance that provides all the metadata about
+     * the platform this driver connects to.
+     *
+     * @return \Doctrine\DBAL\Platforms\AbstractPlatform The database platform.
+     * @since 8.0.0
+     * @deprecated 30.0.0 Please use {@see self::getDatabaseProvider()} and compare to self::PLATFORM_* constants
+     */
+    public function getDatabasePlatform();
+
+    /**
+     * Drop a table from the database if it exists
+     *
+     * @param string $table table name without the prefix
+     * @throws Exception since 21.0.0
+     * @since 8.0.0
+     *
+     * @psalm-taint-sink sql $table
+     */
+    public function dropTable(string $table): void;
+
+    /**
+     * Truncate a table data if it exists
+     *
+     * Cascade is not supported on many platforms but would optionally cascade the truncate by
+     * following the foreign keys.
+     *
+     * @param string $table table name without the prefix
+     * @param bool $cascade whether to truncate cascading
+     * @throws Exception
+     * @since 32.0.0
+     *
+     * @psalm-taint-sink sql $table
+     */
+    public function truncateTable(string $table, bool $cascade): void;
+
+    /**
+     * Check if a table exists
+     *
+     * @param string $table table name without the prefix
+     * @return bool
+     * @throws Exception since 21.0.0
+     * @since 8.0.0
+     */
+    public function tableExists(string $table): bool;
+
+    /**
+     * Escape a parameter to be used in a LIKE query
+     *
+     * @param string $param
+     * @return string
+     * @since 9.0.0
+     */
+    public function escapeLikeParameter(string $param): string;
+
+    /**
+     * Check whether or not the current database support 4byte wide unicode
+     *
+     * @return bool
+     * @since 11.0.0
+     */
+    public function supports4ByteText(): bool;
+
+    /**
+     * Create the schema of the connected database
+     *
+     * @return Schema
+     * @throws Exception since 21.0.0
+     * @since 13.0.0
+     */
+    public function createSchema(): Schema;
+
+    /**
+     * Migrate the database to the given schema
+     *
+     * @param Schema $toSchema
+     * @throws Exception since 21.0.0
+     * @since 13.0.0
+     */
+    public function migrateToSchema(Schema $toSchema): void;
+
+    /**
+     * Returns the database provider name
+     *
+     * @link https://github.com/nextcloud/server/issues/30877
+     *
+     * @param bool $strict differentiate between database flavors, e.g. MySQL vs MariaDB
+     * @return self::PLATFORM_MYSQL|self::PLATFORM_ORACLE|self::PLATFORM_POSTGRES|self::PLATFORM_SQLITE|self::PLATFORM_MARIADB
+     * @since 32.0.0 Optional parameter $strict was added
+     * @since 28.0.0
+     */
+    public function getDatabaseProvider(bool $strict = false): string;
+
+    /**
+     * Get the shard definition by name, if configured
+     *
+     * @param string $name
+     * @return ShardDefinition|null
+     * @since 30.0.0
+     */
+    public function getShardDefinition(string $name): ?ShardDefinition;
+
+    /**
+     * Get a helper class for implementing cross-shard moves
+     *
+     * @return CrossShardMoveHelper
+     * @since 30.0.0
+     */
+    public function getCrossShardMoveHelper(): CrossShardMoveHelper;
 }

lib/private/DB/ConnectionAdapter.php

Indentation +239 added lines, -239 removed lines

@@ -23,243 +23,243 @@
  * Adapts the public API to our internal DBAL connection wrapper
  */
 class ConnectionAdapter implements IDBConnection {
-	/** @var Connection */
-	private $inner;
-
-	public function __construct(Connection $inner) {
-		$this->inner = $inner;
-	}
-
-	public function getQueryBuilder(): IQueryBuilder {
-		return $this->inner->getQueryBuilder();
-	}
-
-	public function prepare($sql, $limit = null, $offset = null): IPreparedStatement {
-		try {
-			return new PreparedStatement(
-				$this->inner->prepare($sql, $limit, $offset)
-			);
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function executeQuery(string $sql, array $params = [], $types = []): IResult {
-		try {
-			return new ResultAdapter(
-				$this->inner->executeQuery($sql, $params, $types)
-			);
-		} catch (Exception $e) {
-			throw DbalException::wrap($e, '', $sql);
-		}
-	}
-
-	public function executeUpdate(string $sql, array $params = [], array $types = []): int {
-		try {
-			return $this->inner->executeUpdate($sql, $params, $types);
-		} catch (Exception $e) {
-			throw DbalException::wrap($e, '', $sql);
-		}
-	}
-
-	public function executeStatement($sql, array $params = [], array $types = []): int {
-		try {
-			return $this->inner->executeStatement($sql, $params, $types);
-		} catch (Exception $e) {
-			throw DbalException::wrap($e, '', $sql);
-		}
-	}
-
-	public function lastInsertId(string $table): int {
-		try {
-			return $this->inner->lastInsertId($table);
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function insertIfNotExist(string $table, array $input, ?array $compare = null) {
-		try {
-			return $this->inner->insertIfNotExist($table, $input, $compare);
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function insertIgnoreConflict(string $table, array $values): int {
-		try {
-			return $this->inner->insertIgnoreConflict($table, $values);
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function setValues($table, array $keys, array $values, array $updatePreconditionValues = []): int {
-		try {
-			return $this->inner->setValues($table, $keys, $values, $updatePreconditionValues);
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function lockTable($tableName): void {
-		try {
-			$this->inner->lockTable($tableName);
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function unlockTable(): void {
-		try {
-			$this->inner->unlockTable();
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function beginTransaction(): void {
-		try {
-			$this->inner->beginTransaction();
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function inTransaction(): bool {
-		return $this->inner->inTransaction();
-	}
-
-	public function commit(): void {
-		try {
-			$this->inner->commit();
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function rollBack(): void {
-		try {
-			$this->inner->rollBack();
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function getError(): string {
-		return $this->inner->getError();
-	}
-
-	public function errorCode() {
-		return $this->inner->errorCode();
-	}
-
-	public function errorInfo() {
-		return $this->inner->errorInfo();
-	}
-
-	public function connect(): bool {
-		try {
-			return $this->inner->connect();
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function close(): void {
-		$this->inner->close();
-	}
-
-	public function quote($input, $type = IQueryBuilder::PARAM_STR) {
-		return $this->inner->quote($input, $type);
-	}
-
-	/**
-	 * @todo we are leaking a 3rdparty type here
-	 */
-	public function getDatabasePlatform(): AbstractPlatform {
-		return $this->inner->getDatabasePlatform();
-	}
-
-	public function dropTable(string $table): void {
-		try {
-			$this->inner->dropTable($table);
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function truncateTable(string $table, bool $cascade): void {
-		try {
-			$this->inner->truncateTable($table, $cascade);
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function tableExists(string $table): bool {
-		try {
-			return $this->inner->tableExists($table);
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function escapeLikeParameter(string $param): string {
-		return $this->inner->escapeLikeParameter($param);
-	}
-
-	public function supports4ByteText(): bool {
-		return $this->inner->supports4ByteText();
-	}
-
-	/**
-	 * @todo leaks a 3rdparty type
-	 */
-	public function createSchema(): Schema {
-		try {
-			return $this->inner->createSchema();
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function migrateToSchema(Schema $toSchema): void {
-		try {
-			$this->inner->migrateToSchema($toSchema);
-		} catch (Exception $e) {
-			throw DbalException::wrap($e);
-		}
-	}
-
-	public function getInner(): Connection {
-		return $this->inner;
-	}
-
-	/**
-	 * @return self::PLATFORM_MYSQL|self::PLATFORM_ORACLE|self::PLATFORM_POSTGRES|self::PLATFORM_SQLITE|self::PLATFORM_MARIADB
-	 */
-	public function getDatabaseProvider(bool $strict = false): string {
-		return $this->inner->getDatabaseProvider($strict);
-	}
-
-	/**
-	 * @internal Should only be used inside the QueryBuilder, ExpressionBuilder and FunctionBuilder
-	 * All apps and API code should not need this and instead use provided functionality from the above.
-	 */
-	public function getServerVersion(): string {
-		return $this->inner->getServerVersion();
-	}
-
-	public function logDatabaseException(\Exception $exception) {
-		$this->inner->logDatabaseException($exception);
-	}
-
-	public function getShardDefinition(string $name): ?ShardDefinition {
-		return $this->inner->getShardDefinition($name);
-	}
-
-	public function getCrossShardMoveHelper(): CrossShardMoveHelper {
-		return $this->inner->getCrossShardMoveHelper();
-	}
+    /** @var Connection */
+    private $inner;
+
+    public function __construct(Connection $inner) {
+        $this->inner = $inner;
+    }
+
+    public function getQueryBuilder(): IQueryBuilder {
+        return $this->inner->getQueryBuilder();
+    }
+
+    public function prepare($sql, $limit = null, $offset = null): IPreparedStatement {
+        try {
+            return new PreparedStatement(
+                $this->inner->prepare($sql, $limit, $offset)
+            );
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function executeQuery(string $sql, array $params = [], $types = []): IResult {
+        try {
+            return new ResultAdapter(
+                $this->inner->executeQuery($sql, $params, $types)
+            );
+        } catch (Exception $e) {
+            throw DbalException::wrap($e, '', $sql);
+        }
+    }
+
+    public function executeUpdate(string $sql, array $params = [], array $types = []): int {
+        try {
+            return $this->inner->executeUpdate($sql, $params, $types);
+        } catch (Exception $e) {
+            throw DbalException::wrap($e, '', $sql);
+        }
+    }
+
+    public function executeStatement($sql, array $params = [], array $types = []): int {
+        try {
+            return $this->inner->executeStatement($sql, $params, $types);
+        } catch (Exception $e) {
+            throw DbalException::wrap($e, '', $sql);
+        }
+    }
+
+    public function lastInsertId(string $table): int {
+        try {
+            return $this->inner->lastInsertId($table);
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function insertIfNotExist(string $table, array $input, ?array $compare = null) {
+        try {
+            return $this->inner->insertIfNotExist($table, $input, $compare);
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function insertIgnoreConflict(string $table, array $values): int {
+        try {
+            return $this->inner->insertIgnoreConflict($table, $values);
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function setValues($table, array $keys, array $values, array $updatePreconditionValues = []): int {
+        try {
+            return $this->inner->setValues($table, $keys, $values, $updatePreconditionValues);
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function lockTable($tableName): void {
+        try {
+            $this->inner->lockTable($tableName);
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function unlockTable(): void {
+        try {
+            $this->inner->unlockTable();
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function beginTransaction(): void {
+        try {
+            $this->inner->beginTransaction();
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function inTransaction(): bool {
+        return $this->inner->inTransaction();
+    }
+
+    public function commit(): void {
+        try {
+            $this->inner->commit();
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function rollBack(): void {
+        try {
+            $this->inner->rollBack();
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function getError(): string {
+        return $this->inner->getError();
+    }
+
+    public function errorCode() {
+        return $this->inner->errorCode();
+    }
+
+    public function errorInfo() {
+        return $this->inner->errorInfo();
+    }
+
+    public function connect(): bool {
+        try {
+            return $this->inner->connect();
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function close(): void {
+        $this->inner->close();
+    }
+
+    public function quote($input, $type = IQueryBuilder::PARAM_STR) {
+        return $this->inner->quote($input, $type);
+    }
+
+    /**
+     * @todo we are leaking a 3rdparty type here
+     */
+    public function getDatabasePlatform(): AbstractPlatform {
+        return $this->inner->getDatabasePlatform();
+    }
+
+    public function dropTable(string $table): void {
+        try {
+            $this->inner->dropTable($table);
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function truncateTable(string $table, bool $cascade): void {
+        try {
+            $this->inner->truncateTable($table, $cascade);
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function tableExists(string $table): bool {
+        try {
+            return $this->inner->tableExists($table);
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function escapeLikeParameter(string $param): string {
+        return $this->inner->escapeLikeParameter($param);
+    }
+
+    public function supports4ByteText(): bool {
+        return $this->inner->supports4ByteText();
+    }
+
+    /**
+     * @todo leaks a 3rdparty type
+     */
+    public function createSchema(): Schema {
+        try {
+            return $this->inner->createSchema();
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function migrateToSchema(Schema $toSchema): void {
+        try {
+            $this->inner->migrateToSchema($toSchema);
+        } catch (Exception $e) {
+            throw DbalException::wrap($e);
+        }
+    }
+
+    public function getInner(): Connection {
+        return $this->inner;
+    }
+
+    /**
+     * @return self::PLATFORM_MYSQL|self::PLATFORM_ORACLE|self::PLATFORM_POSTGRES|self::PLATFORM_SQLITE|self::PLATFORM_MARIADB
+     */
+    public function getDatabaseProvider(bool $strict = false): string {
+        return $this->inner->getDatabaseProvider($strict);
+    }
+
+    /**
+     * @internal Should only be used inside the QueryBuilder, ExpressionBuilder and FunctionBuilder
+     * All apps and API code should not need this and instead use provided functionality from the above.
+     */
+    public function getServerVersion(): string {
+        return $this->inner->getServerVersion();
+    }
+
+    public function logDatabaseException(\Exception $exception) {
+        $this->inner->logDatabaseException($exception);
+    }
+
+    public function getShardDefinition(string $name): ?ShardDefinition {
+        return $this->inner->getShardDefinition($name);
+    }
+
+    public function getCrossShardMoveHelper(): CrossShardMoveHelper {
+        return $this->inner->getCrossShardMoveHelper();
+    }
 }

lib/private/DB/Connection.php

Indentation +917 added lines, -917 removed lines

@@ -50,921 +50,921 @@
 use function in_array;
 
 class Connection extends PrimaryReadReplicaConnection {
-	/** @var string */
-	protected $tablePrefix;
-
-	/** @var \OC\DB\Adapter $adapter */
-	protected $adapter;
-
-	/** @var SystemConfig */
-	private $systemConfig;
-
-	private ClockInterface $clock;
-
-	private LoggerInterface $logger;
-
-	protected $lockedTable = null;
-
-	/** @var int */
-	protected $queriesBuilt = 0;
-
-	/** @var int */
-	protected $queriesExecuted = 0;
-
-	/** @var DbDataCollector|null */
-	protected $dbDataCollector = null;
-	private array $lastConnectionCheck = [];
-
-	protected ?float $transactionActiveSince = null;
-
-	/** @var array<string, int> */
-	protected $tableDirtyWrites = [];
-
-	protected bool $logDbException = false;
-	private ?array $transactionBacktrace = null;
-
-	protected bool $logRequestId;
-	protected string $requestId;
-
-	/** @var array<string, list<string>> */
-	protected array $partitions;
-	/** @var ShardDefinition[] */
-	protected array $shards = [];
-	protected ShardConnectionManager $shardConnectionManager;
-	protected AutoIncrementHandler $autoIncrementHandler;
-	protected bool $isShardingEnabled;
-
-	public const SHARD_PRESETS = [
-		'filecache' => [
-			'companion_keys' => [
-				'file_id',
-			],
-			'companion_tables' => [
-				'filecache_extended',
-				'files_metadata',
-			],
-			'primary_key' => 'fileid',
-			'shard_key' => 'storage',
-			'table' => 'filecache',
-		],
-	];
-
-	/**
-	 * Initializes a new instance of the Connection class.
-	 *
-	 * @throws \Exception
-	 */
-	public function __construct(
-		private array $params,
-		Driver $driver,
-		?Configuration $config = null,
-		?EventManager $eventManager = null,
-	) {
-		if (!isset($params['adapter'])) {
-			throw new \Exception('adapter not set');
-		}
-		if (!isset($params['tablePrefix'])) {
-			throw new \Exception('tablePrefix not set');
-		}
-		/**
-		 * @psalm-suppress InternalMethod
-		 */
-		parent::__construct($params, $driver, $config, $eventManager);
-		$this->adapter = new $params['adapter']($this);
-		$this->tablePrefix = $params['tablePrefix'];
-		$this->isShardingEnabled = isset($this->params['sharding']) && !empty($this->params['sharding']);
-
-		if ($this->isShardingEnabled) {
-			/** @psalm-suppress InvalidArrayOffset */
-			$this->shardConnectionManager = $this->params['shard_connection_manager'] ?? Server::get(ShardConnectionManager::class);
-			/** @psalm-suppress InvalidArrayOffset */
-			$this->autoIncrementHandler = $this->params['auto_increment_handler'] ?? new AutoIncrementHandler(
-				Server::get(ICacheFactory::class),
-				$this->shardConnectionManager,
-			);
-		}
-		$this->systemConfig = \OC::$server->getSystemConfig();
-		$this->clock = Server::get(ClockInterface::class);
-		$this->logger = Server::get(LoggerInterface::class);
-
-		$this->logRequestId = $this->systemConfig->getValue('db.log_request_id', false);
-		$this->logDbException = $this->systemConfig->getValue('db.log_exceptions', false);
-		$this->requestId = Server::get(IRequestId::class)->getId();
-
-		/** @var \OCP\Profiler\IProfiler */
-		$profiler = Server::get(IProfiler::class);
-		if ($profiler->isEnabled()) {
-			$this->dbDataCollector = new DbDataCollector($this);
-			$profiler->add($this->dbDataCollector);
-			$debugStack = new BacktraceDebugStack();
-			$this->dbDataCollector->setDebugStack($debugStack);
-			$this->_config->setSQLLogger($debugStack);
-		}
-
-		/** @var array<string, array{shards: array[], mapper: ?string, from_primary_key: ?int, from_shard_key: ?int}> $shardConfig */
-		$shardConfig = $this->params['sharding'] ?? [];
-		$shardNames = array_keys($shardConfig);
-		$this->shards = array_map(function (array $config, string $name) {
-			if (!isset(self::SHARD_PRESETS[$name])) {
-				throw new \Exception("Shard preset $name not found");
-			}
-
-			$shardMapperClass = $config['mapper'] ?? RoundRobinShardMapper::class;
-			$shardMapper = Server::get($shardMapperClass);
-			if (!$shardMapper instanceof IShardMapper) {
-				throw new \Exception("Invalid shard mapper: $shardMapperClass");
-			}
-			return new ShardDefinition(
-				self::SHARD_PRESETS[$name]['table'],
-				self::SHARD_PRESETS[$name]['primary_key'],
-				self::SHARD_PRESETS[$name]['companion_keys'],
-				self::SHARD_PRESETS[$name]['shard_key'],
-				$shardMapper,
-				self::SHARD_PRESETS[$name]['companion_tables'],
-				$config['shards'],
-				$config['from_primary_key'] ?? 0,
-				$config['from_shard_key'] ?? 0,
-			);
-		}, $shardConfig, $shardNames);
-		$this->shards = array_combine($shardNames, $this->shards);
-		$this->partitions = array_map(function (ShardDefinition $shard) {
-			return array_merge([$shard->table], $shard->companionTables);
-		}, $this->shards);
-
-		$this->setNestTransactionsWithSavepoints(true);
-	}
-
-	/**
-	 * @return IDBConnection[]
-	 */
-	public function getShardConnections(): array {
-		$connections = [];
-		if ($this->isShardingEnabled) {
-			foreach ($this->shards as $shardDefinition) {
-				foreach ($shardDefinition->getAllShards() as $shard) {
-					if ($shard !== ShardDefinition::MIGRATION_SHARD) {
-						/** @var ConnectionAdapter $connection */
-						$connections[] = $this->shardConnectionManager->getConnection($shardDefinition, $shard);
-					}
-				}
-			}
-		}
-		return $connections;
-	}
-
-	/**
-	 * @throws Exception
-	 */
-	public function connect($connectionName = null) {
-		try {
-			if ($this->_conn) {
-				$this->reconnectIfNeeded();
-				/** @psalm-suppress InternalMethod */
-				return parent::connect();
-			}
-
-			// Only trigger the event logger for the initial connect call
-			$eventLogger = Server::get(IEventLogger::class);
-			$eventLogger->start('connect:db', 'db connection opened');
-			/** @psalm-suppress InternalMethod */
-			$status = parent::connect();
-			$eventLogger->end('connect:db');
-
-			$this->lastConnectionCheck[$this->getConnectionName()] = time();
-
-			return $status;
-		} catch (Exception $e) {
-			// throw a new exception to prevent leaking info from the stacktrace
-			throw new Exception('Failed to connect to the database: ' . $e->getMessage(), $e->getCode());
-		}
-	}
-
-	protected function performConnect(?string $connectionName = null): bool {
-		if (($connectionName ?? 'replica') === 'replica'
-			&& count($this->params['replica']) === 1
-			&& $this->params['primary'] === $this->params['replica'][0]) {
-			return parent::performConnect('primary');
-		}
-		return parent::performConnect($connectionName);
-	}
-
-	public function getStats(): array {
-		return [
-			'built' => $this->queriesBuilt,
-			'executed' => $this->queriesExecuted,
-		];
-	}
-
-	/**
-	 * Returns a QueryBuilder for the connection.
-	 */
-	public function getQueryBuilder(): IQueryBuilder {
-		$this->queriesBuilt++;
-
-		$builder = new QueryBuilder(
-			new ConnectionAdapter($this),
-			$this->systemConfig,
-			$this->logger
-		);
-		if ($this->isShardingEnabled && count($this->partitions) > 0) {
-			$builder = new PartitionedQueryBuilder(
-				$builder,
-				$this->shards,
-				$this->shardConnectionManager,
-				$this->autoIncrementHandler,
-			);
-			foreach ($this->partitions as $name => $tables) {
-				$partition = new PartitionSplit($name, $tables);
-				$builder->addPartition($partition);
-			}
-			return $builder;
-		} else {
-			return $builder;
-		}
-	}
-
-	/**
-	 * Gets the QueryBuilder for the connection.
-	 *
-	 * @return \Doctrine\DBAL\Query\QueryBuilder
-	 * @deprecated 8.0.0 please use $this->getQueryBuilder() instead
-	 */
-	public function createQueryBuilder() {
-		$backtrace = $this->getCallerBacktrace();
-		$this->logger->debug('Doctrine QueryBuilder retrieved in {backtrace}', ['app' => 'core', 'backtrace' => $backtrace]);
-		$this->queriesBuilt++;
-		return parent::createQueryBuilder();
-	}
-
-	/**
-	 * Gets the ExpressionBuilder for the connection.
-	 *
-	 * @return \Doctrine\DBAL\Query\Expression\ExpressionBuilder
-	 * @deprecated 8.0.0 please use $this->getQueryBuilder()->expr() instead
-	 */
-	public function getExpressionBuilder() {
-		$backtrace = $this->getCallerBacktrace();
-		$this->logger->debug('Doctrine ExpressionBuilder retrieved in {backtrace}', ['app' => 'core', 'backtrace' => $backtrace]);
-		$this->queriesBuilt++;
-		return parent::getExpressionBuilder();
-	}
-
-	/**
-	 * Get the file and line that called the method where `getCallerBacktrace()` was used
-	 *
-	 * @return string
-	 */
-	protected function getCallerBacktrace() {
-		$traces = debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS, 2);
-
-		// 0 is the method where we use `getCallerBacktrace`
-		// 1 is the target method which uses the method we want to log
-		if (isset($traces[1])) {
-			return $traces[1]['file'] . ':' . $traces[1]['line'];
-		}
-
-		return '';
-	}
-
-	/**
-	 * @return string
-	 */
-	public function getPrefix() {
-		return $this->tablePrefix;
-	}
-
-	/**
-	 * Prepares an SQL statement.
-	 *
-	 * @param string $statement The SQL statement to prepare.
-	 * @param int|null $limit
-	 * @param int|null $offset
-	 *
-	 * @return Statement The prepared statement.
-	 * @throws Exception
-	 */
-	public function prepare($sql, $limit = null, $offset = null): Statement {
-		if ($limit === -1 || $limit === null) {
-			$limit = null;
-		} else {
-			$limit = (int)$limit;
-		}
-		if ($offset !== null) {
-			$offset = (int)$offset;
-		}
-		if (!is_null($limit)) {
-			$platform = $this->getDatabasePlatform();
-			$sql = $platform->modifyLimitQuery($sql, $limit, $offset);
-		}
-		$statement = $this->finishQuery($sql);
-
-		return parent::prepare($statement);
-	}
-
-	/**
-	 * Executes an, optionally parametrized, SQL query.
-	 *
-	 * If the query is parametrized, a prepared statement is used.
-	 * If an SQLLogger is configured, the execution is logged.
-	 *
-	 * @param string $sql The SQL query to execute.
-	 * @param array $params The parameters to bind to the query, if any.
-	 * @param array $types The types the previous parameters are in.
-	 * @param \Doctrine\DBAL\Cache\QueryCacheProfile|null $qcp The query cache profile, optional.
-	 *
-	 * @return Result The executed statement.
-	 *
-	 * @throws \Doctrine\DBAL\Exception
-	 */
-	public function executeQuery(string $sql, array $params = [], $types = [], ?QueryCacheProfile $qcp = null): Result {
-		$tables = $this->getQueriedTables($sql);
-		$now = $this->clock->now()->getTimestamp();
-		$dirtyTableWrites = [];
-		foreach ($tables as $table) {
-			$lastAccess = $this->tableDirtyWrites[$table] ?? 0;
-			// Only very recent writes are considered dirty
-			if ($lastAccess >= ($now - 3)) {
-				$dirtyTableWrites[] = $table;
-			}
-		}
-		if ($this->isTransactionActive()) {
-			// Transacted queries go to the primary. The consistency of the primary guarantees that we can not run
-			// into a dirty read.
-		} elseif (count($dirtyTableWrites) === 0) {
-			// No tables read that could have been written already in the same request and no transaction active
-			// so we can switch back to the replica for reading as long as no writes happen that switch back to the primary
-			// We cannot log here as this would log too early in the server boot process
-			$this->ensureConnectedToReplica();
-		} else {
-			// Read to a table that has been written to previously
-			// While this might not necessarily mean that we did a read after write it is an indication for a code path to check
-			$this->logger->log(
-				(int)($this->systemConfig->getValue('loglevel_dirty_database_queries', null) ?? 0),
-				'dirty table reads: ' . $sql,
-				[
-					'tables' => array_keys($this->tableDirtyWrites),
-					'reads' => $tables,
-					'exception' => new \Exception('dirty table reads: ' . $sql),
-				],
-			);
-			// To prevent a dirty read on a replica that is slightly out of sync, we
-			// switch back to the primary. This is detrimental for performance but
-			// safer for consistency.
-			$this->ensureConnectedToPrimary();
-		}
-
-		$sql = $this->finishQuery($sql);
-		$this->queriesExecuted++;
-		$this->logQueryToFile($sql, $params);
-		try {
-			return parent::executeQuery($sql, $params, $types, $qcp);
-		} catch (\Exception $e) {
-			$this->logDatabaseException($e);
-			throw $e;
-		}
-	}
-
-	/**
-	 * Helper function to get the list of tables affected by a given query
-	 * used to track dirty tables that received a write with the current request
-	 */
-	private function getQueriedTables(string $sql): array {
-		$re = '/(\*PREFIX\*\w+)/mi';
-		preg_match_all($re, $sql, $matches);
-		return array_map([$this, 'replaceTablePrefix'], $matches[0] ?? []);
-	}
-
-	/**
-	 * @throws Exception
-	 */
-	public function executeUpdate(string $sql, array $params = [], array $types = []): int {
-		return $this->executeStatement($sql, $params, $types);
-	}
-
-	/**
-	 * Executes an SQL INSERT/UPDATE/DELETE query with the given parameters
-	 * and returns the number of affected rows.
-	 *
-	 * This method supports PDO binding types as well as DBAL mapping types.
-	 *
-	 * @param string $sql The SQL query.
-	 * @param array $params The query parameters.
-	 * @param array $types The parameter types.
-	 *
-	 * @return int The number of affected rows.
-	 *
-	 * @throws \Doctrine\DBAL\Exception
-	 */
-	public function executeStatement($sql, array $params = [], array $types = []): int {
-		$tables = $this->getQueriedTables($sql);
-		foreach ($tables as $table) {
-			$this->tableDirtyWrites[$table] = $this->clock->now()->getTimestamp();
-		}
-		$sql = $this->finishQuery($sql);
-		$this->queriesExecuted++;
-		$this->logQueryToFile($sql, $params);
-		try {
-			return (int)parent::executeStatement($sql, $params, $types);
-		} catch (\Exception $e) {
-			$this->logDatabaseException($e);
-			throw $e;
-		}
-	}
-
-	protected function logQueryToFile(string $sql, array $params): void {
-		$logFile = $this->systemConfig->getValue('query_log_file');
-		if ($logFile !== '' && is_writable(dirname($logFile)) && (!file_exists($logFile) || is_writable($logFile))) {
-			$prefix = '';
-			if ($this->systemConfig->getValue('query_log_file_requestid') === 'yes') {
-				$prefix .= Server::get(IRequestId::class)->getId() . "\t";
-			}
-
-			$postfix = '';
-			if ($this->systemConfig->getValue('query_log_file_parameters') === 'yes') {
-				$postfix .= '; ' . json_encode($params);
-			}
-
-			if ($this->systemConfig->getValue('query_log_file_backtrace') === 'yes') {
-				$trace = debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS);
-				array_pop($trace);
-				$postfix .= '; ' . json_encode($trace);
-			}
-
-			// FIXME:  Improve to log the actual target db host
-			$isPrimary = $this->connections['primary'] === $this->_conn;
-			$prefix .= ' ' . ($isPrimary === true ? 'primary' : 'replica') . ' ';
-			$prefix .= ' ' . $this->getTransactionNestingLevel() . ' ';
-
-			file_put_contents(
-				$this->systemConfig->getValue('query_log_file', ''),
-				$prefix . $sql . $postfix . "\n",
-				FILE_APPEND
-			);
-		}
-	}
-
-	/**
-	 * Returns the ID of the last inserted row, or the last value from a sequence object,
-	 * depending on the underlying driver.
-	 *
-	 * Note: This method may not return a meaningful or consistent result across different drivers,
-	 * because the underlying database may not even support the notion of AUTO_INCREMENT/IDENTITY
-	 * columns or sequences.
-	 *
-	 * @param string $seqName Name of the sequence object from which the ID should be returned.
-	 *
-	 * @return int the last inserted ID.
-	 * @throws Exception
-	 */
-	public function lastInsertId($name = null): int {
-		if ($name) {
-			$name = $this->replaceTablePrefix($name);
-		}
-		return $this->adapter->lastInsertId($name);
-	}
-
-	/**
-	 * @internal
-	 * @throws Exception
-	 */
-	public function realLastInsertId($seqName = null) {
-		return parent::lastInsertId($seqName);
-	}
-
-	/**
-	 * Insert a row if the matching row does not exists. To accomplish proper race condition avoidance
-	 * it is needed that there is also a unique constraint on the values. Then this method will
-	 * catch the exception and return 0.
-	 *
-	 * @param string $table The table name (will replace *PREFIX* with the actual prefix)
-	 * @param array $input data that should be inserted into the table  (column name => value)
-	 * @param array|null $compare List of values that should be checked for "if not exists"
-	 *                            If this is null or an empty array, all keys of $input will be compared
-	 *                            Please note: text fields (clob) must not be used in the compare array
-	 * @return int number of inserted rows
-	 * @throws \Doctrine\DBAL\Exception
-	 * @deprecated 15.0.0 - use unique index and "try { $db->insert() } catch (UniqueConstraintViolationException $e) {}" instead, because it is more reliable and does not have the risk for deadlocks - see https://github.com/nextcloud/server/pull/12371
-	 */
-	public function insertIfNotExist($table, $input, ?array $compare = null) {
-		try {
-			return $this->adapter->insertIfNotExist($table, $input, $compare);
-		} catch (\Exception $e) {
-			$this->logDatabaseException($e);
-			throw $e;
-		}
-	}
-
-	public function insertIgnoreConflict(string $table, array $values) : int {
-		try {
-			return $this->adapter->insertIgnoreConflict($table, $values);
-		} catch (\Exception $e) {
-			$this->logDatabaseException($e);
-			throw $e;
-		}
-	}
-
-	private function getType($value) {
-		if (is_bool($value)) {
-			return IQueryBuilder::PARAM_BOOL;
-		} elseif (is_int($value)) {
-			return IQueryBuilder::PARAM_INT;
-		} else {
-			return IQueryBuilder::PARAM_STR;
-		}
-	}
-
-	/**
-	 * Insert or update a row value
-	 *
-	 * @param string $table
-	 * @param array $keys (column name => value)
-	 * @param array $values (column name => value)
-	 * @param array $updatePreconditionValues ensure values match preconditions (column name => value)
-	 * @return int number of new rows
-	 * @throws \OCP\DB\Exception
-	 * @throws PreConditionNotMetException
-	 */
-	public function setValues(string $table, array $keys, array $values, array $updatePreconditionValues = []): int {
-		try {
-			$insertQb = $this->getQueryBuilder();
-			$insertQb->insert($table)
-				->values(
-					array_map(function ($value) use ($insertQb) {
-						return $insertQb->createNamedParameter($value, $this->getType($value));
-					}, array_merge($keys, $values))
-				);
-			return $insertQb->executeStatement();
-		} catch (\OCP\DB\Exception $e) {
-			if (!in_array($e->getReason(), [
-				\OCP\DB\Exception::REASON_CONSTRAINT_VIOLATION,
-				\OCP\DB\Exception::REASON_UNIQUE_CONSTRAINT_VIOLATION,
-			])
-			) {
-				throw $e;
-			}
-
-			// value already exists, try update
-			$updateQb = $this->getQueryBuilder();
-			$updateQb->update($table);
-			foreach ($values as $name => $value) {
-				$updateQb->set($name, $updateQb->createNamedParameter($value, $this->getType($value)));
-			}
-			$where = [];
-			$whereValues = array_merge($keys, $updatePreconditionValues);
-			foreach ($whereValues as $name => $value) {
-				if ($value === '') {
-					$where[] = $updateQb->expr()->emptyString(
-						$name
-					);
-				} else {
-					$where[] = $updateQb->expr()->eq(
-						$name,
-						$updateQb->createNamedParameter($value, $this->getType($value)),
-						$this->getType($value)
-					);
-				}
-			}
-			$updateQb->where($updateQb->expr()->andX(...$where));
-			$affected = $updateQb->executeStatement();
-
-			if ($affected === 0 && !empty($updatePreconditionValues)) {
-				throw new PreConditionNotMetException();
-			}
-
-			return 0;
-		}
-	}
-
-	/**
-	 * Create an exclusive read+write lock on a table
-	 *
-	 * @param string $tableName
-	 *
-	 * @throws \BadMethodCallException When trying to acquire a second lock
-	 * @throws Exception
-	 * @since 9.1.0
-	 */
-	public function lockTable($tableName) {
-		if ($this->lockedTable !== null) {
-			throw new \BadMethodCallException('Can not lock a new table until the previous lock is released.');
-		}
-
-		$tableName = $this->tablePrefix . $tableName;
-		$this->lockedTable = $tableName;
-		$this->adapter->lockTable($tableName);
-	}
-
-	/**
-	 * Release a previous acquired lock again
-	 *
-	 * @throws Exception
-	 * @since 9.1.0
-	 */
-	public function unlockTable() {
-		$this->adapter->unlockTable();
-		$this->lockedTable = null;
-	}
-
-	/**
-	 * returns the error code and message as a string for logging
-	 * works with DoctrineException
-	 * @return string
-	 */
-	public function getError() {
-		$msg = $this->errorCode() . ': ';
-		$errorInfo = $this->errorInfo();
-		if (!empty($errorInfo)) {
-			$msg .= 'SQLSTATE = ' . $errorInfo[0] . ', ';
-			$msg .= 'Driver Code = ' . $errorInfo[1] . ', ';
-			$msg .= 'Driver Message = ' . $errorInfo[2];
-		}
-		return $msg;
-	}
-
-	public function errorCode() {
-		return -1;
-	}
-
-	public function errorInfo() {
-		return [];
-	}
-
-	/**
-	 * Drop a table from the database if it exists
-	 *
-	 * @param string $table table name without the prefix
-	 *
-	 * @throws Exception
-	 */
-	public function dropTable($table) {
-		$table = $this->tablePrefix . trim($table);
-		$schema = $this->createSchemaManager();
-		if ($schema->tablesExist([$table])) {
-			$schema->dropTable($table);
-		}
-	}
-
-	/**
-	 * Truncate a table data if it exists
-	 *
-	 * @param string $table table name without the prefix
-	 * @param bool $cascade whether to truncate cascading
-	 *
-	 * @throws Exception
-	 */
-	public function truncateTable(string $table, bool $cascade) {
-		$this->executeStatement($this->getDatabasePlatform()
-			->getTruncateTableSQL($this->tablePrefix . trim($table), $cascade));
-	}
-
-	/**
-	 * Check if a table exists
-	 *
-	 * @param string $table table name without the prefix
-	 *
-	 * @return bool
-	 * @throws Exception
-	 */
-	public function tableExists($table) {
-		$table = $this->tablePrefix . trim($table);
-		$schema = $this->createSchemaManager();
-		return $schema->tablesExist([$table]);
-	}
-
-	protected function finishQuery(string $statement): string {
-		$statement = $this->replaceTablePrefix($statement);
-		$statement = $this->adapter->fixupStatement($statement);
-		if ($this->logRequestId) {
-			return $statement . ' /* reqid: ' . $this->requestId . ' */';
-		} else {
-			return $statement;
-		}
-	}
-
-	// internal use
-	/**
-	 * @param string $statement
-	 * @return string
-	 */
-	protected function replaceTablePrefix($statement) {
-		return str_replace('*PREFIX*', $this->tablePrefix, $statement);
-	}
-
-	/**
-	 * Check if a transaction is active
-	 *
-	 * @return bool
-	 * @since 8.2.0
-	 */
-	public function inTransaction() {
-		return $this->getTransactionNestingLevel() > 0;
-	}
-
-	/**
-	 * Escape a parameter to be used in a LIKE query
-	 *
-	 * @param string $param
-	 * @return string
-	 */
-	public function escapeLikeParameter($param) {
-		return addcslashes($param, '\\_%');
-	}
-
-	/**
-	 * Check whether or not the current database support 4byte wide unicode
-	 *
-	 * @return bool
-	 * @since 11.0.0
-	 */
-	public function supports4ByteText() {
-		if (!$this->getDatabasePlatform() instanceof MySQLPlatform) {
-			return true;
-		}
-		return $this->getParams()['charset'] === 'utf8mb4';
-	}
-
-
-	/**
-	 * Create the schema of the connected database
-	 *
-	 * @return Schema
-	 * @throws Exception
-	 */
-	public function createSchema() {
-		$migrator = $this->getMigrator();
-		return $migrator->createSchema();
-	}
-
-	/**
-	 * Migrate the database to the given schema
-	 *
-	 * @param Schema $toSchema
-	 * @param bool $dryRun If true, will return the sql queries instead of running them.
-	 *
-	 * @throws Exception
-	 *
-	 * @return string|null Returns a string only if $dryRun is true.
-	 */
-	public function migrateToSchema(Schema $toSchema, bool $dryRun = false) {
-		$migrator = $this->getMigrator();
-
-		if ($dryRun) {
-			return $migrator->generateChangeScript($toSchema);
-		} else {
-			$migrator->migrate($toSchema);
-			foreach ($this->getShardConnections() as $shardConnection) {
-				$shardConnection->migrateToSchema($toSchema);
-			}
-		}
-	}
-
-	private function getMigrator() {
-		// TODO properly inject those dependencies
-		$random = \OC::$server->get(ISecureRandom::class);
-		$platform = $this->getDatabasePlatform();
-		$config = \OC::$server->getConfig();
-		$dispatcher = Server::get(\OCP\EventDispatcher\IEventDispatcher::class);
-		if ($platform instanceof SqlitePlatform) {
-			return new SQLiteMigrator($this, $config, $dispatcher);
-		} elseif ($platform instanceof OraclePlatform) {
-			return new OracleMigrator($this, $config, $dispatcher);
-		} else {
-			return new Migrator($this, $config, $dispatcher);
-		}
-	}
-
-	public function beginTransaction() {
-		if (!$this->inTransaction()) {
-			$this->transactionBacktrace = debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS);
-			$this->transactionActiveSince = microtime(true);
-		}
-		return parent::beginTransaction();
-	}
-
-	public function commit() {
-		$result = parent::commit();
-		if ($this->getTransactionNestingLevel() === 0) {
-			$timeTook = microtime(true) - $this->transactionActiveSince;
-			$this->transactionBacktrace = null;
-			$this->transactionActiveSince = null;
-			if ($timeTook > 1) {
-				$logLevel = match (true) {
-					$timeTook > 20 * 60 => ILogger::ERROR,
-					$timeTook > 5 * 60 => ILogger::WARN,
-					$timeTook > 10 => ILogger::INFO,
-					default => ILogger::DEBUG,
-				};
-				$this->logger->log(
-					$logLevel,
-					'Transaction took ' . $timeTook . 's',
-					[
-						'exception' => new \Exception('Transaction took ' . $timeTook . 's'),
-						'timeSpent' => $timeTook,
-					]
-				);
-			}
-		}
-		return $result;
-	}
-
-	public function rollBack() {
-		$result = parent::rollBack();
-		if ($this->getTransactionNestingLevel() === 0) {
-			$timeTook = microtime(true) - $this->transactionActiveSince;
-			$this->transactionBacktrace = null;
-			$this->transactionActiveSince = null;
-			if ($timeTook > 1) {
-				$logLevel = match (true) {
-					$timeTook > 20 * 60 => ILogger::ERROR,
-					$timeTook > 5 * 60 => ILogger::WARN,
-					$timeTook > 10 => ILogger::INFO,
-					default => ILogger::DEBUG,
-				};
-				$this->logger->log(
-					$logLevel,
-					'Transaction rollback took longer than 1s: ' . $timeTook,
-					[
-						'exception' => new \Exception('Long running transaction rollback'),
-						'timeSpent' => $timeTook,
-					]
-				);
-			}
-		}
-		return $result;
-	}
-
-	private function reconnectIfNeeded(): void {
-		if (
-			!isset($this->lastConnectionCheck[$this->getConnectionName()])
-			|| time() <= $this->lastConnectionCheck[$this->getConnectionName()] + 30
-			|| $this->isTransactionActive()
-		) {
-			return;
-		}
-
-		try {
-			$this->_conn->query($this->getDriver()->getDatabasePlatform()->getDummySelectSQL());
-			$this->lastConnectionCheck[$this->getConnectionName()] = time();
-		} catch (ConnectionLost|\Exception $e) {
-			$this->logger->warning('Exception during connectivity check, closing and reconnecting', ['exception' => $e]);
-			$this->close();
-		}
-	}
-
-	private function getConnectionName(): string {
-		return $this->isConnectedToPrimary() ? 'primary' : 'replica';
-	}
-
-	/**
-	 * @return IDBConnection::PLATFORM_MYSQL|IDBConnection::PLATFORM_ORACLE|IDBConnection::PLATFORM_POSTGRES|IDBConnection::PLATFORM_SQLITE|IDBConnection::PLATFORM_MARIADB
-	 */
-	public function getDatabaseProvider(bool $strict = false): string {
-		$platform = $this->getDatabasePlatform();
-		if ($strict && $platform instanceof MariaDBPlatform) {
-			return IDBConnection::PLATFORM_MARIADB;
-		} elseif ($platform instanceof MySQLPlatform) {
-			return IDBConnection::PLATFORM_MYSQL;
-		} elseif ($platform instanceof OraclePlatform) {
-			return IDBConnection::PLATFORM_ORACLE;
-		} elseif ($platform instanceof PostgreSQLPlatform) {
-			return IDBConnection::PLATFORM_POSTGRES;
-		} elseif ($platform instanceof SqlitePlatform) {
-			return IDBConnection::PLATFORM_SQLITE;
-		} else {
-			throw new \Exception('Database ' . $platform::class . ' not supported');
-		}
-	}
-
-	/**
-	 * @internal Should only be used inside the QueryBuilder, ExpressionBuilder and FunctionBuilder
-	 * All apps and API code should not need this and instead use provided functionality from the above.
-	 */
-	public function getServerVersion(): string {
-		/** @var ServerInfoAwareConnection $this->_conn */
-		return $this->_conn->getServerVersion();
-	}
-
-	/**
-	 * Log a database exception if enabled
-	 *
-	 * @param \Exception $exception
-	 * @return void
-	 */
-	public function logDatabaseException(\Exception $exception): void {
-		if ($this->logDbException) {
-			if ($exception instanceof Exception\UniqueConstraintViolationException) {
-				$this->logger->info($exception->getMessage(), ['exception' => $exception, 'transaction' => $this->transactionBacktrace]);
-			} else {
-				$this->logger->error($exception->getMessage(), ['exception' => $exception, 'transaction' => $this->transactionBacktrace]);
-			}
-		}
-	}
-
-	public function getShardDefinition(string $name): ?ShardDefinition {
-		return $this->shards[$name] ?? null;
-	}
-
-	public function getCrossShardMoveHelper(): CrossShardMoveHelper {
-		return new CrossShardMoveHelper($this->shardConnectionManager);
-	}
+    /** @var string */
+    protected $tablePrefix;
+
+    /** @var \OC\DB\Adapter $adapter */
+    protected $adapter;
+
+    /** @var SystemConfig */
+    private $systemConfig;
+
+    private ClockInterface $clock;
+
+    private LoggerInterface $logger;
+
+    protected $lockedTable = null;
+
+    /** @var int */
+    protected $queriesBuilt = 0;
+
+    /** @var int */
+    protected $queriesExecuted = 0;
+
+    /** @var DbDataCollector|null */
+    protected $dbDataCollector = null;
+    private array $lastConnectionCheck = [];
+
+    protected ?float $transactionActiveSince = null;
+
+    /** @var array<string, int> */
+    protected $tableDirtyWrites = [];
+
+    protected bool $logDbException = false;
+    private ?array $transactionBacktrace = null;
+
+    protected bool $logRequestId;
+    protected string $requestId;
+
+    /** @var array<string, list<string>> */
+    protected array $partitions;
+    /** @var ShardDefinition[] */
+    protected array $shards = [];
+    protected ShardConnectionManager $shardConnectionManager;
+    protected AutoIncrementHandler $autoIncrementHandler;
+    protected bool $isShardingEnabled;
+
+    public const SHARD_PRESETS = [
+        'filecache' => [
+            'companion_keys' => [
+                'file_id',
+            ],
+            'companion_tables' => [
+                'filecache_extended',
+                'files_metadata',
+            ],
+            'primary_key' => 'fileid',
+            'shard_key' => 'storage',
+            'table' => 'filecache',
+        ],
+    ];
+
+    /**
+     * Initializes a new instance of the Connection class.
+     *
+     * @throws \Exception
+     */
+    public function __construct(
+        private array $params,
+        Driver $driver,
+        ?Configuration $config = null,
+        ?EventManager $eventManager = null,
+    ) {
+        if (!isset($params['adapter'])) {
+            throw new \Exception('adapter not set');
+        }
+        if (!isset($params['tablePrefix'])) {
+            throw new \Exception('tablePrefix not set');
+        }
+        /**
+         * @psalm-suppress InternalMethod
+         */
+        parent::__construct($params, $driver, $config, $eventManager);
+        $this->adapter = new $params['adapter']($this);
+        $this->tablePrefix = $params['tablePrefix'];
+        $this->isShardingEnabled = isset($this->params['sharding']) && !empty($this->params['sharding']);
+
+        if ($this->isShardingEnabled) {
+            /** @psalm-suppress InvalidArrayOffset */
+            $this->shardConnectionManager = $this->params['shard_connection_manager'] ?? Server::get(ShardConnectionManager::class);
+            /** @psalm-suppress InvalidArrayOffset */
+            $this->autoIncrementHandler = $this->params['auto_increment_handler'] ?? new AutoIncrementHandler(
+                Server::get(ICacheFactory::class),
+                $this->shardConnectionManager,
+            );
+        }
+        $this->systemConfig = \OC::$server->getSystemConfig();
+        $this->clock = Server::get(ClockInterface::class);
+        $this->logger = Server::get(LoggerInterface::class);
+
+        $this->logRequestId = $this->systemConfig->getValue('db.log_request_id', false);
+        $this->logDbException = $this->systemConfig->getValue('db.log_exceptions', false);
+        $this->requestId = Server::get(IRequestId::class)->getId();
+
+        /** @var \OCP\Profiler\IProfiler */
+        $profiler = Server::get(IProfiler::class);
+        if ($profiler->isEnabled()) {
+            $this->dbDataCollector = new DbDataCollector($this);
+            $profiler->add($this->dbDataCollector);
+            $debugStack = new BacktraceDebugStack();
+            $this->dbDataCollector->setDebugStack($debugStack);
+            $this->_config->setSQLLogger($debugStack);
+        }
+
+        /** @var array<string, array{shards: array[], mapper: ?string, from_primary_key: ?int, from_shard_key: ?int}> $shardConfig */
+        $shardConfig = $this->params['sharding'] ?? [];
+        $shardNames = array_keys($shardConfig);
+        $this->shards = array_map(function (array $config, string $name) {
+            if (!isset(self::SHARD_PRESETS[$name])) {
+                throw new \Exception("Shard preset $name not found");
+            }
+
+            $shardMapperClass = $config['mapper'] ?? RoundRobinShardMapper::class;
+            $shardMapper = Server::get($shardMapperClass);
+            if (!$shardMapper instanceof IShardMapper) {
+                throw new \Exception("Invalid shard mapper: $shardMapperClass");
+            }
+            return new ShardDefinition(
+                self::SHARD_PRESETS[$name]['table'],
+                self::SHARD_PRESETS[$name]['primary_key'],
+                self::SHARD_PRESETS[$name]['companion_keys'],
+                self::SHARD_PRESETS[$name]['shard_key'],
+                $shardMapper,
+                self::SHARD_PRESETS[$name]['companion_tables'],
+                $config['shards'],
+                $config['from_primary_key'] ?? 0,
+                $config['from_shard_key'] ?? 0,
+            );
+        }, $shardConfig, $shardNames);
+        $this->shards = array_combine($shardNames, $this->shards);
+        $this->partitions = array_map(function (ShardDefinition $shard) {
+            return array_merge([$shard->table], $shard->companionTables);
+        }, $this->shards);
+
+        $this->setNestTransactionsWithSavepoints(true);
+    }
+
+    /**
+     * @return IDBConnection[]
+     */
+    public function getShardConnections(): array {
+        $connections = [];
+        if ($this->isShardingEnabled) {
+            foreach ($this->shards as $shardDefinition) {
+                foreach ($shardDefinition->getAllShards() as $shard) {
+                    if ($shard !== ShardDefinition::MIGRATION_SHARD) {
+                        /** @var ConnectionAdapter $connection */
+                        $connections[] = $this->shardConnectionManager->getConnection($shardDefinition, $shard);
+                    }
+                }
+            }
+        }
+        return $connections;
+    }
+
+    /**
+     * @throws Exception
+     */
+    public function connect($connectionName = null) {
+        try {
+            if ($this->_conn) {
+                $this->reconnectIfNeeded();
+                /** @psalm-suppress InternalMethod */
+                return parent::connect();
+            }
+
+            // Only trigger the event logger for the initial connect call
+            $eventLogger = Server::get(IEventLogger::class);
+            $eventLogger->start('connect:db', 'db connection opened');
+            /** @psalm-suppress InternalMethod */
+            $status = parent::connect();
+            $eventLogger->end('connect:db');
+
+            $this->lastConnectionCheck[$this->getConnectionName()] = time();
+
+            return $status;
+        } catch (Exception $e) {
+            // throw a new exception to prevent leaking info from the stacktrace
+            throw new Exception('Failed to connect to the database: ' . $e->getMessage(), $e->getCode());
+        }
+    }
+
+    protected function performConnect(?string $connectionName = null): bool {
+        if (($connectionName ?? 'replica') === 'replica'
+            && count($this->params['replica']) === 1
+            && $this->params['primary'] === $this->params['replica'][0]) {
+            return parent::performConnect('primary');
+        }
+        return parent::performConnect($connectionName);
+    }
+
+    public function getStats(): array {
+        return [
+            'built' => $this->queriesBuilt,
+            'executed' => $this->queriesExecuted,
+        ];
+    }
+
+    /**
+     * Returns a QueryBuilder for the connection.
+     */
+    public function getQueryBuilder(): IQueryBuilder {
+        $this->queriesBuilt++;
+
+        $builder = new QueryBuilder(
+            new ConnectionAdapter($this),
+            $this->systemConfig,
+            $this->logger
+        );
+        if ($this->isShardingEnabled && count($this->partitions) > 0) {
+            $builder = new PartitionedQueryBuilder(
+                $builder,
+                $this->shards,
+                $this->shardConnectionManager,
+                $this->autoIncrementHandler,
+            );
+            foreach ($this->partitions as $name => $tables) {
+                $partition = new PartitionSplit($name, $tables);
+                $builder->addPartition($partition);
+            }
+            return $builder;
+        } else {
+            return $builder;
+        }
+    }
+
+    /**
+     * Gets the QueryBuilder for the connection.
+     *
+     * @return \Doctrine\DBAL\Query\QueryBuilder
+     * @deprecated 8.0.0 please use $this->getQueryBuilder() instead
+     */
+    public function createQueryBuilder() {
+        $backtrace = $this->getCallerBacktrace();
+        $this->logger->debug('Doctrine QueryBuilder retrieved in {backtrace}', ['app' => 'core', 'backtrace' => $backtrace]);
+        $this->queriesBuilt++;
+        return parent::createQueryBuilder();
+    }
+
+    /**
+     * Gets the ExpressionBuilder for the connection.
+     *
+     * @return \Doctrine\DBAL\Query\Expression\ExpressionBuilder
+     * @deprecated 8.0.0 please use $this->getQueryBuilder()->expr() instead
+     */
+    public function getExpressionBuilder() {
+        $backtrace = $this->getCallerBacktrace();
+        $this->logger->debug('Doctrine ExpressionBuilder retrieved in {backtrace}', ['app' => 'core', 'backtrace' => $backtrace]);
+        $this->queriesBuilt++;
+        return parent::getExpressionBuilder();
+    }
+
+    /**
+     * Get the file and line that called the method where `getCallerBacktrace()` was used
+     *
+     * @return string
+     */
+    protected function getCallerBacktrace() {
+        $traces = debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS, 2);
+
+        // 0 is the method where we use `getCallerBacktrace`
+        // 1 is the target method which uses the method we want to log
+        if (isset($traces[1])) {
+            return $traces[1]['file'] . ':' . $traces[1]['line'];
+        }
+
+        return '';
+    }
+
+    /**
+     * @return string
+     */
+    public function getPrefix() {
+        return $this->tablePrefix;
+    }
+
+    /**
+     * Prepares an SQL statement.
+     *
+     * @param string $statement The SQL statement to prepare.
+     * @param int|null $limit
+     * @param int|null $offset
+     *
+     * @return Statement The prepared statement.
+     * @throws Exception
+     */
+    public function prepare($sql, $limit = null, $offset = null): Statement {
+        if ($limit === -1 || $limit === null) {
+            $limit = null;
+        } else {
+            $limit = (int)$limit;
+        }
+        if ($offset !== null) {
+            $offset = (int)$offset;
+        }
+        if (!is_null($limit)) {
+            $platform = $this->getDatabasePlatform();
+            $sql = $platform->modifyLimitQuery($sql, $limit, $offset);
+        }
+        $statement = $this->finishQuery($sql);
+
+        return parent::prepare($statement);
+    }
+
+    /**
+     * Executes an, optionally parametrized, SQL query.
+     *
+     * If the query is parametrized, a prepared statement is used.
+     * If an SQLLogger is configured, the execution is logged.
+     *
+     * @param string $sql The SQL query to execute.
+     * @param array $params The parameters to bind to the query, if any.
+     * @param array $types The types the previous parameters are in.
+     * @param \Doctrine\DBAL\Cache\QueryCacheProfile|null $qcp The query cache profile, optional.
+     *
+     * @return Result The executed statement.
+     *
+     * @throws \Doctrine\DBAL\Exception
+     */
+    public function executeQuery(string $sql, array $params = [], $types = [], ?QueryCacheProfile $qcp = null): Result {
+        $tables = $this->getQueriedTables($sql);
+        $now = $this->clock->now()->getTimestamp();
+        $dirtyTableWrites = [];
+        foreach ($tables as $table) {
+            $lastAccess = $this->tableDirtyWrites[$table] ?? 0;
+            // Only very recent writes are considered dirty
+            if ($lastAccess >= ($now - 3)) {
+                $dirtyTableWrites[] = $table;
+            }
+        }
+        if ($this->isTransactionActive()) {
+            // Transacted queries go to the primary. The consistency of the primary guarantees that we can not run
+            // into a dirty read.
+        } elseif (count($dirtyTableWrites) === 0) {
+            // No tables read that could have been written already in the same request and no transaction active
+            // so we can switch back to the replica for reading as long as no writes happen that switch back to the primary
+            // We cannot log here as this would log too early in the server boot process
+            $this->ensureConnectedToReplica();
+        } else {
+            // Read to a table that has been written to previously
+            // While this might not necessarily mean that we did a read after write it is an indication for a code path to check
+            $this->logger->log(
+                (int)($this->systemConfig->getValue('loglevel_dirty_database_queries', null) ?? 0),
+                'dirty table reads: ' . $sql,
+                [
+                    'tables' => array_keys($this->tableDirtyWrites),
+                    'reads' => $tables,
+                    'exception' => new \Exception('dirty table reads: ' . $sql),
+                ],
+            );
+            // To prevent a dirty read on a replica that is slightly out of sync, we
+            // switch back to the primary. This is detrimental for performance but
+            // safer for consistency.
+            $this->ensureConnectedToPrimary();
+        }
+
+        $sql = $this->finishQuery($sql);
+        $this->queriesExecuted++;
+        $this->logQueryToFile($sql, $params);
+        try {
+            return parent::executeQuery($sql, $params, $types, $qcp);
+        } catch (\Exception $e) {
+            $this->logDatabaseException($e);
+            throw $e;
+        }
+    }
+
+    /**
+     * Helper function to get the list of tables affected by a given query
+     * used to track dirty tables that received a write with the current request
+     */
+    private function getQueriedTables(string $sql): array {
+        $re = '/(\*PREFIX\*\w+)/mi';
+        preg_match_all($re, $sql, $matches);
+        return array_map([$this, 'replaceTablePrefix'], $matches[0] ?? []);
+    }
+
+    /**
+     * @throws Exception
+     */
+    public function executeUpdate(string $sql, array $params = [], array $types = []): int {
+        return $this->executeStatement($sql, $params, $types);
+    }
+
+    /**
+     * Executes an SQL INSERT/UPDATE/DELETE query with the given parameters
+     * and returns the number of affected rows.
+     *
+     * This method supports PDO binding types as well as DBAL mapping types.
+     *
+     * @param string $sql The SQL query.
+     * @param array $params The query parameters.
+     * @param array $types The parameter types.
+     *
+     * @return int The number of affected rows.
+     *
+     * @throws \Doctrine\DBAL\Exception
+     */
+    public function executeStatement($sql, array $params = [], array $types = []): int {
+        $tables = $this->getQueriedTables($sql);
+        foreach ($tables as $table) {
+            $this->tableDirtyWrites[$table] = $this->clock->now()->getTimestamp();
+        }
+        $sql = $this->finishQuery($sql);
+        $this->queriesExecuted++;
+        $this->logQueryToFile($sql, $params);
+        try {
+            return (int)parent::executeStatement($sql, $params, $types);
+        } catch (\Exception $e) {
+            $this->logDatabaseException($e);
+            throw $e;
+        }
+    }
+
+    protected function logQueryToFile(string $sql, array $params): void {
+        $logFile = $this->systemConfig->getValue('query_log_file');
+        if ($logFile !== '' && is_writable(dirname($logFile)) && (!file_exists($logFile) || is_writable($logFile))) {
+            $prefix = '';
+            if ($this->systemConfig->getValue('query_log_file_requestid') === 'yes') {
+                $prefix .= Server::get(IRequestId::class)->getId() . "\t";
+            }
+
+            $postfix = '';
+            if ($this->systemConfig->getValue('query_log_file_parameters') === 'yes') {
+                $postfix .= '; ' . json_encode($params);
+            }
+
+            if ($this->systemConfig->getValue('query_log_file_backtrace') === 'yes') {
+                $trace = debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS);
+                array_pop($trace);
+                $postfix .= '; ' . json_encode($trace);
+            }
+
+            // FIXME:  Improve to log the actual target db host
+            $isPrimary = $this->connections['primary'] === $this->_conn;
+            $prefix .= ' ' . ($isPrimary === true ? 'primary' : 'replica') . ' ';
+            $prefix .= ' ' . $this->getTransactionNestingLevel() . ' ';
+
+            file_put_contents(
+                $this->systemConfig->getValue('query_log_file', ''),
+                $prefix . $sql . $postfix . "\n",
+                FILE_APPEND
+            );
+        }
+    }
+
+    /**
+     * Returns the ID of the last inserted row, or the last value from a sequence object,
+     * depending on the underlying driver.
+     *
+     * Note: This method may not return a meaningful or consistent result across different drivers,
+     * because the underlying database may not even support the notion of AUTO_INCREMENT/IDENTITY
+     * columns or sequences.
+     *
+     * @param string $seqName Name of the sequence object from which the ID should be returned.
+     *
+     * @return int the last inserted ID.
+     * @throws Exception
+     */
+    public function lastInsertId($name = null): int {
+        if ($name) {
+            $name = $this->replaceTablePrefix($name);
+        }
+        return $this->adapter->lastInsertId($name);
+    }
+
+    /**
+     * @internal
+     * @throws Exception
+     */
+    public function realLastInsertId($seqName = null) {
+        return parent::lastInsertId($seqName);
+    }
+
+    /**
+     * Insert a row if the matching row does not exists. To accomplish proper race condition avoidance
+     * it is needed that there is also a unique constraint on the values. Then this method will
+     * catch the exception and return 0.
+     *
+     * @param string $table The table name (will replace *PREFIX* with the actual prefix)
+     * @param array $input data that should be inserted into the table  (column name => value)
+     * @param array|null $compare List of values that should be checked for "if not exists"
+     *                            If this is null or an empty array, all keys of $input will be compared
+     *                            Please note: text fields (clob) must not be used in the compare array
+     * @return int number of inserted rows
+     * @throws \Doctrine\DBAL\Exception
+     * @deprecated 15.0.0 - use unique index and "try { $db->insert() } catch (UniqueConstraintViolationException $e) {}" instead, because it is more reliable and does not have the risk for deadlocks - see https://github.com/nextcloud/server/pull/12371
+     */
+    public function insertIfNotExist($table, $input, ?array $compare = null) {
+        try {
+            return $this->adapter->insertIfNotExist($table, $input, $compare);
+        } catch (\Exception $e) {
+            $this->logDatabaseException($e);
+            throw $e;
+        }
+    }
+
+    public function insertIgnoreConflict(string $table, array $values) : int {
+        try {
+            return $this->adapter->insertIgnoreConflict($table, $values);
+        } catch (\Exception $e) {
+            $this->logDatabaseException($e);
+            throw $e;
+        }
+    }
+
+    private function getType($value) {
+        if (is_bool($value)) {
+            return IQueryBuilder::PARAM_BOOL;
+        } elseif (is_int($value)) {
+            return IQueryBuilder::PARAM_INT;
+        } else {
+            return IQueryBuilder::PARAM_STR;
+        }
+    }
+
+    /**
+     * Insert or update a row value
+     *
+     * @param string $table
+     * @param array $keys (column name => value)
+     * @param array $values (column name => value)
+     * @param array $updatePreconditionValues ensure values match preconditions (column name => value)
+     * @return int number of new rows
+     * @throws \OCP\DB\Exception
+     * @throws PreConditionNotMetException
+     */
+    public function setValues(string $table, array $keys, array $values, array $updatePreconditionValues = []): int {
+        try {
+            $insertQb = $this->getQueryBuilder();
+            $insertQb->insert($table)
+                ->values(
+                    array_map(function ($value) use ($insertQb) {
+                        return $insertQb->createNamedParameter($value, $this->getType($value));
+                    }, array_merge($keys, $values))
+                );
+            return $insertQb->executeStatement();
+        } catch (\OCP\DB\Exception $e) {
+            if (!in_array($e->getReason(), [
+                \OCP\DB\Exception::REASON_CONSTRAINT_VIOLATION,
+                \OCP\DB\Exception::REASON_UNIQUE_CONSTRAINT_VIOLATION,
+            ])
+            ) {
+                throw $e;
+            }
+
+            // value already exists, try update
+            $updateQb = $this->getQueryBuilder();
+            $updateQb->update($table);
+            foreach ($values as $name => $value) {
+                $updateQb->set($name, $updateQb->createNamedParameter($value, $this->getType($value)));
+            }
+            $where = [];
+            $whereValues = array_merge($keys, $updatePreconditionValues);
+            foreach ($whereValues as $name => $value) {
+                if ($value === '') {
+                    $where[] = $updateQb->expr()->emptyString(
+                        $name
+                    );
+                } else {
+                    $where[] = $updateQb->expr()->eq(
+                        $name,
+                        $updateQb->createNamedParameter($value, $this->getType($value)),
+                        $this->getType($value)
+                    );
+                }
+            }
+            $updateQb->where($updateQb->expr()->andX(...$where));
+            $affected = $updateQb->executeStatement();
+
+            if ($affected === 0 && !empty($updatePreconditionValues)) {
+                throw new PreConditionNotMetException();
+            }
+
+            return 0;
+        }
+    }
+
+    /**
+     * Create an exclusive read+write lock on a table
+     *
+     * @param string $tableName
+     *
+     * @throws \BadMethodCallException When trying to acquire a second lock
+     * @throws Exception
+     * @since 9.1.0
+     */
+    public function lockTable($tableName) {
+        if ($this->lockedTable !== null) {
+            throw new \BadMethodCallException('Can not lock a new table until the previous lock is released.');
+        }
+
+        $tableName = $this->tablePrefix . $tableName;
+        $this->lockedTable = $tableName;
+        $this->adapter->lockTable($tableName);
+    }
+
+    /**
+     * Release a previous acquired lock again
+     *
+     * @throws Exception
+     * @since 9.1.0
+     */
+    public function unlockTable() {
+        $this->adapter->unlockTable();
+        $this->lockedTable = null;
+    }
+
+    /**
+     * returns the error code and message as a string for logging
+     * works with DoctrineException
+     * @return string
+     */
+    public function getError() {
+        $msg = $this->errorCode() . ': ';
+        $errorInfo = $this->errorInfo();
+        if (!empty($errorInfo)) {
+            $msg .= 'SQLSTATE = ' . $errorInfo[0] . ', ';
+            $msg .= 'Driver Code = ' . $errorInfo[1] . ', ';
+            $msg .= 'Driver Message = ' . $errorInfo[2];
+        }
+        return $msg;
+    }
+
+    public function errorCode() {
+        return -1;
+    }
+
+    public function errorInfo() {
+        return [];
+    }
+
+    /**
+     * Drop a table from the database if it exists
+     *
+     * @param string $table table name without the prefix
+     *
+     * @throws Exception
+     */
+    public function dropTable($table) {
+        $table = $this->tablePrefix . trim($table);
+        $schema = $this->createSchemaManager();
+        if ($schema->tablesExist([$table])) {
+            $schema->dropTable($table);
+        }
+    }
+
+    /**
+     * Truncate a table data if it exists
+     *
+     * @param string $table table name without the prefix
+     * @param bool $cascade whether to truncate cascading
+     *
+     * @throws Exception
+     */
+    public function truncateTable(string $table, bool $cascade) {
+        $this->executeStatement($this->getDatabasePlatform()
+            ->getTruncateTableSQL($this->tablePrefix . trim($table), $cascade));
+    }
+
+    /**
+     * Check if a table exists
+     *
+     * @param string $table table name without the prefix
+     *
+     * @return bool
+     * @throws Exception
+     */
+    public function tableExists($table) {
+        $table = $this->tablePrefix . trim($table);
+        $schema = $this->createSchemaManager();
+        return $schema->tablesExist([$table]);
+    }
+
+    protected function finishQuery(string $statement): string {
+        $statement = $this->replaceTablePrefix($statement);
+        $statement = $this->adapter->fixupStatement($statement);
+        if ($this->logRequestId) {
+            return $statement . ' /* reqid: ' . $this->requestId . ' */';
+        } else {
+            return $statement;
+        }
+    }
+
+    // internal use
+    /**
+     * @param string $statement
+     * @return string
+     */
+    protected function replaceTablePrefix($statement) {
+        return str_replace('*PREFIX*', $this->tablePrefix, $statement);
+    }
+
+    /**
+     * Check if a transaction is active
+     *
+     * @return bool
+     * @since 8.2.0
+     */
+    public function inTransaction() {
+        return $this->getTransactionNestingLevel() > 0;
+    }
+
+    /**
+     * Escape a parameter to be used in a LIKE query
+     *
+     * @param string $param
+     * @return string
+     */
+    public function escapeLikeParameter($param) {
+        return addcslashes($param, '\\_%');
+    }
+
+    /**
+     * Check whether or not the current database support 4byte wide unicode
+     *
+     * @return bool
+     * @since 11.0.0
+     */
+    public function supports4ByteText() {
+        if (!$this->getDatabasePlatform() instanceof MySQLPlatform) {
+            return true;
+        }
+        return $this->getParams()['charset'] === 'utf8mb4';
+    }
+
+
+    /**
+     * Create the schema of the connected database
+     *
+     * @return Schema
+     * @throws Exception
+     */
+    public function createSchema() {
+        $migrator = $this->getMigrator();
+        return $migrator->createSchema();
+    }
+
+    /**
+     * Migrate the database to the given schema
+     *
+     * @param Schema $toSchema
+     * @param bool $dryRun If true, will return the sql queries instead of running them.
+     *
+     * @throws Exception
+     *
+     * @return string|null Returns a string only if $dryRun is true.
+     */
+    public function migrateToSchema(Schema $toSchema, bool $dryRun = false) {
+        $migrator = $this->getMigrator();
+
+        if ($dryRun) {
+            return $migrator->generateChangeScript($toSchema);
+        } else {
+            $migrator->migrate($toSchema);
+            foreach ($this->getShardConnections() as $shardConnection) {
+                $shardConnection->migrateToSchema($toSchema);
+            }
+        }
+    }
+
+    private function getMigrator() {
+        // TODO properly inject those dependencies
+        $random = \OC::$server->get(ISecureRandom::class);
+        $platform = $this->getDatabasePlatform();
+        $config = \OC::$server->getConfig();
+        $dispatcher = Server::get(\OCP\EventDispatcher\IEventDispatcher::class);
+        if ($platform instanceof SqlitePlatform) {
+            return new SQLiteMigrator($this, $config, $dispatcher);
+        } elseif ($platform instanceof OraclePlatform) {
+            return new OracleMigrator($this, $config, $dispatcher);
+        } else {
+            return new Migrator($this, $config, $dispatcher);
+        }
+    }
+
+    public function beginTransaction() {
+        if (!$this->inTransaction()) {
+            $this->transactionBacktrace = debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS);
+            $this->transactionActiveSince = microtime(true);
+        }
+        return parent::beginTransaction();
+    }
+
+    public function commit() {
+        $result = parent::commit();
+        if ($this->getTransactionNestingLevel() === 0) {
+            $timeTook = microtime(true) - $this->transactionActiveSince;
+            $this->transactionBacktrace = null;
+            $this->transactionActiveSince = null;
+            if ($timeTook > 1) {
+                $logLevel = match (true) {
+                    $timeTook > 20 * 60 => ILogger::ERROR,
+                    $timeTook > 5 * 60 => ILogger::WARN,
+                    $timeTook > 10 => ILogger::INFO,
+                    default => ILogger::DEBUG,
+                };
+                $this->logger->log(
+                    $logLevel,
+                    'Transaction took ' . $timeTook . 's',
+                    [
+                        'exception' => new \Exception('Transaction took ' . $timeTook . 's'),
+                        'timeSpent' => $timeTook,
+                    ]
+                );
+            }
+        }
+        return $result;
+    }
+
+    public function rollBack() {
+        $result = parent::rollBack();
+        if ($this->getTransactionNestingLevel() === 0) {
+            $timeTook = microtime(true) - $this->transactionActiveSince;
+            $this->transactionBacktrace = null;
+            $this->transactionActiveSince = null;
+            if ($timeTook > 1) {
+                $logLevel = match (true) {
+                    $timeTook > 20 * 60 => ILogger::ERROR,
+                    $timeTook > 5 * 60 => ILogger::WARN,
+                    $timeTook > 10 => ILogger::INFO,
+                    default => ILogger::DEBUG,
+                };
+                $this->logger->log(
+                    $logLevel,
+                    'Transaction rollback took longer than 1s: ' . $timeTook,
+                    [
+                        'exception' => new \Exception('Long running transaction rollback'),
+                        'timeSpent' => $timeTook,
+                    ]
+                );
+            }
+        }
+        return $result;
+    }
+
+    private function reconnectIfNeeded(): void {
+        if (
+            !isset($this->lastConnectionCheck[$this->getConnectionName()])
+            || time() <= $this->lastConnectionCheck[$this->getConnectionName()] + 30
+            || $this->isTransactionActive()
+        ) {
+            return;
+        }
+
+        try {
+            $this->_conn->query($this->getDriver()->getDatabasePlatform()->getDummySelectSQL());
+            $this->lastConnectionCheck[$this->getConnectionName()] = time();
+        } catch (ConnectionLost|\Exception $e) {
+            $this->logger->warning('Exception during connectivity check, closing and reconnecting', ['exception' => $e]);
+            $this->close();
+        }
+    }
+
+    private function getConnectionName(): string {
+        return $this->isConnectedToPrimary() ? 'primary' : 'replica';
+    }
+
+    /**
+     * @return IDBConnection::PLATFORM_MYSQL|IDBConnection::PLATFORM_ORACLE|IDBConnection::PLATFORM_POSTGRES|IDBConnection::PLATFORM_SQLITE|IDBConnection::PLATFORM_MARIADB
+     */
+    public function getDatabaseProvider(bool $strict = false): string {
+        $platform = $this->getDatabasePlatform();
+        if ($strict && $platform instanceof MariaDBPlatform) {
+            return IDBConnection::PLATFORM_MARIADB;
+        } elseif ($platform instanceof MySQLPlatform) {
+            return IDBConnection::PLATFORM_MYSQL;
+        } elseif ($platform instanceof OraclePlatform) {
+            return IDBConnection::PLATFORM_ORACLE;
+        } elseif ($platform instanceof PostgreSQLPlatform) {
+            return IDBConnection::PLATFORM_POSTGRES;
+        } elseif ($platform instanceof SqlitePlatform) {
+            return IDBConnection::PLATFORM_SQLITE;
+        } else {
+            throw new \Exception('Database ' . $platform::class . ' not supported');
+        }
+    }
+
+    /**
+     * @internal Should only be used inside the QueryBuilder, ExpressionBuilder and FunctionBuilder
+     * All apps and API code should not need this and instead use provided functionality from the above.
+     */
+    public function getServerVersion(): string {
+        /** @var ServerInfoAwareConnection $this->_conn */
+        return $this->_conn->getServerVersion();
+    }
+
+    /**
+     * Log a database exception if enabled
+     *
+     * @param \Exception $exception
+     * @return void
+     */
+    public function logDatabaseException(\Exception $exception): void {
+        if ($this->logDbException) {
+            if ($exception instanceof Exception\UniqueConstraintViolationException) {
+                $this->logger->info($exception->getMessage(), ['exception' => $exception, 'transaction' => $this->transactionBacktrace]);
+            } else {
+                $this->logger->error($exception->getMessage(), ['exception' => $exception, 'transaction' => $this->transactionBacktrace]);
+            }
+        }
+    }
+
+    public function getShardDefinition(string $name): ?ShardDefinition {
+        return $this->shards[$name] ?? null;
+    }
+
+    public function getCrossShardMoveHelper(): CrossShardMoveHelper {
+        return new CrossShardMoveHelper($this->shardConnectionManager);
+    }
 }

lib/private/DB/QueryBuilder/QueryBuilder.php

Indentation +1366 added lines, -1366 removed lines

@@ -29,1371 +29,1371 @@
 use Psr\Log\LoggerInterface;
 
 class QueryBuilder implements IQueryBuilder {
-	/** @var ConnectionAdapter */
-	private $connection;
-
-	/** @var SystemConfig */
-	private $systemConfig;
-
-	private LoggerInterface $logger;
-
-	/** @var \Doctrine\DBAL\Query\QueryBuilder */
-	private $queryBuilder;
-
-	/** @var QuoteHelper */
-	private $helper;
-
-	/** @var bool */
-	private $automaticTablePrefix = true;
-	private bool $nonEmptyWhere = false;
-
-	/** @var string */
-	protected $lastInsertedTable;
-	private array $selectedColumns = [];
-
-	/**
-	 * Initializes a new QueryBuilder.
-	 *
-	 * @param ConnectionAdapter $connection
-	 * @param SystemConfig $systemConfig
-	 */
-	public function __construct(ConnectionAdapter $connection, SystemConfig $systemConfig, LoggerInterface $logger) {
-		$this->connection = $connection;
-		$this->systemConfig = $systemConfig;
-		$this->logger = $logger;
-		$this->queryBuilder = new \Doctrine\DBAL\Query\QueryBuilder($this->connection->getInner());
-		$this->helper = new QuoteHelper();
-	}
-
-	/**
-	 * Enable/disable automatic prefixing of table names with the oc_ prefix
-	 *
-	 * @param bool $enabled If set to true table names will be prefixed with the
-	 *                      owncloud database prefix automatically.
-	 * @since 8.2.0
-	 */
-	public function automaticTablePrefix($enabled) {
-		$this->automaticTablePrefix = (bool)$enabled;
-	}
-
-	/**
-	 * Gets an ExpressionBuilder used for object-oriented construction of query expressions.
-	 * This producer method is intended for convenient inline usage. Example:
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u')
-	 *         ->from('users', 'u')
-	 *         ->where($qb->expr()->eq('u.id', 1));
-	 * </code>
-	 *
-	 * For more complex expression construction, consider storing the expression
-	 * builder object in a local variable.
-	 *
-	 * @return \OCP\DB\QueryBuilder\IExpressionBuilder
-	 */
-	public function expr() {
-		return match($this->connection->getDatabaseProvider()) {
-			IDBConnection::PLATFORM_ORACLE => new OCIExpressionBuilder($this->connection, $this, $this->logger),
-			IDBConnection::PLATFORM_POSTGRES => new PgSqlExpressionBuilder($this->connection, $this, $this->logger),
-			IDBConnection::PLATFORM_MARIADB,
-			IDBConnection::PLATFORM_MYSQL => new MySqlExpressionBuilder($this->connection, $this, $this->logger),
-			IDBConnection::PLATFORM_SQLITE => new SqliteExpressionBuilder($this->connection, $this, $this->logger),
-		};
-	}
-
-	/**
-	 * Gets an FunctionBuilder used for object-oriented construction of query functions.
-	 * This producer method is intended for convenient inline usage. Example:
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u')
-	 *         ->from('users', 'u')
-	 *         ->where($qb->fun()->md5('u.id'));
-	 * </code>
-	 *
-	 * For more complex function construction, consider storing the function
-	 * builder object in a local variable.
-	 *
-	 * @return \OCP\DB\QueryBuilder\IFunctionBuilder
-	 */
-	public function func() {
-		return match($this->connection->getDatabaseProvider()) {
-			IDBConnection::PLATFORM_ORACLE => new OCIFunctionBuilder($this->connection, $this, $this->helper),
-			IDBConnection::PLATFORM_POSTGRES => new PgSqlFunctionBuilder($this->connection, $this, $this->helper),
-			IDBConnection::PLATFORM_MARIADB,
-			IDBConnection::PLATFORM_MYSQL => new FunctionBuilder($this->connection, $this, $this->helper),
-			IDBConnection::PLATFORM_SQLITE => new SqliteFunctionBuilder($this->connection, $this, $this->helper),
-		};
-	}
-
-	/**
-	 * Gets the type of the currently built query.
-	 *
-	 * @return integer
-	 */
-	public function getType() {
-		return $this->queryBuilder->getType();
-	}
-
-	/**
-	 * Gets the associated DBAL Connection for this query builder.
-	 *
-	 * @return \OCP\IDBConnection
-	 */
-	public function getConnection() {
-		return $this->connection;
-	}
-
-	/**
-	 * Gets the state of this query builder instance.
-	 *
-	 * @return int Always returns 0 which is former `QueryBuilder::STATE_DIRTY`
-	 * @deprecated 30.0.0 This function is going to be removed with the next Doctrine/DBAL update
-	 *    and we can not fix this in our wrapper.
-	 */
-	public function getState() {
-		$this->logger->debug(IQueryBuilder::class . '::' . __FUNCTION__ . ' is deprecated and will be removed soon.', ['exception' => new \Exception('Deprecated call to ' . __METHOD__)]);
-		return $this->queryBuilder->getState();
-	}
-
-	private function prepareForExecute() {
-		if ($this->systemConfig->getValue('log_query', false)) {
-			try {
-				$params = [];
-				foreach ($this->getParameters() as $placeholder => $value) {
-					if ($value instanceof \DateTimeInterface) {
-						$params[] = $placeholder . ' => DateTime:\'' . $value->format('c') . '\'';
-					} elseif (is_array($value)) {
-						$params[] = $placeholder . ' => (\'' . implode('\', \'', $value) . '\')';
-					} else {
-						$params[] = $placeholder . ' => \'' . $value . '\'';
-					}
-				}
-				if (empty($params)) {
-					$this->logger->debug('DB QueryBuilder: \'{query}\'', [
-						'query' => $this->getSQL(),
-						'app' => 'core',
-					]);
-				} else {
-					$this->logger->debug('DB QueryBuilder: \'{query}\' with parameters: {params}', [
-						'query' => $this->getSQL(),
-						'params' => implode(', ', $params),
-						'app' => 'core',
-					]);
-				}
-			} catch (\Error $e) {
-				// likely an error during conversion of $value to string
-				$this->logger->error('DB QueryBuilder: error trying to log SQL query', ['exception' => $e]);
-			}
-		}
-
-		// if (!empty($this->getQueryPart('select'))) {
-		// $select = $this->getQueryPart('select');
-		// $hasSelectAll = array_filter($select, static function ($s) {
-		// return $s === '*';
-		// });
-		// $hasSelectSpecific = array_filter($select, static function ($s) {
-		// return $s !== '*';
-		// });
-
-		// if (empty($hasSelectAll) === empty($hasSelectSpecific)) {
-		// $exception = new QueryException('Query is selecting * and specific values in the same query. This is not supported in Oracle.');
-		// $this->logger->error($exception->getMessage(), [
-		// 'query' => $this->getSQL(),
-		// 'app' => 'core',
-		// 'exception' => $exception,
-		// ]);
-		// }
-		// }
-
-		$tooLongOutputColumns = [];
-		foreach ($this->getOutputColumns() as $column) {
-			if (strlen($column) > 30) {
-				$tooLongOutputColumns[] = $column;
-			}
-		}
-
-		if (!empty($tooLongOutputColumns)) {
-			$exception = new QueryException('More than 30 characters for an output column name are not allowed on Oracle.');
-			$this->logger->error($exception->getMessage(), [
-				'query' => $this->getSQL(),
-				'columns' => $tooLongOutputColumns,
-				'app' => 'core',
-				'exception' => $exception,
-			]);
-		}
-
-		$numberOfParameters = 0;
-		$hasTooLargeArrayParameter = false;
-		foreach ($this->getParameters() as $parameter) {
-			if (is_array($parameter)) {
-				$count = count($parameter);
-				$numberOfParameters += $count;
-				$hasTooLargeArrayParameter = $hasTooLargeArrayParameter || ($count > 1000);
-			}
-		}
-
-		if ($hasTooLargeArrayParameter) {
-			$exception = new QueryException('More than 1000 expressions in a list are not allowed on Oracle.');
-			$this->logger->error($exception->getMessage(), [
-				'query' => $this->getSQL(),
-				'app' => 'core',
-				'exception' => $exception,
-			]);
-		}
-
-		if ($numberOfParameters > 65535) {
-			$exception = new QueryException('The number of parameters must not exceed 65535. Restriction by PostgreSQL.');
-			$this->logger->error($exception->getMessage(), [
-				'query' => $this->getSQL(),
-				'app' => 'core',
-				'exception' => $exception,
-			]);
-		}
-	}
-
-	/**
-	 * Executes this query using the bound parameters and their types.
-	 *
-	 * Uses {@see Connection::executeQuery} for select statements and {@see Connection::executeUpdate}
-	 * for insert, update and delete statements.
-	 *
-	 * @return IResult|int
-	 */
-	public function execute(?IDBConnection $connection = null) {
-		try {
-			if ($this->getType() === \Doctrine\DBAL\Query\QueryBuilder::SELECT) {
-				return $this->executeQuery($connection);
-			} else {
-				return $this->executeStatement($connection);
-			}
-		} catch (DBALException $e) {
-			// `IQueryBuilder->execute` never wrapped the exception, but `executeQuery` and `executeStatement` do
-			/** @var \Doctrine\DBAL\Exception $previous */
-			$previous = $e->getPrevious();
-
-			throw $previous;
-		}
-	}
-
-	public function executeQuery(?IDBConnection $connection = null): IResult {
-		if ($this->getType() !== \Doctrine\DBAL\Query\QueryBuilder::SELECT) {
-			throw new \RuntimeException('Invalid query type, expected SELECT query');
-		}
-
-		$this->prepareForExecute();
-		if (!$connection) {
-			$connection = $this->connection;
-		}
-
-		return $connection->executeQuery(
-			$this->getSQL(),
-			$this->getParameters(),
-			$this->getParameterTypes(),
-		);
-	}
-
-	public function executeStatement(?IDBConnection $connection = null): int {
-		if ($this->getType() === \Doctrine\DBAL\Query\QueryBuilder::SELECT) {
-			throw new \RuntimeException('Invalid query type, expected INSERT, DELETE or UPDATE statement');
-		}
-
-		$this->prepareForExecute();
-		if (!$connection) {
-			$connection = $this->connection;
-		}
-
-		return $connection->executeStatement(
-			$this->getSQL(),
-			$this->getParameters(),
-			$this->getParameterTypes(),
-		);
-	}
-
-
-	/**
-	 * Gets the complete SQL string formed by the current specifications of this QueryBuilder.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u')
-	 *         ->from('User', 'u')
-	 *     echo $qb->getSQL(); // SELECT u FROM User u
-	 * </code>
-	 *
-	 * @return string The SQL query string.
-	 */
-	public function getSQL() {
-		return $this->queryBuilder->getSQL();
-	}
-
-	/**
-	 * Sets a query parameter for the query being constructed.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u')
-	 *         ->from('users', 'u')
-	 *         ->where('u.id = :user_id')
-	 *         ->setParameter(':user_id', 1);
-	 * </code>
-	 *
-	 * @param string|integer $key The parameter position or name.
-	 * @param mixed $value The parameter value.
-	 * @param string|null|int $type One of the IQueryBuilder::PARAM_* constants.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function setParameter($key, $value, $type = null) {
-		$this->queryBuilder->setParameter($key, $value, $type);
-
-		return $this;
-	}
-
-	/**
-	 * Sets a collection of query parameters for the query being constructed.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u')
-	 *         ->from('users', 'u')
-	 *         ->where('u.id = :user_id1 OR u.id = :user_id2')
-	 *         ->setParameters(array(
-	 *             ':user_id1' => 1,
-	 *             ':user_id2' => 2
-	 *         ));
-	 * </code>
-	 *
-	 * @param array $params The query parameters to set.
-	 * @param array $types The query parameters types to set.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function setParameters(array $params, array $types = []) {
-		$this->queryBuilder->setParameters($params, $types);
-
-		return $this;
-	}
-
-	/**
-	 * Gets all defined query parameters for the query being constructed indexed by parameter index or name.
-	 *
-	 * @return array The currently defined query parameters indexed by parameter index or name.
-	 */
-	public function getParameters() {
-		return $this->queryBuilder->getParameters();
-	}
-
-	/**
-	 * Gets a (previously set) query parameter of the query being constructed.
-	 *
-	 * @param mixed $key The key (index or name) of the bound parameter.
-	 *
-	 * @return mixed The value of the bound parameter.
-	 */
-	public function getParameter($key) {
-		return $this->queryBuilder->getParameter($key);
-	}
-
-	/**
-	 * Gets all defined query parameter types for the query being constructed indexed by parameter index or name.
-	 *
-	 * @return array The currently defined query parameter types indexed by parameter index or name.
-	 */
-	public function getParameterTypes() {
-		return $this->queryBuilder->getParameterTypes();
-	}
-
-	/**
-	 * Gets a (previously set) query parameter type of the query being constructed.
-	 *
-	 * @param mixed $key The key (index or name) of the bound parameter type.
-	 *
-	 * @return mixed The value of the bound parameter type.
-	 */
-	public function getParameterType($key) {
-		return $this->queryBuilder->getParameterType($key);
-	}
-
-	/**
-	 * Sets the position of the first result to retrieve (the "offset").
-	 *
-	 * @param int $firstResult The first result to return.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function setFirstResult($firstResult) {
-		$this->queryBuilder->setFirstResult((int)$firstResult);
-
-		return $this;
-	}
-
-	/**
-	 * Gets the position of the first result the query object was set to retrieve (the "offset").
-	 * Returns 0 if {@link setFirstResult} was not applied to this QueryBuilder.
-	 *
-	 * @return int The position of the first result.
-	 */
-	public function getFirstResult() {
-		return $this->queryBuilder->getFirstResult();
-	}
-
-	/**
-	 * Sets the maximum number of results to retrieve (the "limit").
-	 *
-	 * NOTE: Setting max results to "0" will cause mixed behaviour. While most
-	 * of the databases will just return an empty result set, Oracle will return
-	 * all entries.
-	 *
-	 * @param int|null $maxResults The maximum number of results to retrieve.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function setMaxResults($maxResults) {
-		if ($maxResults === null) {
-			$this->queryBuilder->setMaxResults($maxResults);
-		} else {
-			$this->queryBuilder->setMaxResults((int)$maxResults);
-		}
-
-		return $this;
-	}
-
-	/**
-	 * Gets the maximum number of results the query object was set to retrieve (the "limit").
-	 * Returns NULL if {@link setMaxResults} was not applied to this query builder.
-	 *
-	 * @return int|null The maximum number of results.
-	 */
-	public function getMaxResults() {
-		return $this->queryBuilder->getMaxResults();
-	}
-
-	/**
-	 * Specifies an item that is to be returned in the query result.
-	 * Replaces any previously specified selections, if any.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u.id', 'p.id')
-	 *         ->from('users', 'u')
-	 *         ->leftJoin('u', 'phonenumbers', 'p', 'u.id = p.user_id');
-	 * </code>
-	 *
-	 * @param mixed ...$selects The selection expressions.
-	 *
-	 * '@return $this This QueryBuilder instance.
-	 */
-	public function select(...$selects) {
-		if (count($selects) === 1 && is_array($selects[0])) {
-			$selects = $selects[0];
-		}
-		$this->addOutputColumns($selects);
-
-		$this->queryBuilder->select(
-			$this->helper->quoteColumnNames($selects)
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Specifies an item that is to be returned with a different name in the query result.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->selectAlias('u.id', 'user_id')
-	 *         ->from('users', 'u')
-	 *         ->leftJoin('u', 'phonenumbers', 'p', 'u.id = p.user_id');
-	 * </code>
-	 *
-	 * @param mixed $select The selection expressions.
-	 * @param string $alias The column alias used in the constructed query.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function selectAlias($select, $alias) {
-		$this->queryBuilder->addSelect(
-			$this->helper->quoteColumnName($select) . ' AS ' . $this->helper->quoteColumnName($alias)
-		);
-		$this->addOutputColumns([$alias]);
-
-		return $this;
-	}
-
-	/**
-	 * Specifies an item that is to be returned uniquely in the query result.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->selectDistinct('type')
-	 *         ->from('users');
-	 * </code>
-	 *
-	 * @param mixed $select The selection expressions.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function selectDistinct($select) {
-		if (!is_array($select)) {
-			$select = [$select];
-		}
-		$this->addOutputColumns($select);
-
-		$quotedSelect = $this->helper->quoteColumnNames($select);
-
-		$this->queryBuilder->addSelect(
-			'DISTINCT ' . implode(', ', $quotedSelect)
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Adds an item that is to be returned in the query result.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u.id')
-	 *         ->addSelect('p.id')
-	 *         ->from('users', 'u')
-	 *         ->leftJoin('u', 'phonenumbers', 'u.id = p.user_id');
-	 * </code>
-	 *
-	 * @param mixed ...$selects The selection expression.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function addSelect(...$selects) {
-		if (count($selects) === 1 && is_array($selects[0])) {
-			$selects = $selects[0];
-		}
-		$this->addOutputColumns($selects);
-
-		$this->queryBuilder->addSelect(
-			$this->helper->quoteColumnNames($selects)
-		);
-
-		return $this;
-	}
-
-	private function addOutputColumns(array $columns): void {
-		foreach ($columns as $column) {
-			if (is_array($column)) {
-				$this->addOutputColumns($column);
-			} elseif (is_string($column) && !str_contains($column, '*')) {
-				if (str_contains(strtolower($column), ' as ')) {
-					[, $column] = preg_split('/ as /i', $column);
-				}
-				if (str_contains($column, '.')) {
-					[, $column] = explode('.', $column);
-				}
-				$this->selectedColumns[] = $column;
-			}
-		}
-	}
-
-	public function getOutputColumns(): array {
-		return array_unique($this->selectedColumns);
-	}
-
-	/**
-	 * Turns the query being built into a bulk delete query that ranges over
-	 * a certain table.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->delete('users', 'u')
-	 *         ->where('u.id = :user_id');
-	 *         ->setParameter(':user_id', 1);
-	 * </code>
-	 *
-	 * @param string $delete The table whose rows are subject to the deletion.
-	 * @param string $alias The table alias used in the constructed query.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 * @since 30.0.0 Alias is deprecated and will no longer be used with the next Doctrine/DBAL update
-	 */
-	public function delete($delete = null, $alias = null) {
-		if ($alias !== null) {
-			$this->logger->debug('DELETE queries with alias are no longer supported and the provided alias is ignored', ['exception' => new \InvalidArgumentException('Table alias provided for DELETE query')]);
-		}
-
-		$this->queryBuilder->delete(
-			$this->getTableName($delete),
-			$alias
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Turns the query being built into a bulk update query that ranges over
-	 * a certain table
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->update('users', 'u')
-	 *         ->set('u.password', md5('password'))
-	 *         ->where('u.id = ?');
-	 * </code>
-	 *
-	 * @param string $update The table whose rows are subject to the update.
-	 * @param string $alias The table alias used in the constructed query.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 * @since 30.0.0 Alias is deprecated and will no longer be used with the next Doctrine/DBAL update
-	 */
-	public function update($update = null, $alias = null) {
-		if ($alias !== null) {
-			$this->logger->debug('UPDATE queries with alias are no longer supported and the provided alias is ignored', ['exception' => new \InvalidArgumentException('Table alias provided for UPDATE query')]);
-		}
-
-		$this->queryBuilder->update(
-			$this->getTableName($update),
-			$alias
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Turns the query being built into an insert query that inserts into
-	 * a certain table
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->insert('users')
-	 *         ->values(
-	 *             array(
-	 *                 'name' => '?',
-	 *                 'password' => '?'
-	 *             )
-	 *         );
-	 * </code>
-	 *
-	 * @param string $insert The table into which the rows should be inserted.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function insert($insert = null) {
-		$this->queryBuilder->insert(
-			$this->getTableName($insert)
-		);
-
-		$this->lastInsertedTable = $insert;
-
-		return $this;
-	}
-
-	/**
-	 * Creates and adds a query root corresponding to the table identified by the
-	 * given alias, forming a cartesian product with any existing query roots.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u.id')
-	 *         ->from('users', 'u')
-	 * </code>
-	 *
-	 * @param string|IQueryFunction $from The table.
-	 * @param string|null $alias The alias of the table.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function from($from, $alias = null) {
-		$this->queryBuilder->from(
-			$this->getTableName($from),
-			$this->quoteAlias($alias)
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Creates and adds a join to the query.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u.name')
-	 *         ->from('users', 'u')
-	 *         ->join('u', 'phonenumbers', 'p', 'p.is_primary = 1');
-	 * </code>
-	 *
-	 * @param string $fromAlias The alias that points to a from clause.
-	 * @param string $join The table name to join.
-	 * @param string $alias The alias of the join table.
-	 * @param string|ICompositeExpression|null $condition The condition for the join.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function join($fromAlias, $join, $alias, $condition = null) {
-		$this->queryBuilder->join(
-			$this->quoteAlias($fromAlias),
-			$this->getTableName($join),
-			$this->quoteAlias($alias),
-			$condition
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Creates and adds a join to the query.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u.name')
-	 *         ->from('users', 'u')
-	 *         ->innerJoin('u', 'phonenumbers', 'p', 'p.is_primary = 1');
-	 * </code>
-	 *
-	 * @param string $fromAlias The alias that points to a from clause.
-	 * @param string $join The table name to join.
-	 * @param string $alias The alias of the join table.
-	 * @param string|ICompositeExpression|null $condition The condition for the join.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function innerJoin($fromAlias, $join, $alias, $condition = null) {
-		$this->queryBuilder->innerJoin(
-			$this->quoteAlias($fromAlias),
-			$this->getTableName($join),
-			$this->quoteAlias($alias),
-			$condition
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Creates and adds a left join to the query.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u.name')
-	 *         ->from('users', 'u')
-	 *         ->leftJoin('u', 'phonenumbers', 'p', 'p.is_primary = 1');
-	 * </code>
-	 *
-	 * @param string $fromAlias The alias that points to a from clause.
-	 * @param string|IQueryFunction $join The table name or sub-query to join.
-	 * @param string $alias The alias of the join table.
-	 * @param string|ICompositeExpression|null $condition The condition for the join.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function leftJoin($fromAlias, $join, $alias, $condition = null) {
-		$this->queryBuilder->leftJoin(
-			$this->quoteAlias($fromAlias),
-			$this->getTableName($join),
-			$this->quoteAlias($alias),
-			$condition
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Creates and adds a right join to the query.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u.name')
-	 *         ->from('users', 'u')
-	 *         ->rightJoin('u', 'phonenumbers', 'p', 'p.is_primary = 1');
-	 * </code>
-	 *
-	 * @param string $fromAlias The alias that points to a from clause.
-	 * @param string $join The table name to join.
-	 * @param string $alias The alias of the join table.
-	 * @param string|ICompositeExpression|null $condition The condition for the join.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function rightJoin($fromAlias, $join, $alias, $condition = null) {
-		$this->queryBuilder->rightJoin(
-			$this->quoteAlias($fromAlias),
-			$this->getTableName($join),
-			$this->quoteAlias($alias),
-			$condition
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Sets a new value for a column in a bulk update query.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->update('users', 'u')
-	 *         ->set('u.password', md5('password'))
-	 *         ->where('u.id = ?');
-	 * </code>
-	 *
-	 * @param string $key The column to set.
-	 * @param ILiteral|IParameter|IQueryFunction|string $value The value, expression, placeholder, etc.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function set($key, $value) {
-		$this->queryBuilder->set(
-			$this->helper->quoteColumnName($key),
-			$this->helper->quoteColumnName($value)
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Specifies one or more restrictions to the query result.
-	 * Replaces any previously specified restrictions, if any.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u.name')
-	 *         ->from('users', 'u')
-	 *         ->where('u.id = ?');
-	 *
-	 *     // You can optionally programmatically build and/or expressions
-	 *     $qb = $conn->getQueryBuilder();
-	 *
-	 *     $or = $qb->expr()->orx(
-	 *         $qb->expr()->eq('u.id', 1),
-	 *         $qb->expr()->eq('u.id', 2),
-	 *     );
-	 *
-	 *     $qb->update('users', 'u')
-	 *         ->set('u.password', md5('password'))
-	 *         ->where($or);
-	 * </code>
-	 *
-	 * @param mixed ...$predicates The restriction predicates.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function where(...$predicates) {
-		if ($this->nonEmptyWhere && $this->systemConfig->getValue('debug', false)) {
-			// Only logging a warning, not throwing for now.
-			$e = new QueryException('Using where() on non-empty WHERE part, please verify it is intentional to not call andWhere() or orWhere() instead. Otherwise consider creating a new query builder object or call resetQueryPart(\'where\') first.');
-			$this->logger->warning($e->getMessage(), ['exception' => $e]);
-		}
-
-		$this->nonEmptyWhere = true;
-
-		call_user_func_array(
-			[$this->queryBuilder, 'where'],
-			$predicates
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Adds one or more restrictions to the query results, forming a logical
-	 * conjunction with any previously specified restrictions.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u')
-	 *         ->from('users', 'u')
-	 *         ->where('u.username LIKE ?')
-	 *         ->andWhere('u.is_active = 1');
-	 * </code>
-	 *
-	 * @param mixed ...$where The query restrictions.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 *
-	 * @see where()
-	 */
-	public function andWhere(...$where) {
-		$this->nonEmptyWhere = true;
-		call_user_func_array(
-			[$this->queryBuilder, 'andWhere'],
-			$where
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Adds one or more restrictions to the query results, forming a logical
-	 * disjunction with any previously specified restrictions.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u.name')
-	 *         ->from('users', 'u')
-	 *         ->where('u.id = 1')
-	 *         ->orWhere('u.id = 2');
-	 * </code>
-	 *
-	 * @param mixed ...$where The WHERE statement.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 *
-	 * @see where()
-	 */
-	public function orWhere(...$where) {
-		$this->nonEmptyWhere = true;
-		call_user_func_array(
-			[$this->queryBuilder, 'orWhere'],
-			$where
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Specifies a grouping over the results of the query.
-	 * Replaces any previously specified groupings, if any.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u.name')
-	 *         ->from('users', 'u')
-	 *         ->groupBy('u.id');
-	 * </code>
-	 *
-	 * @param mixed ...$groupBys The grouping expression.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function groupBy(...$groupBys) {
-		if (count($groupBys) === 1 && is_array($groupBys[0])) {
-			$groupBys = $groupBys[0];
-		}
-
-		call_user_func_array(
-			[$this->queryBuilder, 'groupBy'],
-			$this->helper->quoteColumnNames($groupBys)
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Adds a grouping expression to the query.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->select('u.name')
-	 *         ->from('users', 'u')
-	 *         ->groupBy('u.lastLogin');
-	 *         ->addGroupBy('u.createdAt')
-	 * </code>
-	 *
-	 * @param mixed ...$groupBy The grouping expression.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function addGroupBy(...$groupBy) {
-		call_user_func_array(
-			[$this->queryBuilder, 'addGroupBy'],
-			$this->helper->quoteColumnNames($groupBy)
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Sets a value for a column in an insert query.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->insert('users')
-	 *         ->values(
-	 *             array(
-	 *                 'name' => '?'
-	 *             )
-	 *         )
-	 *         ->setValue('password', '?');
-	 * </code>
-	 *
-	 * @param string $column The column into which the value should be inserted.
-	 * @param IParameter|string $value The value that should be inserted into the column.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function setValue($column, $value) {
-		$this->queryBuilder->setValue(
-			$this->helper->quoteColumnName($column),
-			(string)$value
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Specifies values for an insert query indexed by column names.
-	 * Replaces any previous values, if any.
-	 *
-	 * <code>
-	 *     $qb = $conn->getQueryBuilder()
-	 *         ->insert('users')
-	 *         ->values(
-	 *             array(
-	 *                 'name' => '?',
-	 *                 'password' => '?'
-	 *             )
-	 *         );
-	 * </code>
-	 *
-	 * @param array $values The values to specify for the insert query indexed by column names.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function values(array $values) {
-		$quotedValues = [];
-		foreach ($values as $key => $value) {
-			$quotedValues[$this->helper->quoteColumnName($key)] = $value;
-		}
-
-		$this->queryBuilder->values($quotedValues);
-
-		return $this;
-	}
-
-	/**
-	 * Specifies a restriction over the groups of the query.
-	 * Replaces any previous having restrictions, if any.
-	 *
-	 * @param mixed ...$having The restriction over the groups.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function having(...$having) {
-		call_user_func_array(
-			[$this->queryBuilder, 'having'],
-			$having
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Adds a restriction over the groups of the query, forming a logical
-	 * conjunction with any existing having restrictions.
-	 *
-	 * @param mixed ...$having The restriction to append.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function andHaving(...$having) {
-		call_user_func_array(
-			[$this->queryBuilder, 'andHaving'],
-			$having
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Adds a restriction over the groups of the query, forming a logical
-	 * disjunction with any existing having restrictions.
-	 *
-	 * @param mixed ...$having The restriction to add.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function orHaving(...$having) {
-		call_user_func_array(
-			[$this->queryBuilder, 'orHaving'],
-			$having
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Specifies an ordering for the query results.
-	 * Replaces any previously specified orderings, if any.
-	 *
-	 * @param string|IQueryFunction|ILiteral|IParameter $sort The ordering expression.
-	 * @param string $order The ordering direction.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function orderBy($sort, $order = null) {
-		$this->queryBuilder->orderBy(
-			$this->helper->quoteColumnName($sort),
-			$order
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Adds an ordering to the query results.
-	 *
-	 * @param string|ILiteral|IParameter|IQueryFunction $sort The ordering expression.
-	 * @param string $order The ordering direction.
-	 *
-	 * @return $this This QueryBuilder instance.
-	 */
-	public function addOrderBy($sort, $order = null) {
-		$this->queryBuilder->addOrderBy(
-			$this->helper->quoteColumnName($sort),
-			$order
-		);
-
-		return $this;
-	}
-
-	/**
-	 * Gets a query part by its name.
-	 *
-	 * @param string $queryPartName
-	 *
-	 * @return mixed
-	 * @deprecated 30.0.0 This function is going to be removed with the next Doctrine/DBAL update
-	 *   and we can not fix this in our wrapper. Please track the details you need, outside the object.
-	 */
-	public function getQueryPart($queryPartName) {
-		$this->logger->debug(IQueryBuilder::class . '::' . __FUNCTION__ . ' is deprecated and will be removed soon.', ['exception' => new \Exception('Deprecated call to ' . __METHOD__)]);
-		return $this->queryBuilder->getQueryPart($queryPartName);
-	}
-
-	/**
-	 * Gets all query parts.
-	 *
-	 * @return array
-	 * @deprecated 30.0.0 This function is going to be removed with the next Doctrine/DBAL update
-	 *   and we can not fix this in our wrapper. Please track the details you need, outside the object.
-	 */
-	public function getQueryParts() {
-		$this->logger->debug(IQueryBuilder::class . '::' . __FUNCTION__ . ' is deprecated and will be removed soon.', ['exception' => new \Exception('Deprecated call to ' . __METHOD__)]);
-		return $this->queryBuilder->getQueryParts();
-	}
-
-	/**
-	 * Resets SQL parts.
-	 *
-	 * @param array|null $queryPartNames
-	 *
-	 * @return $this This QueryBuilder instance.
-	 * @deprecated 30.0.0 This function is going to be removed with the next Doctrine/DBAL update
-	 *  and we can not fix this in our wrapper. Please create a new IQueryBuilder instead.
-	 */
-	public function resetQueryParts($queryPartNames = null) {
-		$this->logger->debug(IQueryBuilder::class . '::' . __FUNCTION__ . ' is deprecated and will be removed soon.', ['exception' => new \Exception('Deprecated call to ' . __METHOD__)]);
-		$this->queryBuilder->resetQueryParts($queryPartNames);
-
-		return $this;
-	}
-
-	/**
-	 * Resets a single SQL part.
-	 *
-	 * @param string $queryPartName
-	 *
-	 * @return $this This QueryBuilder instance.
-	 * @deprecated 30.0.0 This function is going to be removed with the next Doctrine/DBAL update
-	 *  and we can not fix this in our wrapper. Please create a new IQueryBuilder instead.
-	 */
-	public function resetQueryPart($queryPartName) {
-		$this->logger->debug(IQueryBuilder::class . '::' . __FUNCTION__ . ' is deprecated and will be removed soon.', ['exception' => new \Exception('Deprecated call to ' . __METHOD__)]);
-		$this->queryBuilder->resetQueryPart($queryPartName);
-
-		return $this;
-	}
-
-	/**
-	 * Creates a new named parameter and bind the value $value to it.
-	 *
-	 * This method provides a shortcut for PDOStatement::bindValue
-	 * when using prepared statements.
-	 *
-	 * The parameter $value specifies the value that you want to bind. If
-	 * $placeholder is not provided bindValue() will automatically create a
-	 * placeholder for you. An automatic placeholder will be of the name
-	 * ':dcValue1', ':dcValue2' etc.
-	 *
-	 * For more information see {@link https://www.php.net/pdostatement-bindparam}
-	 *
-	 * Example:
-	 * <code>
-	 * $value = 2;
-	 * $q->eq( 'id', $q->bindValue( $value ) );
-	 * $stmt = $q->executeQuery(); // executed with 'id = 2'
-	 * </code>
-	 *
-	 * @license New BSD License
-	 * @link http://www.zetacomponents.org
-	 *
-	 * @param mixed $value
-	 * @param IQueryBuilder::PARAM_* $type
-	 * @param string $placeHolder The name to bind with. The string must start with a colon ':'.
-	 *
-	 * @return IParameter the placeholder name used.
-	 */
-	public function createNamedParameter($value, $type = IQueryBuilder::PARAM_STR, $placeHolder = null) {
-		return new Parameter($this->queryBuilder->createNamedParameter($value, $type, $placeHolder));
-	}
-
-	/**
-	 * Creates a new positional parameter and bind the given value to it.
-	 *
-	 * Attention: If you are using positional parameters with the query builder you have
-	 * to be very careful to bind all parameters in the order they appear in the SQL
-	 * statement , otherwise they get bound in the wrong order which can lead to serious
-	 * bugs in your code.
-	 *
-	 * Example:
-	 * <code>
-	 *  $qb = $conn->getQueryBuilder();
-	 *  $qb->select('u.*')
-	 *     ->from('users', 'u')
-	 *     ->where('u.username = ' . $qb->createPositionalParameter('Foo', IQueryBuilder::PARAM_STR))
-	 *     ->orWhere('u.username = ' . $qb->createPositionalParameter('Bar', IQueryBuilder::PARAM_STR))
-	 * </code>
-	 *
-	 * @param mixed $value
-	 * @param IQueryBuilder::PARAM_* $type
-	 *
-	 * @return IParameter
-	 */
-	public function createPositionalParameter($value, $type = IQueryBuilder::PARAM_STR) {
-		return new Parameter($this->queryBuilder->createPositionalParameter($value, $type));
-	}
-
-	/**
-	 * Creates a new parameter
-	 *
-	 * Example:
-	 * <code>
-	 *  $qb = $conn->getQueryBuilder();
-	 *  $qb->select('u.*')
-	 *     ->from('users', 'u')
-	 *     ->where('u.username = ' . $qb->createParameter('name'))
-	 *     ->setParameter('name', 'Bar', IQueryBuilder::PARAM_STR))
-	 * </code>
-	 *
-	 * @param string $name
-	 *
-	 * @return IParameter
-	 */
-	public function createParameter($name) {
-		return new Parameter(':' . $name);
-	}
-
-	/**
-	 * Creates a new function
-	 *
-	 * Attention: Column names inside the call have to be quoted before hand
-	 *
-	 * Example:
-	 * <code>
-	 *  $qb = $conn->getQueryBuilder();
-	 *  $qb->select($qb->createFunction('COUNT(*)'))
-	 *     ->from('users', 'u')
-	 *  echo $qb->getSQL(); // SELECT COUNT(*) FROM `users` u
-	 * </code>
-	 * <code>
-	 *  $qb = $conn->getQueryBuilder();
-	 *  $qb->select($qb->createFunction('COUNT(`column`)'))
-	 *     ->from('users', 'u')
-	 *  echo $qb->getSQL(); // SELECT COUNT(`column`) FROM `users` u
-	 * </code>
-	 *
-	 * @param string $call
-	 *
-	 * @return IQueryFunction
-	 */
-	public function createFunction($call) {
-		return new QueryFunction($call);
-	}
-
-	/**
-	 * Used to get the id of the last inserted element
-	 * @return int
-	 * @throws \BadMethodCallException When being called before an insert query has been run.
-	 */
-	public function getLastInsertId(): int {
-		if ($this->getType() === \Doctrine\DBAL\Query\QueryBuilder::INSERT && $this->lastInsertedTable) {
-			// lastInsertId() needs the prefix but no quotes
-			$table = $this->prefixTableName($this->lastInsertedTable);
-			return $this->connection->lastInsertId($table);
-		}
-
-		throw new \BadMethodCallException('Invalid call to getLastInsertId without using insert() before.');
-	}
-
-	/**
-	 * Returns the table name quoted and with database prefix as needed by the implementation
-	 *
-	 * @param string|IQueryFunction $table
-	 * @return string
-	 */
-	public function getTableName($table) {
-		if ($table instanceof IQueryFunction) {
-			return (string)$table;
-		}
-
-		$table = $this->prefixTableName($table);
-		return $this->helper->quoteColumnName($table);
-	}
-
-	/**
-	 * Returns the table name with database prefix as needed by the implementation
-	 *
-	 * Was protected until version 30.
-	 *
-	 * @param string $table
-	 * @return string
-	 */
-	public function prefixTableName(string $table): string {
-		if ($this->automaticTablePrefix === false || str_starts_with($table, '*PREFIX*')) {
-			return $table;
-		}
-
-		return '*PREFIX*' . $table;
-	}
-
-	/**
-	 * Returns the column name quoted and with table alias prefix as needed by the implementation
-	 *
-	 * @param string $column
-	 * @param string $tableAlias
-	 * @return string
-	 */
-	public function getColumnName($column, $tableAlias = '') {
-		if ($tableAlias !== '') {
-			$tableAlias .= '.';
-		}
-
-		return $this->helper->quoteColumnName($tableAlias . $column);
-	}
-
-	/**
-	 * Returns the column name quoted and with table alias prefix as needed by the implementation
-	 *
-	 * @param string $alias
-	 * @return string
-	 */
-	public function quoteAlias($alias) {
-		if ($alias === '' || $alias === null) {
-			return $alias;
-		}
-
-		return $this->helper->quoteColumnName($alias);
-	}
-
-	public function escapeLikeParameter(string $parameter): string {
-		return $this->connection->escapeLikeParameter($parameter);
-	}
-
-	public function hintShardKey(string $column, mixed $value, bool $overwrite = false): self {
-		return $this;
-	}
-
-	public function runAcrossAllShards(): self {
-		// noop
-		return $this;
-	}
+    /** @var ConnectionAdapter */
+    private $connection;
+
+    /** @var SystemConfig */
+    private $systemConfig;
+
+    private LoggerInterface $logger;
+
+    /** @var \Doctrine\DBAL\Query\QueryBuilder */
+    private $queryBuilder;
+
+    /** @var QuoteHelper */
+    private $helper;
+
+    /** @var bool */
+    private $automaticTablePrefix = true;
+    private bool $nonEmptyWhere = false;
+
+    /** @var string */
+    protected $lastInsertedTable;
+    private array $selectedColumns = [];
+
+    /**
+     * Initializes a new QueryBuilder.
+     *
+     * @param ConnectionAdapter $connection
+     * @param SystemConfig $systemConfig
+     */
+    public function __construct(ConnectionAdapter $connection, SystemConfig $systemConfig, LoggerInterface $logger) {
+        $this->connection = $connection;
+        $this->systemConfig = $systemConfig;
+        $this->logger = $logger;
+        $this->queryBuilder = new \Doctrine\DBAL\Query\QueryBuilder($this->connection->getInner());
+        $this->helper = new QuoteHelper();
+    }
+
+    /**
+     * Enable/disable automatic prefixing of table names with the oc_ prefix
+     *
+     * @param bool $enabled If set to true table names will be prefixed with the
+     *                      owncloud database prefix automatically.
+     * @since 8.2.0
+     */
+    public function automaticTablePrefix($enabled) {
+        $this->automaticTablePrefix = (bool)$enabled;
+    }
+
+    /**
+     * Gets an ExpressionBuilder used for object-oriented construction of query expressions.
+     * This producer method is intended for convenient inline usage. Example:
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u')
+     *         ->from('users', 'u')
+     *         ->where($qb->expr()->eq('u.id', 1));
+     * </code>
+     *
+     * For more complex expression construction, consider storing the expression
+     * builder object in a local variable.
+     *
+     * @return \OCP\DB\QueryBuilder\IExpressionBuilder
+     */
+    public function expr() {
+        return match($this->connection->getDatabaseProvider()) {
+            IDBConnection::PLATFORM_ORACLE => new OCIExpressionBuilder($this->connection, $this, $this->logger),
+            IDBConnection::PLATFORM_POSTGRES => new PgSqlExpressionBuilder($this->connection, $this, $this->logger),
+            IDBConnection::PLATFORM_MARIADB,
+            IDBConnection::PLATFORM_MYSQL => new MySqlExpressionBuilder($this->connection, $this, $this->logger),
+            IDBConnection::PLATFORM_SQLITE => new SqliteExpressionBuilder($this->connection, $this, $this->logger),
+        };
+    }
+
+    /**
+     * Gets an FunctionBuilder used for object-oriented construction of query functions.
+     * This producer method is intended for convenient inline usage. Example:
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u')
+     *         ->from('users', 'u')
+     *         ->where($qb->fun()->md5('u.id'));
+     * </code>
+     *
+     * For more complex function construction, consider storing the function
+     * builder object in a local variable.
+     *
+     * @return \OCP\DB\QueryBuilder\IFunctionBuilder
+     */
+    public function func() {
+        return match($this->connection->getDatabaseProvider()) {
+            IDBConnection::PLATFORM_ORACLE => new OCIFunctionBuilder($this->connection, $this, $this->helper),
+            IDBConnection::PLATFORM_POSTGRES => new PgSqlFunctionBuilder($this->connection, $this, $this->helper),
+            IDBConnection::PLATFORM_MARIADB,
+            IDBConnection::PLATFORM_MYSQL => new FunctionBuilder($this->connection, $this, $this->helper),
+            IDBConnection::PLATFORM_SQLITE => new SqliteFunctionBuilder($this->connection, $this, $this->helper),
+        };
+    }
+
+    /**
+     * Gets the type of the currently built query.
+     *
+     * @return integer
+     */
+    public function getType() {
+        return $this->queryBuilder->getType();
+    }
+
+    /**
+     * Gets the associated DBAL Connection for this query builder.
+     *
+     * @return \OCP\IDBConnection
+     */
+    public function getConnection() {
+        return $this->connection;
+    }
+
+    /**
+     * Gets the state of this query builder instance.
+     *
+     * @return int Always returns 0 which is former `QueryBuilder::STATE_DIRTY`
+     * @deprecated 30.0.0 This function is going to be removed with the next Doctrine/DBAL update
+     *    and we can not fix this in our wrapper.
+     */
+    public function getState() {
+        $this->logger->debug(IQueryBuilder::class . '::' . __FUNCTION__ . ' is deprecated and will be removed soon.', ['exception' => new \Exception('Deprecated call to ' . __METHOD__)]);
+        return $this->queryBuilder->getState();
+    }
+
+    private function prepareForExecute() {
+        if ($this->systemConfig->getValue('log_query', false)) {
+            try {
+                $params = [];
+                foreach ($this->getParameters() as $placeholder => $value) {
+                    if ($value instanceof \DateTimeInterface) {
+                        $params[] = $placeholder . ' => DateTime:\'' . $value->format('c') . '\'';
+                    } elseif (is_array($value)) {
+                        $params[] = $placeholder . ' => (\'' . implode('\', \'', $value) . '\')';
+                    } else {
+                        $params[] = $placeholder . ' => \'' . $value . '\'';
+                    }
+                }
+                if (empty($params)) {
+                    $this->logger->debug('DB QueryBuilder: \'{query}\'', [
+                        'query' => $this->getSQL(),
+                        'app' => 'core',
+                    ]);
+                } else {
+                    $this->logger->debug('DB QueryBuilder: \'{query}\' with parameters: {params}', [
+                        'query' => $this->getSQL(),
+                        'params' => implode(', ', $params),
+                        'app' => 'core',
+                    ]);
+                }
+            } catch (\Error $e) {
+                // likely an error during conversion of $value to string
+                $this->logger->error('DB QueryBuilder: error trying to log SQL query', ['exception' => $e]);
+            }
+        }
+
+        // if (!empty($this->getQueryPart('select'))) {
+        // $select = $this->getQueryPart('select');
+        // $hasSelectAll = array_filter($select, static function ($s) {
+        // return $s === '*';
+        // });
+        // $hasSelectSpecific = array_filter($select, static function ($s) {
+        // return $s !== '*';
+        // });
+
+        // if (empty($hasSelectAll) === empty($hasSelectSpecific)) {
+        // $exception = new QueryException('Query is selecting * and specific values in the same query. This is not supported in Oracle.');
+        // $this->logger->error($exception->getMessage(), [
+        // 'query' => $this->getSQL(),
+        // 'app' => 'core',
+        // 'exception' => $exception,
+        // ]);
+        // }
+        // }
+
+        $tooLongOutputColumns = [];
+        foreach ($this->getOutputColumns() as $column) {
+            if (strlen($column) > 30) {
+                $tooLongOutputColumns[] = $column;
+            }
+        }
+
+        if (!empty($tooLongOutputColumns)) {
+            $exception = new QueryException('More than 30 characters for an output column name are not allowed on Oracle.');
+            $this->logger->error($exception->getMessage(), [
+                'query' => $this->getSQL(),
+                'columns' => $tooLongOutputColumns,
+                'app' => 'core',
+                'exception' => $exception,
+            ]);
+        }
+
+        $numberOfParameters = 0;
+        $hasTooLargeArrayParameter = false;
+        foreach ($this->getParameters() as $parameter) {
+            if (is_array($parameter)) {
+                $count = count($parameter);
+                $numberOfParameters += $count;
+                $hasTooLargeArrayParameter = $hasTooLargeArrayParameter || ($count > 1000);
+            }
+        }
+
+        if ($hasTooLargeArrayParameter) {
+            $exception = new QueryException('More than 1000 expressions in a list are not allowed on Oracle.');
+            $this->logger->error($exception->getMessage(), [
+                'query' => $this->getSQL(),
+                'app' => 'core',
+                'exception' => $exception,
+            ]);
+        }
+
+        if ($numberOfParameters > 65535) {
+            $exception = new QueryException('The number of parameters must not exceed 65535. Restriction by PostgreSQL.');
+            $this->logger->error($exception->getMessage(), [
+                'query' => $this->getSQL(),
+                'app' => 'core',
+                'exception' => $exception,
+            ]);
+        }
+    }
+
+    /**
+     * Executes this query using the bound parameters and their types.
+     *
+     * Uses {@see Connection::executeQuery} for select statements and {@see Connection::executeUpdate}
+     * for insert, update and delete statements.
+     *
+     * @return IResult|int
+     */
+    public function execute(?IDBConnection $connection = null) {
+        try {
+            if ($this->getType() === \Doctrine\DBAL\Query\QueryBuilder::SELECT) {
+                return $this->executeQuery($connection);
+            } else {
+                return $this->executeStatement($connection);
+            }
+        } catch (DBALException $e) {
+            // `IQueryBuilder->execute` never wrapped the exception, but `executeQuery` and `executeStatement` do
+            /** @var \Doctrine\DBAL\Exception $previous */
+            $previous = $e->getPrevious();
+
+            throw $previous;
+        }
+    }
+
+    public function executeQuery(?IDBConnection $connection = null): IResult {
+        if ($this->getType() !== \Doctrine\DBAL\Query\QueryBuilder::SELECT) {
+            throw new \RuntimeException('Invalid query type, expected SELECT query');
+        }
+
+        $this->prepareForExecute();
+        if (!$connection) {
+            $connection = $this->connection;
+        }
+
+        return $connection->executeQuery(
+            $this->getSQL(),
+            $this->getParameters(),
+            $this->getParameterTypes(),
+        );
+    }
+
+    public function executeStatement(?IDBConnection $connection = null): int {
+        if ($this->getType() === \Doctrine\DBAL\Query\QueryBuilder::SELECT) {
+            throw new \RuntimeException('Invalid query type, expected INSERT, DELETE or UPDATE statement');
+        }
+
+        $this->prepareForExecute();
+        if (!$connection) {
+            $connection = $this->connection;
+        }
+
+        return $connection->executeStatement(
+            $this->getSQL(),
+            $this->getParameters(),
+            $this->getParameterTypes(),
+        );
+    }
+
+
+    /**
+     * Gets the complete SQL string formed by the current specifications of this QueryBuilder.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u')
+     *         ->from('User', 'u')
+     *     echo $qb->getSQL(); // SELECT u FROM User u
+     * </code>
+     *
+     * @return string The SQL query string.
+     */
+    public function getSQL() {
+        return $this->queryBuilder->getSQL();
+    }
+
+    /**
+     * Sets a query parameter for the query being constructed.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u')
+     *         ->from('users', 'u')
+     *         ->where('u.id = :user_id')
+     *         ->setParameter(':user_id', 1);
+     * </code>
+     *
+     * @param string|integer $key The parameter position or name.
+     * @param mixed $value The parameter value.
+     * @param string|null|int $type One of the IQueryBuilder::PARAM_* constants.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function setParameter($key, $value, $type = null) {
+        $this->queryBuilder->setParameter($key, $value, $type);
+
+        return $this;
+    }
+
+    /**
+     * Sets a collection of query parameters for the query being constructed.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u')
+     *         ->from('users', 'u')
+     *         ->where('u.id = :user_id1 OR u.id = :user_id2')
+     *         ->setParameters(array(
+     *             ':user_id1' => 1,
+     *             ':user_id2' => 2
+     *         ));
+     * </code>
+     *
+     * @param array $params The query parameters to set.
+     * @param array $types The query parameters types to set.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function setParameters(array $params, array $types = []) {
+        $this->queryBuilder->setParameters($params, $types);
+
+        return $this;
+    }
+
+    /**
+     * Gets all defined query parameters for the query being constructed indexed by parameter index or name.
+     *
+     * @return array The currently defined query parameters indexed by parameter index or name.
+     */
+    public function getParameters() {
+        return $this->queryBuilder->getParameters();
+    }
+
+    /**
+     * Gets a (previously set) query parameter of the query being constructed.
+     *
+     * @param mixed $key The key (index or name) of the bound parameter.
+     *
+     * @return mixed The value of the bound parameter.
+     */
+    public function getParameter($key) {
+        return $this->queryBuilder->getParameter($key);
+    }
+
+    /**
+     * Gets all defined query parameter types for the query being constructed indexed by parameter index or name.
+     *
+     * @return array The currently defined query parameter types indexed by parameter index or name.
+     */
+    public function getParameterTypes() {
+        return $this->queryBuilder->getParameterTypes();
+    }
+
+    /**
+     * Gets a (previously set) query parameter type of the query being constructed.
+     *
+     * @param mixed $key The key (index or name) of the bound parameter type.
+     *
+     * @return mixed The value of the bound parameter type.
+     */
+    public function getParameterType($key) {
+        return $this->queryBuilder->getParameterType($key);
+    }
+
+    /**
+     * Sets the position of the first result to retrieve (the "offset").
+     *
+     * @param int $firstResult The first result to return.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function setFirstResult($firstResult) {
+        $this->queryBuilder->setFirstResult((int)$firstResult);
+
+        return $this;
+    }
+
+    /**
+     * Gets the position of the first result the query object was set to retrieve (the "offset").
+     * Returns 0 if {@link setFirstResult} was not applied to this QueryBuilder.
+     *
+     * @return int The position of the first result.
+     */
+    public function getFirstResult() {
+        return $this->queryBuilder->getFirstResult();
+    }
+
+    /**
+     * Sets the maximum number of results to retrieve (the "limit").
+     *
+     * NOTE: Setting max results to "0" will cause mixed behaviour. While most
+     * of the databases will just return an empty result set, Oracle will return
+     * all entries.
+     *
+     * @param int|null $maxResults The maximum number of results to retrieve.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function setMaxResults($maxResults) {
+        if ($maxResults === null) {
+            $this->queryBuilder->setMaxResults($maxResults);
+        } else {
+            $this->queryBuilder->setMaxResults((int)$maxResults);
+        }
+
+        return $this;
+    }
+
+    /**
+     * Gets the maximum number of results the query object was set to retrieve (the "limit").
+     * Returns NULL if {@link setMaxResults} was not applied to this query builder.
+     *
+     * @return int|null The maximum number of results.
+     */
+    public function getMaxResults() {
+        return $this->queryBuilder->getMaxResults();
+    }
+
+    /**
+     * Specifies an item that is to be returned in the query result.
+     * Replaces any previously specified selections, if any.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u.id', 'p.id')
+     *         ->from('users', 'u')
+     *         ->leftJoin('u', 'phonenumbers', 'p', 'u.id = p.user_id');
+     * </code>
+     *
+     * @param mixed ...$selects The selection expressions.
+     *
+     * '@return $this This QueryBuilder instance.
+     */
+    public function select(...$selects) {
+        if (count($selects) === 1 && is_array($selects[0])) {
+            $selects = $selects[0];
+        }
+        $this->addOutputColumns($selects);
+
+        $this->queryBuilder->select(
+            $this->helper->quoteColumnNames($selects)
+        );
+
+        return $this;
+    }
+
+    /**
+     * Specifies an item that is to be returned with a different name in the query result.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->selectAlias('u.id', 'user_id')
+     *         ->from('users', 'u')
+     *         ->leftJoin('u', 'phonenumbers', 'p', 'u.id = p.user_id');
+     * </code>
+     *
+     * @param mixed $select The selection expressions.
+     * @param string $alias The column alias used in the constructed query.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function selectAlias($select, $alias) {
+        $this->queryBuilder->addSelect(
+            $this->helper->quoteColumnName($select) . ' AS ' . $this->helper->quoteColumnName($alias)
+        );
+        $this->addOutputColumns([$alias]);
+
+        return $this;
+    }
+
+    /**
+     * Specifies an item that is to be returned uniquely in the query result.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->selectDistinct('type')
+     *         ->from('users');
+     * </code>
+     *
+     * @param mixed $select The selection expressions.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function selectDistinct($select) {
+        if (!is_array($select)) {
+            $select = [$select];
+        }
+        $this->addOutputColumns($select);
+
+        $quotedSelect = $this->helper->quoteColumnNames($select);
+
+        $this->queryBuilder->addSelect(
+            'DISTINCT ' . implode(', ', $quotedSelect)
+        );
+
+        return $this;
+    }
+
+    /**
+     * Adds an item that is to be returned in the query result.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u.id')
+     *         ->addSelect('p.id')
+     *         ->from('users', 'u')
+     *         ->leftJoin('u', 'phonenumbers', 'u.id = p.user_id');
+     * </code>
+     *
+     * @param mixed ...$selects The selection expression.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function addSelect(...$selects) {
+        if (count($selects) === 1 && is_array($selects[0])) {
+            $selects = $selects[0];
+        }
+        $this->addOutputColumns($selects);
+
+        $this->queryBuilder->addSelect(
+            $this->helper->quoteColumnNames($selects)
+        );
+
+        return $this;
+    }
+
+    private function addOutputColumns(array $columns): void {
+        foreach ($columns as $column) {
+            if (is_array($column)) {
+                $this->addOutputColumns($column);
+            } elseif (is_string($column) && !str_contains($column, '*')) {
+                if (str_contains(strtolower($column), ' as ')) {
+                    [, $column] = preg_split('/ as /i', $column);
+                }
+                if (str_contains($column, '.')) {
+                    [, $column] = explode('.', $column);
+                }
+                $this->selectedColumns[] = $column;
+            }
+        }
+    }
+
+    public function getOutputColumns(): array {
+        return array_unique($this->selectedColumns);
+    }
+
+    /**
+     * Turns the query being built into a bulk delete query that ranges over
+     * a certain table.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->delete('users', 'u')
+     *         ->where('u.id = :user_id');
+     *         ->setParameter(':user_id', 1);
+     * </code>
+     *
+     * @param string $delete The table whose rows are subject to the deletion.
+     * @param string $alias The table alias used in the constructed query.
+     *
+     * @return $this This QueryBuilder instance.
+     * @since 30.0.0 Alias is deprecated and will no longer be used with the next Doctrine/DBAL update
+     */
+    public function delete($delete = null, $alias = null) {
+        if ($alias !== null) {
+            $this->logger->debug('DELETE queries with alias are no longer supported and the provided alias is ignored', ['exception' => new \InvalidArgumentException('Table alias provided for DELETE query')]);
+        }
+
+        $this->queryBuilder->delete(
+            $this->getTableName($delete),
+            $alias
+        );
+
+        return $this;
+    }
+
+    /**
+     * Turns the query being built into a bulk update query that ranges over
+     * a certain table
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->update('users', 'u')
+     *         ->set('u.password', md5('password'))
+     *         ->where('u.id = ?');
+     * </code>
+     *
+     * @param string $update The table whose rows are subject to the update.
+     * @param string $alias The table alias used in the constructed query.
+     *
+     * @return $this This QueryBuilder instance.
+     * @since 30.0.0 Alias is deprecated and will no longer be used with the next Doctrine/DBAL update
+     */
+    public function update($update = null, $alias = null) {
+        if ($alias !== null) {
+            $this->logger->debug('UPDATE queries with alias are no longer supported and the provided alias is ignored', ['exception' => new \InvalidArgumentException('Table alias provided for UPDATE query')]);
+        }
+
+        $this->queryBuilder->update(
+            $this->getTableName($update),
+            $alias
+        );
+
+        return $this;
+    }
+
+    /**
+     * Turns the query being built into an insert query that inserts into
+     * a certain table
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->insert('users')
+     *         ->values(
+     *             array(
+     *                 'name' => '?',
+     *                 'password' => '?'
+     *             )
+     *         );
+     * </code>
+     *
+     * @param string $insert The table into which the rows should be inserted.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function insert($insert = null) {
+        $this->queryBuilder->insert(
+            $this->getTableName($insert)
+        );
+
+        $this->lastInsertedTable = $insert;
+
+        return $this;
+    }
+
+    /**
+     * Creates and adds a query root corresponding to the table identified by the
+     * given alias, forming a cartesian product with any existing query roots.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u.id')
+     *         ->from('users', 'u')
+     * </code>
+     *
+     * @param string|IQueryFunction $from The table.
+     * @param string|null $alias The alias of the table.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function from($from, $alias = null) {
+        $this->queryBuilder->from(
+            $this->getTableName($from),
+            $this->quoteAlias($alias)
+        );
+
+        return $this;
+    }
+
+    /**
+     * Creates and adds a join to the query.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u.name')
+     *         ->from('users', 'u')
+     *         ->join('u', 'phonenumbers', 'p', 'p.is_primary = 1');
+     * </code>
+     *
+     * @param string $fromAlias The alias that points to a from clause.
+     * @param string $join The table name to join.
+     * @param string $alias The alias of the join table.
+     * @param string|ICompositeExpression|null $condition The condition for the join.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function join($fromAlias, $join, $alias, $condition = null) {
+        $this->queryBuilder->join(
+            $this->quoteAlias($fromAlias),
+            $this->getTableName($join),
+            $this->quoteAlias($alias),
+            $condition
+        );
+
+        return $this;
+    }
+
+    /**
+     * Creates and adds a join to the query.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u.name')
+     *         ->from('users', 'u')
+     *         ->innerJoin('u', 'phonenumbers', 'p', 'p.is_primary = 1');
+     * </code>
+     *
+     * @param string $fromAlias The alias that points to a from clause.
+     * @param string $join The table name to join.
+     * @param string $alias The alias of the join table.
+     * @param string|ICompositeExpression|null $condition The condition for the join.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function innerJoin($fromAlias, $join, $alias, $condition = null) {
+        $this->queryBuilder->innerJoin(
+            $this->quoteAlias($fromAlias),
+            $this->getTableName($join),
+            $this->quoteAlias($alias),
+            $condition
+        );
+
+        return $this;
+    }
+
+    /**
+     * Creates and adds a left join to the query.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u.name')
+     *         ->from('users', 'u')
+     *         ->leftJoin('u', 'phonenumbers', 'p', 'p.is_primary = 1');
+     * </code>
+     *
+     * @param string $fromAlias The alias that points to a from clause.
+     * @param string|IQueryFunction $join The table name or sub-query to join.
+     * @param string $alias The alias of the join table.
+     * @param string|ICompositeExpression|null $condition The condition for the join.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function leftJoin($fromAlias, $join, $alias, $condition = null) {
+        $this->queryBuilder->leftJoin(
+            $this->quoteAlias($fromAlias),
+            $this->getTableName($join),
+            $this->quoteAlias($alias),
+            $condition
+        );
+
+        return $this;
+    }
+
+    /**
+     * Creates and adds a right join to the query.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u.name')
+     *         ->from('users', 'u')
+     *         ->rightJoin('u', 'phonenumbers', 'p', 'p.is_primary = 1');
+     * </code>
+     *
+     * @param string $fromAlias The alias that points to a from clause.
+     * @param string $join The table name to join.
+     * @param string $alias The alias of the join table.
+     * @param string|ICompositeExpression|null $condition The condition for the join.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function rightJoin($fromAlias, $join, $alias, $condition = null) {
+        $this->queryBuilder->rightJoin(
+            $this->quoteAlias($fromAlias),
+            $this->getTableName($join),
+            $this->quoteAlias($alias),
+            $condition
+        );
+
+        return $this;
+    }
+
+    /**
+     * Sets a new value for a column in a bulk update query.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->update('users', 'u')
+     *         ->set('u.password', md5('password'))
+     *         ->where('u.id = ?');
+     * </code>
+     *
+     * @param string $key The column to set.
+     * @param ILiteral|IParameter|IQueryFunction|string $value The value, expression, placeholder, etc.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function set($key, $value) {
+        $this->queryBuilder->set(
+            $this->helper->quoteColumnName($key),
+            $this->helper->quoteColumnName($value)
+        );
+
+        return $this;
+    }
+
+    /**
+     * Specifies one or more restrictions to the query result.
+     * Replaces any previously specified restrictions, if any.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u.name')
+     *         ->from('users', 'u')
+     *         ->where('u.id = ?');
+     *
+     *     // You can optionally programmatically build and/or expressions
+     *     $qb = $conn->getQueryBuilder();
+     *
+     *     $or = $qb->expr()->orx(
+     *         $qb->expr()->eq('u.id', 1),
+     *         $qb->expr()->eq('u.id', 2),
+     *     );
+     *
+     *     $qb->update('users', 'u')
+     *         ->set('u.password', md5('password'))
+     *         ->where($or);
+     * </code>
+     *
+     * @param mixed ...$predicates The restriction predicates.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function where(...$predicates) {
+        if ($this->nonEmptyWhere && $this->systemConfig->getValue('debug', false)) {
+            // Only logging a warning, not throwing for now.
+            $e = new QueryException('Using where() on non-empty WHERE part, please verify it is intentional to not call andWhere() or orWhere() instead. Otherwise consider creating a new query builder object or call resetQueryPart(\'where\') first.');
+            $this->logger->warning($e->getMessage(), ['exception' => $e]);
+        }
+
+        $this->nonEmptyWhere = true;
+
+        call_user_func_array(
+            [$this->queryBuilder, 'where'],
+            $predicates
+        );
+
+        return $this;
+    }
+
+    /**
+     * Adds one or more restrictions to the query results, forming a logical
+     * conjunction with any previously specified restrictions.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u')
+     *         ->from('users', 'u')
+     *         ->where('u.username LIKE ?')
+     *         ->andWhere('u.is_active = 1');
+     * </code>
+     *
+     * @param mixed ...$where The query restrictions.
+     *
+     * @return $this This QueryBuilder instance.
+     *
+     * @see where()
+     */
+    public function andWhere(...$where) {
+        $this->nonEmptyWhere = true;
+        call_user_func_array(
+            [$this->queryBuilder, 'andWhere'],
+            $where
+        );
+
+        return $this;
+    }
+
+    /**
+     * Adds one or more restrictions to the query results, forming a logical
+     * disjunction with any previously specified restrictions.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u.name')
+     *         ->from('users', 'u')
+     *         ->where('u.id = 1')
+     *         ->orWhere('u.id = 2');
+     * </code>
+     *
+     * @param mixed ...$where The WHERE statement.
+     *
+     * @return $this This QueryBuilder instance.
+     *
+     * @see where()
+     */
+    public function orWhere(...$where) {
+        $this->nonEmptyWhere = true;
+        call_user_func_array(
+            [$this->queryBuilder, 'orWhere'],
+            $where
+        );
+
+        return $this;
+    }
+
+    /**
+     * Specifies a grouping over the results of the query.
+     * Replaces any previously specified groupings, if any.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u.name')
+     *         ->from('users', 'u')
+     *         ->groupBy('u.id');
+     * </code>
+     *
+     * @param mixed ...$groupBys The grouping expression.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function groupBy(...$groupBys) {
+        if (count($groupBys) === 1 && is_array($groupBys[0])) {
+            $groupBys = $groupBys[0];
+        }
+
+        call_user_func_array(
+            [$this->queryBuilder, 'groupBy'],
+            $this->helper->quoteColumnNames($groupBys)
+        );
+
+        return $this;
+    }
+
+    /**
+     * Adds a grouping expression to the query.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->select('u.name')
+     *         ->from('users', 'u')
+     *         ->groupBy('u.lastLogin');
+     *         ->addGroupBy('u.createdAt')
+     * </code>
+     *
+     * @param mixed ...$groupBy The grouping expression.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function addGroupBy(...$groupBy) {
+        call_user_func_array(
+            [$this->queryBuilder, 'addGroupBy'],
+            $this->helper->quoteColumnNames($groupBy)
+        );
+
+        return $this;
+    }
+
+    /**
+     * Sets a value for a column in an insert query.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->insert('users')
+     *         ->values(
+     *             array(
+     *                 'name' => '?'
+     *             )
+     *         )
+     *         ->setValue('password', '?');
+     * </code>
+     *
+     * @param string $column The column into which the value should be inserted.
+     * @param IParameter|string $value The value that should be inserted into the column.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function setValue($column, $value) {
+        $this->queryBuilder->setValue(
+            $this->helper->quoteColumnName($column),
+            (string)$value
+        );
+
+        return $this;
+    }
+
+    /**
+     * Specifies values for an insert query indexed by column names.
+     * Replaces any previous values, if any.
+     *
+     * <code>
+     *     $qb = $conn->getQueryBuilder()
+     *         ->insert('users')
+     *         ->values(
+     *             array(
+     *                 'name' => '?',
+     *                 'password' => '?'
+     *             )
+     *         );
+     * </code>
+     *
+     * @param array $values The values to specify for the insert query indexed by column names.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function values(array $values) {
+        $quotedValues = [];
+        foreach ($values as $key => $value) {
+            $quotedValues[$this->helper->quoteColumnName($key)] = $value;
+        }
+
+        $this->queryBuilder->values($quotedValues);
+
+        return $this;
+    }
+
+    /**
+     * Specifies a restriction over the groups of the query.
+     * Replaces any previous having restrictions, if any.
+     *
+     * @param mixed ...$having The restriction over the groups.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function having(...$having) {
+        call_user_func_array(
+            [$this->queryBuilder, 'having'],
+            $having
+        );
+
+        return $this;
+    }
+
+    /**
+     * Adds a restriction over the groups of the query, forming a logical
+     * conjunction with any existing having restrictions.
+     *
+     * @param mixed ...$having The restriction to append.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function andHaving(...$having) {
+        call_user_func_array(
+            [$this->queryBuilder, 'andHaving'],
+            $having
+        );
+
+        return $this;
+    }
+
+    /**
+     * Adds a restriction over the groups of the query, forming a logical
+     * disjunction with any existing having restrictions.
+     *
+     * @param mixed ...$having The restriction to add.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function orHaving(...$having) {
+        call_user_func_array(
+            [$this->queryBuilder, 'orHaving'],
+            $having
+        );
+
+        return $this;
+    }
+
+    /**
+     * Specifies an ordering for the query results.
+     * Replaces any previously specified orderings, if any.
+     *
+     * @param string|IQueryFunction|ILiteral|IParameter $sort The ordering expression.
+     * @param string $order The ordering direction.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function orderBy($sort, $order = null) {
+        $this->queryBuilder->orderBy(
+            $this->helper->quoteColumnName($sort),
+            $order
+        );
+
+        return $this;
+    }
+
+    /**
+     * Adds an ordering to the query results.
+     *
+     * @param string|ILiteral|IParameter|IQueryFunction $sort The ordering expression.
+     * @param string $order The ordering direction.
+     *
+     * @return $this This QueryBuilder instance.
+     */
+    public function addOrderBy($sort, $order = null) {
+        $this->queryBuilder->addOrderBy(
+            $this->helper->quoteColumnName($sort),
+            $order
+        );
+
+        return $this;
+    }
+
+    /**
+     * Gets a query part by its name.
+     *
+     * @param string $queryPartName
+     *
+     * @return mixed
+     * @deprecated 30.0.0 This function is going to be removed with the next Doctrine/DBAL update
+     *   and we can not fix this in our wrapper. Please track the details you need, outside the object.
+     */
+    public function getQueryPart($queryPartName) {
+        $this->logger->debug(IQueryBuilder::class . '::' . __FUNCTION__ . ' is deprecated and will be removed soon.', ['exception' => new \Exception('Deprecated call to ' . __METHOD__)]);
+        return $this->queryBuilder->getQueryPart($queryPartName);
+    }
+
+    /**
+     * Gets all query parts.
+     *
+     * @return array
+     * @deprecated 30.0.0 This function is going to be removed with the next Doctrine/DBAL update
+     *   and we can not fix this in our wrapper. Please track the details you need, outside the object.
+     */
+    public function getQueryParts() {
+        $this->logger->debug(IQueryBuilder::class . '::' . __FUNCTION__ . ' is deprecated and will be removed soon.', ['exception' => new \Exception('Deprecated call to ' . __METHOD__)]);
+        return $this->queryBuilder->getQueryParts();
+    }
+
+    /**
+     * Resets SQL parts.
+     *
+     * @param array|null $queryPartNames
+     *
+     * @return $this This QueryBuilder instance.
+     * @deprecated 30.0.0 This function is going to be removed with the next Doctrine/DBAL update
+     *  and we can not fix this in our wrapper. Please create a new IQueryBuilder instead.
+     */
+    public function resetQueryParts($queryPartNames = null) {
+        $this->logger->debug(IQueryBuilder::class . '::' . __FUNCTION__ . ' is deprecated and will be removed soon.', ['exception' => new \Exception('Deprecated call to ' . __METHOD__)]);
+        $this->queryBuilder->resetQueryParts($queryPartNames);
+
+        return $this;
+    }
+
+    /**
+     * Resets a single SQL part.
+     *
+     * @param string $queryPartName
+     *
+     * @return $this This QueryBuilder instance.
+     * @deprecated 30.0.0 This function is going to be removed with the next Doctrine/DBAL update
+     *  and we can not fix this in our wrapper. Please create a new IQueryBuilder instead.
+     */
+    public function resetQueryPart($queryPartName) {
+        $this->logger->debug(IQueryBuilder::class . '::' . __FUNCTION__ . ' is deprecated and will be removed soon.', ['exception' => new \Exception('Deprecated call to ' . __METHOD__)]);
+        $this->queryBuilder->resetQueryPart($queryPartName);
+
+        return $this;
+    }
+
+    /**
+     * Creates a new named parameter and bind the value $value to it.
+     *
+     * This method provides a shortcut for PDOStatement::bindValue
+     * when using prepared statements.
+     *
+     * The parameter $value specifies the value that you want to bind. If
+     * $placeholder is not provided bindValue() will automatically create a
+     * placeholder for you. An automatic placeholder will be of the name
+     * ':dcValue1', ':dcValue2' etc.
+     *
+     * For more information see {@link https://www.php.net/pdostatement-bindparam}
+     *
+     * Example:
+     * <code>
+     * $value = 2;
+     * $q->eq( 'id', $q->bindValue( $value ) );
+     * $stmt = $q->executeQuery(); // executed with 'id = 2'
+     * </code>
+     *
+     * @license New BSD License
+     * @link http://www.zetacomponents.org
+     *
+     * @param mixed $value
+     * @param IQueryBuilder::PARAM_* $type
+     * @param string $placeHolder The name to bind with. The string must start with a colon ':'.
+     *
+     * @return IParameter the placeholder name used.
+     */
+    public function createNamedParameter($value, $type = IQueryBuilder::PARAM_STR, $placeHolder = null) {
+        return new Parameter($this->queryBuilder->createNamedParameter($value, $type, $placeHolder));
+    }
+
+    /**
+     * Creates a new positional parameter and bind the given value to it.
+     *
+     * Attention: If you are using positional parameters with the query builder you have
+     * to be very careful to bind all parameters in the order they appear in the SQL
+     * statement , otherwise they get bound in the wrong order which can lead to serious
+     * bugs in your code.
+     *
+     * Example:
+     * <code>
+     *  $qb = $conn->getQueryBuilder();
+     *  $qb->select('u.*')
+     *     ->from('users', 'u')
+     *     ->where('u.username = ' . $qb->createPositionalParameter('Foo', IQueryBuilder::PARAM_STR))
+     *     ->orWhere('u.username = ' . $qb->createPositionalParameter('Bar', IQueryBuilder::PARAM_STR))
+     * </code>
+     *
+     * @param mixed $value
+     * @param IQueryBuilder::PARAM_* $type
+     *
+     * @return IParameter
+     */
+    public function createPositionalParameter($value, $type = IQueryBuilder::PARAM_STR) {
+        return new Parameter($this->queryBuilder->createPositionalParameter($value, $type));
+    }
+
+    /**
+     * Creates a new parameter
+     *
+     * Example:
+     * <code>
+     *  $qb = $conn->getQueryBuilder();
+     *  $qb->select('u.*')
+     *     ->from('users', 'u')
+     *     ->where('u.username = ' . $qb->createParameter('name'))
+     *     ->setParameter('name', 'Bar', IQueryBuilder::PARAM_STR))
+     * </code>
+     *
+     * @param string $name
+     *
+     * @return IParameter
+     */
+    public function createParameter($name) {
+        return new Parameter(':' . $name);
+    }
+
+    /**
+     * Creates a new function
+     *
+     * Attention: Column names inside the call have to be quoted before hand
+     *
+     * Example:
+     * <code>
+     *  $qb = $conn->getQueryBuilder();
+     *  $qb->select($qb->createFunction('COUNT(*)'))
+     *     ->from('users', 'u')
+     *  echo $qb->getSQL(); // SELECT COUNT(*) FROM `users` u
+     * </code>
+     * <code>
+     *  $qb = $conn->getQueryBuilder();
+     *  $qb->select($qb->createFunction('COUNT(`column`)'))
+     *     ->from('users', 'u')
+     *  echo $qb->getSQL(); // SELECT COUNT(`column`) FROM `users` u
+     * </code>
+     *
+     * @param string $call
+     *
+     * @return IQueryFunction
+     */
+    public function createFunction($call) {
+        return new QueryFunction($call);
+    }
+
+    /**
+     * Used to get the id of the last inserted element
+     * @return int
+     * @throws \BadMethodCallException When being called before an insert query has been run.
+     */
+    public function getLastInsertId(): int {
+        if ($this->getType() === \Doctrine\DBAL\Query\QueryBuilder::INSERT && $this->lastInsertedTable) {
+            // lastInsertId() needs the prefix but no quotes
+            $table = $this->prefixTableName($this->lastInsertedTable);
+            return $this->connection->lastInsertId($table);
+        }
+
+        throw new \BadMethodCallException('Invalid call to getLastInsertId without using insert() before.');
+    }
+
+    /**
+     * Returns the table name quoted and with database prefix as needed by the implementation
+     *
+     * @param string|IQueryFunction $table
+     * @return string
+     */
+    public function getTableName($table) {
+        if ($table instanceof IQueryFunction) {
+            return (string)$table;
+        }
+
+        $table = $this->prefixTableName($table);
+        return $this->helper->quoteColumnName($table);
+    }
+
+    /**
+     * Returns the table name with database prefix as needed by the implementation
+     *
+     * Was protected until version 30.
+     *
+     * @param string $table
+     * @return string
+     */
+    public function prefixTableName(string $table): string {
+        if ($this->automaticTablePrefix === false || str_starts_with($table, '*PREFIX*')) {
+            return $table;
+        }
+
+        return '*PREFIX*' . $table;
+    }
+
+    /**
+     * Returns the column name quoted and with table alias prefix as needed by the implementation
+     *
+     * @param string $column
+     * @param string $tableAlias
+     * @return string
+     */
+    public function getColumnName($column, $tableAlias = '') {
+        if ($tableAlias !== '') {
+            $tableAlias .= '.';
+        }
+
+        return $this->helper->quoteColumnName($tableAlias . $column);
+    }
+
+    /**
+     * Returns the column name quoted and with table alias prefix as needed by the implementation
+     *
+     * @param string $alias
+     * @return string
+     */
+    public function quoteAlias($alias) {
+        if ($alias === '' || $alias === null) {
+            return $alias;
+        }
+
+        return $this->helper->quoteColumnName($alias);
+    }
+
+    public function escapeLikeParameter(string $parameter): string {
+        return $this->connection->escapeLikeParameter($parameter);
+    }
+
+    public function hintShardKey(string $column, mixed $value, bool $overwrite = false): self {
+        return $this;
+    }
+
+    public function runAcrossAllShards(): self {
+        // noop
+        return $this;
+    }
 
 }