Make ClickHouseSchemaManager use DB name from params instead of default

Author: Yevhen Chornohradskyi

src/ClickHouseSchemaManager.php

@@ -17,9 +17,9 @@
 use Doctrine\DBAL\Schema\AbstractSchemaManager;
 use Doctrine\DBAL\Schema\Column;
 use Doctrine\DBAL\Schema\Index;
+use Doctrine\DBAL\Schema\Schema;
 use Doctrine\DBAL\Schema\View;
 use Doctrine\DBAL\Types\Type;
-use const CASE_LOWER;
 use function array_change_key_case;
 use function array_filter;
 use function array_key_exists;
@@ -35,6 +35,7 @@
 use function strpos;
 use function strtolower;
 use function trim;
+use const CASE_LOWER;
 
 /**
  * Schema manager for the ClickHouse DBMS.
@@ -59,10 +60,26 @@ protected function _getPortableViewDefinition($view)
         return new View($view['name'], $statement);
     }
 
+    /**
+     * Returns a list of all tables in the current database.
+     *
+     * @return string[]
+     */
+    public function listTableNames()
+    {
+        $database = ($this->_conn->getParams()['stick_to_default'] ?? false) ? $this->_conn->getDatabase() : null;
+        $sql = $this->_platform->getListTablesSQL($database);
+
+        $tables = $this->_conn->fetchAll($sql);
+        $tableNames = $this->_getPortableTablesList($tables);
+
+        return $this->filterAssetNames($tableNames);
+    }
+
     /**
      * {@inheritdoc}
      */
-    public function listTableIndexes($table) : array
+    public function listTableIndexes($table): array
     {
         $tableView = $this->_getPortableViewDefinition(['name' => $table]);
 
@@ -96,33 +113,33 @@ function (string $column) {
     /**
      * {@inheritdoc}
      */
-    protected function _getPortableTableColumnDefinition($tableColumn) : Column
+    protected function _getPortableTableColumnDefinition($tableColumn): Column
     {
         $tableColumn = array_change_key_case($tableColumn, CASE_LOWER);
 
-        $dbType  = $columnType = trim($tableColumn['type']);
-        $length  = null;
-        $fixed   = false;
+        $dbType = $columnType = trim($tableColumn['type']);
+        $length = null;
+        $fixed = false;
         $notnull = true;
 
         if (preg_match('/(Nullable\((\w+)\))/i', $columnType, $matches)) {
             $columnType = str_replace($matches[1], $matches[2], $columnType);
-            $notnull    = false;
+            $notnull = false;
         }
 
         if (stripos($columnType, 'fixedstring') === 0) {
             // get length from FixedString definition
             $length = preg_replace('~.*\(([0-9]*)\).*~', '$1', $columnType);
             $dbType = 'fixedstring';
-            $fixed  = true;
+            $fixed = true;
         }
 
         $unsigned = false;
         if (stripos($columnType, 'uint') === 0) {
             $unsigned = true;
         }
 
-        if (! isset($tableColumn['name'])) {
+        if (!isset($tableColumn['name'])) {
             $tableColumn['name'] = '';
         }
 
@@ -133,14 +150,14 @@ protected function _getPortableTableColumnDefinition($tableColumn) : Column
         }
 
         $options = [
-            'length' => $length,
-            'notnull' => $notnull,
-            'default' => $default,
-            'primary' => false,
-            'fixed' => $fixed,
-            'unsigned' => $unsigned,
+            'length'        => $length,
+            'notnull'       => $notnull,
+            'default'       => $default,
+            'primary'       => false,
+            'fixed'         => $fixed,
+            'unsigned'      => $unsigned,
             'autoincrement' => false,
-            'comment' => null,
+            'comment'       => null,
         ];
 
         return new Column(