2.3.0

- внедряем репозиторий таблиц в Connection.
- репозиторий таблиц создается на этапе `Config`.
- к классу `Config` добавлены методы-хелперы `initTables`, `addTable`, `getTable`
- после коннекта репозиторий таблиц доступен через публичное поле `tables`
- после коннекта таблицы доступны через `$pdo->tables[key]` или `$pdo->tables->getTable(key)`

Author: karelwintersky

interfaces/Database/ConfigInterface.php

@@ -8,6 +8,45 @@ interface ConfigInterface
 {
     public function __construct(array $connection_config = [], ?LoggerInterface $logger = null);
 
+    /**
+     * Инициализирует репозиторий таблиц
+     *
+     * @param string $prefix
+     * @param array $tables
+     * @param array $havePrefix
+     * @param array $haveAlias
+     * @return self
+     */
+    public function initTables(string $prefix = '',
+                               array $tables = [],
+                               array $havePrefix = [],
+                               array $haveAlias = []): self;
+
+    /**
+     * Добавляет таблицу в репозиторий. Хелпер.
+     *
+     * @param string $key
+     * @param string|null $tableName
+     * @param string|null $replacement
+     * @param bool $withPrefix
+     * @param string|null $alias
+     * @return self
+     */
+    public function addTable(string $key,
+                             ?string $tableName = null,
+                             ?string $replacement = null,
+                             bool $withPrefix = false,
+                             ?string $alias = null):self;
+
+    /**
+     * Возвращает таблицу по ключу с учетом всех правил
+     * Если ключ не указан - вернет все таблицы
+     *
+     * @param $key
+     * @return string|array
+     */
+    public function getTable($key = null):string|array;
+
     public function setDriver(?string $driver):self;
     public function setHost(string $host = 'localhost'):self;
     public function setPort(mixed $port): self;

interfaces/Database/TablesInterface.php

@@ -19,4 +19,6 @@ public function addTable(
         ?string $alias = null
     ): Tables;
 
+    public function getTable(?string $key = null):array|string;
+
 }

sources/Database/Config.php

@@ -32,6 +32,8 @@ class Config implements ConfigInterface
     public ?float $slowQueryThreshold = 1.0; // ms
     public bool $collectBacktrace = true;
 
+    public Tables $tables;
+
     public function __construct(array $connection_config = [], ?LoggerInterface $logger = null)
     {
         $this->logger = $logger ?? new NullLogger();
@@ -54,6 +56,32 @@ public function __construct(array $connection_config = [], ?LoggerInterface $log
         } else {
             $this->charset = self::DEFAULT_CHARSET;
         }
+
+        $this->tables = new Tables();
+    }
+
+    public function initTables(string $prefix = '',
+                               array $tables = [],
+                               array $havePrefix = [],
+                               array $haveAlias = []): self
+    {
+        $this->tables = new Tables($prefix, $tables, $havePrefix, $haveAlias);
+        return $this;
+    }
+
+    public function addTable(string $key,
+                             ?string $tableName = null,
+                             ?string $replacement = null,
+                             bool $withPrefix = false,
+                             ?string $alias = null):self
+    {
+        $this->tables->addTable($key, $tableName, $replacement, $withPrefix, $alias);
+        return $this;
+    }
+
+    public function getTable($key = null):string|array
+    {
+        return $this->tables->getTable($key);
     }
 
     public function setDriver(?string $driver):self

sources/Database/Connector.php

@@ -12,6 +12,7 @@ class Connector extends PDO implements ConnectorInterface
     private ?PDO $pdo_connector = null;
     private ?Config $config;
     private ?Stats $stats;
+    public  Tables $tables;
 
     private string $dsn;
     private ?string $username;
@@ -29,6 +30,7 @@ public function __construct(
         $this->password = $config->getPassword();
         $this->options = $config->getOptions() ?? [];
         $this->stats = new Stats($config);
+        $this->tables = $config->tables;
     }
 
     /**
@@ -90,7 +92,7 @@ private function initConnection(): void
      * Check real connection
      * @return void
      */
-    private function ensureConnection()
+    private function ensureConnection(): void
     {
         if (empty($this->pdo_connector)) {
             $this->initConnection();

sources/Database/Tables.php

@@ -76,14 +76,33 @@ public function addTable(
             $this->haveAlias[$key] = $alias;
         }
 
-        return $this; // Для цепочечных вызовов
+        return $this;
     }
 
-    //
+    /**
+     * Возвращает список таблиц (в репозитории) с учетом правил замен
+     * Или одну таблицу по ключу.
+     *
+     * @param string|null $key
+     * @return array|string
+     */
+    public function getTable(?string $key = null):array|string
+    {
+        if (is_null($key)) {
+            $tables = [];
+            foreach ($this->tables as $key => $v) {
+                $tables[] = $this->offsetGet($key);
+            }
+
+            return $tables;
+        }
+
+        return $this->offsetGet($key);
+    }
 
     /**
      * Проверяет, существует ли ключ
-     * (таблица в репозитории)     *
+     * (таблица в репозитории)
      *
      * @param mixed $offset
      * @return bool
@@ -111,9 +130,8 @@ public function offsetGet(mixed $offset): string
         // Если аргумент есть в таблице замен - подставляем значение из have_prefix
         if (isset($this->havePrefix[$offset])) {
             $result = $this->havePrefix[$offset];
-        }
-        // Иначе если есть в таблице have_prefix - ставим префикс
-        elseif (in_array($offset, $this->havePrefix, true)) {
+        } elseif (in_array($offset, $this->havePrefix, true)) {
+            // Иначе если есть в таблице have_prefix - ставим префикс
             $result = $this->prefix . $tableName;
         }
         // Иначе ставим значение ключа (уже в $tableName)