Sharding.php

Go to the documentation of this file.

<?php
namespace Magento\Framework\Setup\Declaration\Schema;

use Magento\Framework\App\DeploymentConfig;
use Magento\Framework\Config\ConfigOptionsListConstants;

class Sharding
{
    const DEFAULT_CONNECTION = 'default';

    private $deploymentConfig;

    private $resources;

    public function __construct(DeploymentConfig $deploymentConfig, array $resources)
    {
        $this->deploymentConfig = $deploymentConfig;
        $this->resources = $resources;
    }

    public function getResources()
    {
        $resources = [];

        foreach ($this->resources as $resource) {
            if ($this->canUseResource($resource)) {
                $resources[] = $resource;
            }
        }

        return $resources;
    }

    public function canUseResource($scopeName)
    {
        $connections = $this->deploymentConfig
            ->get(ConfigOptionsListConstants::CONFIG_PATH_DB_CONNECTIONS);
        return isset($connections[$scopeName]);
    }

    public function getDefaultResource()
    {
        return self::DEFAULT_CONNECTION;
    }
}