libraries/classes/Controllers/Server/BinlogController.php

   1 <?php
   2
   3 declare(strict_types=1);
   4
   5 namespace PhpMyAdmin\Controllers\Server;
   6
   7 use PhpMyAdmin\Common;
   8 use PhpMyAdmin\Controllers\AbstractController;
   9 use PhpMyAdmin\DatabaseInterface;
  10 use PhpMyAdmin\Html\Generator;
  11 use PhpMyAdmin\Message;
  12 use PhpMyAdmin\Response;
  13 use PhpMyAdmin\Template;
  14 use PhpMyAdmin\Util;
  15 use function array_key_exists;
  16
  17 /**
  18  * Handles viewing binary logs
  19  */
  20 class BinlogController extends AbstractController
  21 {
  22     /**
  23      * binary log files
  24      *
  25      * @var array
  26      */
  27     protected $binaryLogs;
  28
  29     /** @var DatabaseInterface */
  30     private $dbi;
  31
  32     /**
  33      * @param Response          $response
  34      * @param DatabaseInterface $dbi
  35      */
  36     public function __construct($response, Template $template, $dbi)
  37     {
  38         parent::__construct($response, $template);
  39         $this->dbi = $dbi;
  40
  41         $this->binaryLogs = $this->dbi->fetchResult(
  42             'SHOW MASTER LOGS',
  43             'Log_name',
  44             null,
  45             DatabaseInterface::CONNECT_USER,
  46             DatabaseInterface::QUERY_STORE
  47         );
  48     }
  49
  50     public function index(): void
  51     {
  52         global $cfg, $PMA_Theme;
  53
  54         $params = [
  55             'log' => $_POST['log'] ?? null,
  56             'pos' => $_POST['pos'] ?? null,
  57             'is_full_query' => $_POST['is_full_query'] ?? null,
  58         ];
  59
  60         Common::server();
  61
  62         $position = ! empty($params['pos']) ? (int) $params['pos'] : 0;
  63
  64         $urlParams = [];
  65         if (isset($params['log'])
  66             && array_key_exists($params['log'], $this->binaryLogs)
  67         ) {
  68             $urlParams['log'] = $params['log'];
  69         }
  70
  71         $isFullQuery = false;
  72         if (! empty($params['is_full_query'])) {
  73             $isFullQuery = true;
  74             $urlParams['is_full_query'] = 1;
  75         }
  76
  77         $sqlQuery = $this->getSqlQuery(
  78             $params['log'] ?? '',
  79             $position,
  80             (int) $cfg['MaxRows']
  81         );
  82         $result = $this->dbi->query($sqlQuery);
  83
  84         $numRows = 0;
  85         if (isset($result) && $result) {
  86             $numRows = $this->dbi->numRows($result);
  87         }
  88
  89         $previousParams = $urlParams;
  90         $fullQueriesParams = $urlParams;
  91         $nextParams = $urlParams;
  92         if ($position > 0) {
  93             $fullQueriesParams['pos'] = $position;
  94             if ($position > $cfg['MaxRows']) {
  95                 $previousParams['pos'] = $position - $cfg['MaxRows'];
  96             }
  97         }
  98         $fullQueriesParams['is_full_query'] = 1;
  99         if ($isFullQuery) {
 100             unset($fullQueriesParams['is_full_query']);
 101         }
 102         if ($numRows >= $cfg['MaxRows']) {
 103             $nextParams['pos'] = $position + $cfg['MaxRows'];
 104         }
 105
 106         $values = [];
 107         while ($value = $this->dbi->fetchAssoc($result)) {
 108             $values[] = $value;
 109         }
 110
 111         $this->render('server/binlog/index', [
 112             'url_params' => $urlParams,
 113             'binary_logs' => $this->binaryLogs,
 114             'log' => $params['log'],
 115             'sql_message' => Generator::getMessage(Message::success(), $sqlQuery),
 116             'values' => $values,
 117             'has_previous' => $position > 0,
 118             'has_next' => $numRows >= $cfg['MaxRows'],
 119             'previous_params' => $previousParams,
 120             'full_queries_params' => $fullQueriesParams,
 121             'next_params' => $nextParams,
 122             'has_icons' => Util::showIcons('TableNavigationLinksMode'),
 123             'is_full_query' => $isFullQuery,
 124             'image_path' => $PMA_Theme->getImgPath(),
 125         ]);
 126     }
 127
 128     /**
 129      * @param string $log      Binary log file name
 130      * @param int    $position Position to display
 131      * @param int    $maxRows  Maximum number of rows
 132      */
 133     private function getSqlQuery(
 134         string $log,
 135         int $position,
 136         int $maxRows
 137     ): string {
 138         $sqlQuery = 'SHOW BINLOG EVENTS';
 139         if (! empty($log)) {
 140             $sqlQuery .= ' IN \'' . $log . '\'';
 141         }
 142         $sqlQuery .= ' LIMIT ' . $position . ', ' . $maxRows;
 143
 144         return $sqlQuery;
 145     }
 146 }