Bdf\Prime\Connection\Factory\ShardingConnectionFactory

Complexity

Total Complexity

4

Size/Duplication

Total Lines	48
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	create()	0	18	2
A	__construct()	0	3	1
A	support()	0	3	1

<?php

namespace Bdf\Prime\Connection\Factory;

use Bdf\Prime\Connection\ConnectionInterface;
use Bdf\Prime\Sharding\ShardingConnection;
use Doctrine\DBAL\Configuration;

/**
 * ShardingConnection
 */
class ShardingConnectionFactory implements ConnectionFactoryInterface
{
    /**
     * The delegated loader
     *
     * @var ConnectionFactoryInterface
     */
    private $connectionFactory;

Expected 1 blank line(s) before first member var; 0 found

    /**
     * Set default configuration
     *
     * @param ConnectionFactoryInterface $connectionFactory
     */
    public function __construct(ConnectionFactoryInterface $connectionFactory)
    {
        $this->connectionFactory = $connectionFactory;
    }

    /**

Parameter $connectionName should have a doc-comment as per coding-style.

Parameter $parameters should have a doc-comment as per coding-style.

Parameter $config should have a doc-comment as per coding-style.

     * {@inheritDoc}
     */
    public function create(string $connectionName, array $parameters, Configuration $config): ConnectionInterface
    {
        $allParameters = $parameters['shards'];
        unset($parameters['shards']);

        $globalParameters = $parameters;
        unset($globalParameters['wrapperClass']);
        unset($globalParameters['distributionKey']);
        unset($globalParameters['shardChoser']);

        $parameters['shard_connections'] = [];
        foreach ($allParameters as $shardId => $shardParameters) {
            $parameters['shard_connections'][$shardId] = $this->connectionFactory->create($connectionName.'.'.$shardId, array_merge($globalParameters, $shardParameters), $config);
        }

        $parameters['wrapperClass'] = $parameters['wrapperClass'] ?? ShardingConnection::class;

Operation must be bracketed

        return $this->connectionFactory->create($connectionName, $parameters, $config);
    }

    /**

Parameter $connectionName should have a doc-comment as per coding-style.

Parameter $parameters should have a doc-comment as per coding-style.

     * {@inheritDoc}
     */
    public function support(string $connectionName, array $parameters): bool

The method parameter $connectionName is never used

    {
        return isset($parameters['shards']);
    }
}