Config.php

Go to the documentation of this file.

<?php
namespace Magento\Framework\App\ResourceConnection;

use Magento\Framework\Config\ConfigOptionsListConstants;
use Magento\Framework\Serialize\SerializerInterface;

class Config extends \Magento\Framework\Config\Data\Scoped implements ConfigInterface
{
    protected $_connectionNames = [];

    private $deploymentConfig;

    private $initialized = false;

    public function __construct(
        Config\Reader $reader,
        \Magento\Framework\Config\ScopeInterface $configScope,
        \Magento\Framework\Config\CacheInterface $cache,
        \Magento\Framework\App\DeploymentConfig $deploymentConfig,
        $cacheId = 'resourcesCache',
        SerializerInterface $serializer = null
    ) {
        parent::__construct($reader, $configScope, $cache, $cacheId, $serializer);
        $this->deploymentConfig = $deploymentConfig;
    }

    public function getConnectionName($resourceName)
    {
        $this->initConnections();
        $connectionName = \Magento\Framework\App\ResourceConnection::DEFAULT_CONNECTION;
 
        if (!isset($this->_connectionNames[$resourceName])) {
            $resourcesConfig = $this->get();
            $pointerResourceName = $resourceName;
            while (true) {
                if (isset($resourcesConfig[$pointerResourceName]['connection'])) {
                    $connectionName = $resourcesConfig[$pointerResourceName]['connection'];
                    $this->_connectionNames[$resourceName] = $connectionName;
                    break;
                } elseif (isset($this->_connectionNames[$pointerResourceName])) {
                    $this->_connectionNames[$resourceName] = $this->_connectionNames[$pointerResourceName];
                    $connectionName = $this->_connectionNames[$resourceName];
                    break;
                } elseif (isset($resourcesConfig[$pointerResourceName]['extends'])) {
                    $pointerResourceName = $resourcesConfig[$pointerResourceName]['extends'];
                } else {
                    break;
                }
            }
        } else {
            $connectionName = $this->_connectionNames[$resourceName];
        }

        return $connectionName;
    }

    private function initConnections()
    {
        if (!$this->initialized) {
            $this->initialized = true;
            $resource = $this->deploymentConfig->getConfigData(ConfigOptionsListConstants::KEY_RESOURCE) ?: [];
            foreach ($resource as $resourceName => $resourceData) {
                if (!isset($resourceData['connection'])) {
                    throw new \InvalidArgumentException('Invalid initial resource configuration');
                }
                $this->_connectionNames[$resourceName] = $resourceData['connection'];
            }
        }
    }
}