src/Partitioning/Maintenance.php

   1 <?php
   2
   3 declare(strict_types=1);
   4
   5 namespace PhpMyAdmin\Partitioning;
   6
   7 use PhpMyAdmin\DatabaseInterface;
   8 use PhpMyAdmin\Identifiers\DatabaseName;
   9 use PhpMyAdmin\Identifiers\TableName;
  10 use PhpMyAdmin\Table\Table;
  11 use PhpMyAdmin\Util;
  12
  13 use function __;
  14 use function sprintf;
  15
  16 final class Maintenance
  17 {
  18     public function __construct(private DatabaseInterface $dbi)
  19     {
  20     }
  21
  22     /** @return mixed[] */
  23     public function analyze(DatabaseName $db, TableName $table, string $partition): array
  24     {
  25         $query = sprintf(
  26             'ALTER TABLE %s ANALYZE PARTITION %s;',
  27             Util::backquote($table->getName()),
  28             Util::backquote($partition),
  29         );
  30
  31         $this->dbi->selectDb($db);
  32         $result = $this->dbi->fetchResult($query);
  33
  34         $rows = [];
  35         foreach ($result as $row) {
  36             $rows[$row['Table']][] = $row;
  37         }
  38
  39         return [$rows, $query];
  40     }
  41
  42     /** @return mixed[] */
  43     public function check(DatabaseName $db, TableName $table, string $partition): array
  44     {
  45         $query = sprintf(
  46             'ALTER TABLE %s CHECK PARTITION %s;',
  47             Util::backquote($table->getName()),
  48             Util::backquote($partition),
  49         );
  50
  51         $this->dbi->selectDb($db);
  52         $result = $this->dbi->fetchResult($query);
  53
  54         $rows = [];
  55         foreach ($result as $row) {
  56             $rows[$row['Table']][] = $row;
  57         }
  58
  59         return [$rows, $query];
  60     }
  61
  62     /** @return mixed[] */
  63     public function drop(DatabaseName $db, TableName $table, string $partition): array
  64     {
  65         $query = sprintf(
  66             'ALTER TABLE %s DROP PARTITION %s;',
  67             Util::backquote($table->getName()),
  68             Util::backquote($partition),
  69         );
  70
  71         $this->dbi->selectDb($db);
  72         $result = $this->dbi->tryQuery($query);
  73
  74         return [(bool) $result, $query];
  75     }
  76
  77     /** @return mixed[] */
  78     public function optimize(DatabaseName $db, TableName $table, string $partition): array
  79     {
  80         $query = sprintf(
  81             'ALTER TABLE %s OPTIMIZE PARTITION %s;',
  82             Util::backquote($table->getName()),
  83             Util::backquote($partition),
  84         );
  85
  86         $this->dbi->selectDb($db);
  87         $result = $this->dbi->fetchResult($query);
  88
  89         $rows = [];
  90         foreach ($result as $row) {
  91             $rows[$row['Table']][] = $row;
  92         }
  93
  94         return [$rows, $query];
  95     }
  96
  97     /**
  98      * @return array<int, bool|string>
  99      * @psalm-return array{bool, string}
 100      */
 101     public function rebuild(DatabaseName $db, TableName $table, string $partition): array
 102     {
 103         $query = sprintf(
 104             'ALTER TABLE %s REBUILD PARTITION %s;',
 105             Util::backquote($table->getName()),
 106             Util::backquote($partition),
 107         );
 108
 109         $this->dbi->selectDb($db);
 110         $result = $this->dbi->tryQuery($query);
 111
 112         return [(bool) $result, $query];
 113     }
 114
 115     /** @return mixed[] */
 116     public function repair(DatabaseName $db, TableName $table, string $partition): array
 117     {
 118         $query = sprintf(
 119             'ALTER TABLE %s REPAIR PARTITION %s;',
 120             Util::backquote($table->getName()),
 121             Util::backquote($partition),
 122         );
 123
 124         $this->dbi->selectDb($db);
 125         $result = $this->dbi->fetchResult($query);
 126
 127         $rows = [];
 128         foreach ($result as $row) {
 129             $rows[$row['Table']][] = $row;
 130         }
 131
 132         return [$rows, $query];
 133     }
 134
 135     /**
 136      * @return array<int, bool|string>
 137      * @psalm-return array{bool, string}
 138      */
 139     public function truncate(DatabaseName $db, TableName $table, string $partition): array
 140     {
 141         if (Table::get($table->getName(), $db->getName(), $this->dbi)->isView()) {
 142             return [false, __('This table is a view, it can not be truncated.')];
 143         }
 144
 145         $query = sprintf(
 146             'ALTER TABLE %s TRUNCATE PARTITION %s;',
 147             Util::backquote($table->getName()),
 148             Util::backquote($partition),
 149         );
 150
 151         $this->dbi->selectDb($db);
 152         $result = $this->dbi->tryQuery($query);
 153
 154         return [(bool) $result, $query];
 155     }
 156 }