Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory : /home/corals/old/vendor/magento/framework/App/ |
<?php
/**
* Copyright © Magento, Inc. All rights reserved.
* See COPYING.txt for license details.
*/
declare(strict_types=1);
namespace Magento\Framework\App;
use Magento\Framework\App\ResourceConnection\ConfigInterface as ResourceConfigInterface;
use Magento\Framework\Config\ConfigOptionsListConstants;
use Magento\Framework\Model\ResourceModel\Type\Db\ConnectionFactoryInterface;
/**
* Application provides ability to configure multiple connections to persistent storage.
*
* This class provides access to all these connections.
*
* @api
* @since 100.0.2
*/
class ResourceConnection
{
public const AUTO_UPDATE_ONCE = 0;
public const AUTO_UPDATE_NEVER = -1;
public const AUTO_UPDATE_ALWAYS = 1;
public const DEFAULT_CONNECTION = 'default';
/**
* Instances of actual connections.
*
* @var \Magento\Framework\DB\Adapter\AdapterInterface[]
*/
protected $connections = [];
/**
* Mapped tables cache array.
*
* @var array
*/
protected $mappedTableNames;
/**
* Resource config.
*
* @var ResourceConfigInterface
*/
protected $config;
/**
* Resource connection adapter factory.
*
* @var ConnectionFactoryInterface
*/
protected $connectionFactory;
/**
* @var DeploymentConfig
*/
private $deploymentConfig;
/**
* @var string
*/
protected $tablePrefix;
/**
* @param ResourceConfigInterface $resourceConfig
* @param ConnectionFactoryInterface $connectionFactory
* @param DeploymentConfig $deploymentConfig
* @param string $tablePrefix
*/
public function __construct(
ResourceConfigInterface $resourceConfig,
ConnectionFactoryInterface $connectionFactory,
DeploymentConfig $deploymentConfig,
$tablePrefix = ''
) {
$this->config = $resourceConfig;
$this->connectionFactory = $connectionFactory;
$this->deploymentConfig = $deploymentConfig;
$this->tablePrefix = $tablePrefix ?: null;
}
/**
* Retrieve connection to resource specified by $resourceName.
*
* @param string $resourceName
* @return \Magento\Framework\DB\Adapter\AdapterInterface
* @throws \DomainException
* @codeCoverageIgnore
*/
public function getConnection($resourceName = self::DEFAULT_CONNECTION)
{
$connectionName = $this->config->getConnectionName($resourceName);
return $this->getConnectionByName($connectionName);
}
/**
* Close connection.
*
* @param string $resourceName
* @return void
* @since 100.1.3
*/
public function closeConnection($resourceName = self::DEFAULT_CONNECTION)
{
if ($resourceName === null) {
foreach ($this->connections as $processConnection) {
if ($processConnection !== null) {
$processConnection->closeConnection();
}
}
$this->connections = [];
} else {
$processConnectionName = $this->getProcessConnectionName($this->config->getConnectionName($resourceName));
if (isset($this->connections[$processConnectionName])) {
if ($this->connections[$processConnectionName] !== null) {
$this->connections[$processConnectionName]->closeConnection();
}
$this->connections[$processConnectionName] = null;
}
}
}
/**
* Retrieve connection by $connectionName.
*
* @param string $connectionName
* @return \Magento\Framework\DB\Adapter\AdapterInterface
* @throws \DomainException
*/
public function getConnectionByName($connectionName)
{
$processConnectionName = $this->getProcessConnectionName($connectionName);
if (isset($this->connections[$processConnectionName])) {
return $this->connections[$processConnectionName];
}
$connectionConfig = $this->deploymentConfig->get(
ConfigOptionsListConstants::CONFIG_PATH_DB_CONNECTIONS . '/' . $connectionName
);
if ($connectionConfig) {
$connection = $this->connectionFactory->create($connectionConfig);
} else {
throw new \DomainException('Connection "' . $connectionName . '" is not defined');
}
$this->connections[$processConnectionName] = $connection;
return $connection;
}
/**
* Get conneciton name for process.
*
* @param string $connectionName
* @return string
*/
private function getProcessConnectionName($connectionName)
{
return $connectionName . '_process_' . getmypid();
}
/**
* Get resource table name, validated by db adapter.
*
* @param string|string[] $modelEntity
* @param string $connectionName
* @return string
*/
public function getTableName($modelEntity, $connectionName = self::DEFAULT_CONNECTION)
{
$tableSuffix = null;
if (is_array($modelEntity)) {
list($modelEntity, $tableSuffix) = $modelEntity;
}
$tableName = (string)$modelEntity;
$mappedTableName = $this->getMappedTableName($tableName);
if ($mappedTableName) {
$tableName = $mappedTableName;
} else {
$tablePrefix = $this->getTablePrefix();
if ($tablePrefix && strpos($tableName, $tablePrefix) !== 0) {
$tableName = $tablePrefix . $tableName;
}
}
if ($tableSuffix) {
$tableName .= '_' . $tableSuffix;
}
return $this->getConnection($connectionName)->getTableName($tableName);
}
/**
* Gets table placeholder by table name.
*
* @param string $tableName
* @return string
* @since 100.1.0
*/
public function getTablePlaceholder($tableName)
{
$tableName = preg_replace('/^' . preg_quote($this->getTablePrefix()) . '_/', '', $tableName);
return $tableName;
}
/**
* Build a trigger name.
*
* @param string $tableName The table that is the subject of the trigger
* @param string $time Either "before" or "after"
* @param string $event The DB level event which activates the trigger, i.e. "update" or "insert"
* @return string
*/
public function getTriggerName($tableName, $time, $event)
{
return $this->getConnection()->getTriggerName($tableName, $time, $event);
}
/**
* Set mapped table name.
*
* @param string $tableName
* @param string $mappedName
* @return $this
* @codeCoverageIgnore
*/
public function setMappedTableName($tableName, $mappedName)
{
$this->mappedTableNames[$tableName] = $mappedName;
return $this;
}
/**
* Get mapped table name.
*
* @param string $tableName
* @return bool|string
*/
public function getMappedTableName($tableName)
{
if (isset($this->mappedTableNames[$tableName])) {
return $this->mappedTableNames[$tableName];
} else {
return false;
}
}
/**
* Retrieve 32bit UNIQUE HASH for a Table index.
*
* @param string $tableName
* @param string|string[] $fields
* @param string $indexType
* @return string
*/
public function getIdxName(
$tableName,
$fields,
$indexType = \Magento\Framework\DB\Adapter\AdapterInterface::INDEX_TYPE_INDEX
) {
return $this->getConnection()
->getIndexName(
$this->getTableName($tableName),
$fields,
$indexType
);
}
/**
* Retrieve 32bit UNIQUE HASH for a Table foreign key.
*
* @param string $priTableName the target table name
* @param string $priColumnName the target table column name
* @param string $refTableName the reference table name
* @param string $refColumnName the reference table column name
* @return string
*/
public function getFkName($priTableName, $priColumnName, $refTableName, $refColumnName)
{
return $this->getConnection()->getForeignKeyName(
$this->getTableName($priTableName),
$priColumnName,
$this->getTableName($refTableName),
$refColumnName
);
}
/**
* Retrieve db name.
*
* That name can be needed, when we do request in information_schema to identify db.
*
* @param string $resourceName
* @return string
* @since 102.0.0
*/
public function getSchemaName($resourceName)
{
return $this->deploymentConfig->get(
ConfigOptionsListConstants::CONFIG_PATH_DB_CONNECTIONS . '/' . $resourceName . '/dbname'
);
}
/**
* Get table prefix.
*
* @return string
*/
public function getTablePrefix()
{
if ($this->tablePrefix !== null) {
return $this->tablePrefix;
}
return (string)$this->deploymentConfig->get(ConfigOptionsListConstants::CONFIG_PATH_DB_PREFIX);
}
}