Implement getValuesForCsvTable

Signed-off-by: Liviu-Mihail Concioiu <[email protected]>

src/Controllers/Database/StructureController.php

@@ -697,6 +697,13 @@ private function getStuffForEngineTypeTable(
                     $sumSize,
                 );
                 break;
+            case 'CSV':
+                [$currentTable, $formattedSize, $unit, $sumSize] = $this->getValuesForCsvTable(
+                    $currentTable,
+                    $sumSize,
+                );
+                break;
+
             // Mysql 5.0.x (and lower) uses MRG_MyISAM
             // and MySQL 5.1.x (and higher) uses MRG_MYISAM
             // Both are aliases for MERGE
@@ -835,6 +842,74 @@ private function getValuesForInnodbTable(
         return [$currentTable, $formattedSize, $unit, $sumSize];
     }
 
+    /**
+     * Get values for CSV table
+     *
+     * https://bugs.mysql.com/bug.php?id=53929
+     *
+     * @param mixed[] $currentTable current table
+     * @param int     $sumSize      sum size
+     *
+     * @return mixed[]
+     */
+    private function getValuesForCsvTable(
+        array $currentTable,
+        int $sumSize,
+    ): array {
+        $formattedSize = $unit = '';
+
+        if (
+            (in_array($currentTable['ENGINE'], ['CSV'], true)
+            && $currentTable['TABLE_ROWS'] < Config::getInstance()->settings['MaxExactCount'])
+            || ! isset($currentTable['TABLE_ROWS'])
+        ) {
+            $currentTable['COUNTED'] = true;
+            $currentTable['TABLE_ROWS'] = $this->dbi
+                ->getTable(Current::$database, $currentTable['TABLE_NAME'])
+                ->countRecords(true);
+        } else {
+            $currentTable['COUNTED'] = false;
+        }
+
+        if ($this->isShowStats) {
+            // Only count columns that have double quotes
+            $columnCount = (int) $this->dbi->fetchValue(
+                'SELECT COUNT(COLUMN_NAME) FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA = '
+                . $this->dbi->quoteString(Current::$database) . ' AND TABLE_NAME = '
+                . $this->dbi->quoteString($currentTable['TABLE_NAME']) . ' AND NUMERIC_SCALE IS NULL;'
+            );
+
+            // Get column names
+            $columnNames = $this->dbi->fetchValue(
+                'SELECT GROUP_CONCAT(COLUMN_NAME) FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA = '
+                . $this->dbi->quoteString(Current::$database) . ' AND TABLE_NAME = '
+                . $this->dbi->quoteString($currentTable['TABLE_NAME']) . ';'
+            );
+
+            // 10Mb buffer for CONCAT_WS
+            // not sure if is needed
+            $this->dbi->query('SET SESSION group_concat_max_len = 10 * 1024 * 1024');
+
+            // Calculate data length
+            $dataLength = (int) $this->dbi->fetchValue('
+                SELECT SUM(CHAR_LENGTH(REPLACE(REPLACE(REPLACE(
+                    CONCAT_WS(\',\', ' . $columnNames . '),
+                    UNHEX(\'0A\'), \'nn\'), UNHEX(\'22\'), \'nn\'), UNHEX(\'5C\'), \'nn\'
+                ))) FROM ' . Util::backquote(Current::$database) . '.' . Util::backquote($currentTable['TABLE_NAME']));
+
+            // Calculate quotes length
+            $quotesLength = $currentTable['TABLE_ROWS'] * $columnCount * 2;
+
+            /** @var int $tblsize */
+            $tblsize = $dataLength + $quotesLength + $currentTable['TABLE_ROWS'];
+
+            $sumSize += $tblsize;
+            [$formattedSize, $unit] = Util::formatByteDown($tblsize, 3, $tblsize > 0 ? 1 : 0);
+        }
+
+        return [$currentTable, $formattedSize, $unit, $sumSize];
+    }
+
     /**
      * Get values for Mroonga table
      *