fix(DB): do not assume sharding is always enabled

Signed-off-by: Arthur Schiwon <blizzz@arthur-schiwon.de>

Author: blizzz

lib/private/DB/Connection.php

@@ -91,6 +91,7 @@ class Connection extends PrimaryReadReplicaConnection {
 	protected array $shards = [];
 	protected ShardConnectionManager $shardConnectionManager;
 	protected AutoIncrementHandler $autoIncrementHandler;
+	protected bool $isShardingEnabled;
 
 	public const SHARD_PRESETS = [
 		'filecache' => [
@@ -130,14 +131,17 @@ public function __construct(
 		parent::__construct($params, $driver, $config, $eventManager);
 		$this->adapter = new $params['adapter']($this);
 		$this->tablePrefix = $params['tablePrefix'];
-
-		/** @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->isShardingEnabled = isset($this->params['dbsharding']) && !empty($this->params['dbsharding']);
+
+		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);
@@ -157,7 +161,7 @@ public function __construct(
 		}
 
 		/** @var array<string, array{shards: array[], mapper: ?string}> $shardConfig */
-		$shardConfig = $this->params['sharding'] ?? [];
+		$shardConfig = $this->params['dbsharding'] ?? [];
 		$shardNames = array_keys($shardConfig);
 		$this->shards = array_map(function (array $config, string $name) {
 			if (!isset(self::SHARD_PRESETS[$name])) {
@@ -192,10 +196,12 @@ public function __construct(
 	 */
 	public function getShardConnections(): array {
 		$connections = [];
-		foreach ($this->shards as $shardDefinition) {
-			foreach ($shardDefinition->getAllShards() as $shard) {
-				/** @var ConnectionAdapter $connection */
-				$connections[] = $this->shardConnectionManager->getConnection($shardDefinition, $shard);
+		if ($this->isShardingEnabled) {
+			foreach ($this->shards as $shardDefinition) {
+				foreach ($shardDefinition->getAllShards() as $shard) {
+					/** @var ConnectionAdapter $connection */
+					$connections[] = $this->shardConnectionManager->getConnection($shardDefinition, $shard);
+				}
 			}
 		}
 		return $connections;
@@ -255,7 +261,7 @@ public function getQueryBuilder(): IQueryBuilder {
 			$this->systemConfig,
 			$this->logger
 		);
-		if (count($this->partitions) > 0) {
+		if ($this->isShardingEnabled && count($this->partitions) > 0) {
 			$builder = new PartitionedQueryBuilder(
 				$builder,
 				$this->shards,