libraries/classes/Controllers/Database/OperationsController.php

   1 <?php
   2
   3 declare(strict_types=1);
   4
   5 namespace PhpMyAdmin\Controllers\Database;
   6
   7 use PhpMyAdmin\Charsets;
   8 use PhpMyAdmin\CheckUserPrivileges;
   9 use PhpMyAdmin\ConfigStorage\Relation;
  10 use PhpMyAdmin\ConfigStorage\RelationCleanup;
  11 use PhpMyAdmin\Controllers\AbstractController;
  12 use PhpMyAdmin\DatabaseInterface;
  13 use PhpMyAdmin\Html\Generator;
  14 use PhpMyAdmin\Message;
  15 use PhpMyAdmin\Operations;
  16 use PhpMyAdmin\Plugins;
  17 use PhpMyAdmin\Query\Utilities;
  18 use PhpMyAdmin\ResponseRenderer;
  19 use PhpMyAdmin\Template;
  20 use PhpMyAdmin\Url;
  21 use PhpMyAdmin\Util;
  22
  23 use function __;
  24 use function count;
  25 use function mb_strtolower;
  26 use function strlen;
  27
  28 /**
  29  * Handles miscellaneous database operations.
  30  */
  31 class OperationsController extends AbstractController
  32 {
  33     /** @var Operations */
  34     private $operations;
  35
  36     /** @var CheckUserPrivileges */
  37     private $checkUserPrivileges;
  38
  39     /** @var Relation */
  40     private $relation;
  41
  42     /** @var RelationCleanup */
  43     private $relationCleanup;
  44
  45     /** @var DatabaseInterface */
  46     private $dbi;
  47
  48     public function __construct(
  49         ResponseRenderer $response,
  50         Template $template,
  51         Operations $operations,
  52         CheckUserPrivileges $checkUserPrivileges,
  53         Relation $relation,
  54         RelationCleanup $relationCleanup,
  55         DatabaseInterface $dbi
  56     ) {
  57         parent::__construct($response, $template);
  58         $this->operations = $operations;
  59         $this->checkUserPrivileges = $checkUserPrivileges;
  60         $this->relation = $relation;
  61         $this->relationCleanup = $relationCleanup;
  62         $this->dbi = $dbi;
  63     }
  64
  65     public function __invoke(): void
  66     {
  67         $this->checkUserPrivileges->getPrivileges();
  68
  69         $this->addScriptFiles(['database/operations.js']);
  70
  71         $GLOBALS['sql_query'] = '';
  72
  73         /**
  74          * Rename/move or copy database
  75          */
  76         if (strlen($GLOBALS['db']) > 0 && (! empty($_POST['db_rename']) || ! empty($_POST['db_copy']))) {
  77             if (! empty($_POST['db_rename'])) {
  78                 $GLOBALS['move'] = true;
  79             } else {
  80                 $GLOBALS['move'] = false;
  81             }
  82
  83             if (! isset($_POST['newname']) || strlen($_POST['newname']) === 0) {
  84                 $GLOBALS['message'] = Message::error(__('The database name is empty!'));
  85             } else {
  86                 // lower_case_table_names=1 `DB` becomes `db`
  87                 if ($this->dbi->getLowerCaseNames() === '1') {
  88                     $_POST['newname'] = mb_strtolower($_POST['newname']);
  89                 }
  90
  91                 if ($_POST['newname'] === $_REQUEST['db']) {
  92                     $GLOBALS['message'] = Message::error(
  93                         __('Cannot copy database to the same name. Change the name and try again.')
  94                     );
  95                 } else {
  96                     $_error = false;
  97                     if ($GLOBALS['move'] || ! empty($_POST['create_database_before_copying'])) {
  98                         $this->operations->createDbBeforeCopy();
  99                     }
 100
 101                     // here I don't use DELIMITER because it's not part of the
 102                     // language; I have to send each statement one by one
 103
 104                     // to avoid selecting alternatively the current and new db
 105                     // we would need to modify the CREATE definitions to qualify
 106                     // the db name
 107                     $this->operations->runProcedureAndFunctionDefinitions($GLOBALS['db']);
 108
 109                     // go back to current db, just in case
 110                     $this->dbi->selectDb($GLOBALS['db']);
 111
 112                     $GLOBALS['tables_full'] = $this->dbi->getTablesFull($GLOBALS['db']);
 113
 114                     // remove all foreign key constraints, otherwise we can get errors
 115                     $GLOBALS['export_sql_plugin'] = Plugins::getPlugin('export', 'sql', [
 116                         'export_type' => 'database',
 117                         'single_table' => isset($GLOBALS['single_table']),
 118                     ]);
 119
 120                     // create stand-in tables for views
 121                     $GLOBALS['views'] = $this->operations->getViewsAndCreateSqlViewStandIn(
 122                         $GLOBALS['tables_full'],
 123                         $GLOBALS['export_sql_plugin'],
 124                         $GLOBALS['db']
 125                     );
 126
 127                     // copy tables
 128                     $GLOBALS['sqlConstratints'] = $this->operations->copyTables(
 129                         $GLOBALS['tables_full'],
 130                         $GLOBALS['move'],
 131                         $GLOBALS['db']
 132                     );
 133
 134                     // handle the views
 135                     if (! $_error) {
 136                         $this->operations->handleTheViews($GLOBALS['views'], $GLOBALS['move'], $GLOBALS['db']);
 137                     }
 138
 139                     unset($GLOBALS['views']);
 140
 141                     // now that all tables exist, create all the accumulated constraints
 142                     if (! $_error && count($GLOBALS['sqlConstratints']) > 0) {
 143                         $this->operations->createAllAccumulatedConstraints($GLOBALS['sqlConstratints']);
 144                     }
 145
 146                     unset($GLOBALS['sqlConstratints']);
 147
 148                     if ($this->dbi->getVersion() >= 50100) {
 149                         // here DELIMITER is not used because it's not part of the
 150                         // language; each statement is sent one by one
 151
 152                         $this->operations->runEventDefinitionsForDb($GLOBALS['db']);
 153                     }
 154
 155                     // go back to current db, just in case
 156                     $this->dbi->selectDb($GLOBALS['db']);
 157
 158                     // Duplicate the bookmarks for this db (done once for each db)
 159                     $this->operations->duplicateBookmarks($_error, $GLOBALS['db']);
 160
 161                     if (! $_error && $GLOBALS['move']) {
 162                         if (isset($_POST['adjust_privileges']) && ! empty($_POST['adjust_privileges'])) {
 163                             $this->operations->adjustPrivilegesMoveDb($GLOBALS['db'], $_POST['newname']);
 164                         }
 165
 166                         /**
 167                          * cleanup pmadb stuff for this db
 168                          */
 169                         $this->relationCleanup->database($GLOBALS['db']);
 170
 171                         // if someday the RENAME DATABASE reappears, do not DROP
 172                         $GLOBALS['local_query'] = 'DROP DATABASE '
 173                             . Util::backquote($GLOBALS['db']) . ';';
 174                         $GLOBALS['sql_query'] .= "\n" . $GLOBALS['local_query'];
 175                         $this->dbi->query($GLOBALS['local_query']);
 176
 177                         $GLOBALS['message'] = Message::success(
 178                             __('Database %1$s has been renamed to %2$s.')
 179                         );
 180                         $GLOBALS['message']->addParam($GLOBALS['db']);
 181                         $GLOBALS['message']->addParam($_POST['newname']);
 182                     } elseif (! $_error) {
 183                         if (isset($_POST['adjust_privileges']) && ! empty($_POST['adjust_privileges'])) {
 184                             $this->operations->adjustPrivilegesCopyDb($GLOBALS['db'], $_POST['newname']);
 185                         }
 186
 187                         $GLOBALS['message'] = Message::success(
 188                             __('Database %1$s has been copied to %2$s.')
 189                         );
 190                         $GLOBALS['message']->addParam($GLOBALS['db']);
 191                         $GLOBALS['message']->addParam($_POST['newname']);
 192                     } else {
 193                         $GLOBALS['message'] = Message::error();
 194                     }
 195
 196                     $GLOBALS['reload'] = true;
 197
 198                     /* Change database to be used */
 199                     if (! $_error && $GLOBALS['move']) {
 200                         $GLOBALS['db'] = $_POST['newname'];
 201                     } elseif (! $_error) {
 202                         if (isset($_POST['switch_to_new']) && $_POST['switch_to_new'] === 'true') {
 203                             $_SESSION['pma_switch_to_new'] = true;
 204                             $GLOBALS['db'] = $_POST['newname'];
 205                         } else {
 206                             $_SESSION['pma_switch_to_new'] = false;
 207                         }
 208                     }
 209                 }
 210             }
 211
 212             /**
 213              * Database has been successfully renamed/moved.  If in an Ajax request,
 214              * generate the output with {@link ResponseRenderer} and exit
 215              */
 216             if ($this->response->isAjax()) {
 217                 $this->response->setRequestStatus($GLOBALS['message']->isSuccess());
 218                 $this->response->addJSON('message', $GLOBALS['message']);
 219                 $this->response->addJSON('newname', $_POST['newname']);
 220                 $this->response->addJSON(
 221                     'sql_query',
 222                     Generator::getMessage('', $GLOBALS['sql_query'])
 223                 );
 224                 $this->response->addJSON('db', $GLOBALS['db']);
 225
 226                 return;
 227             }
 228         }
 229
 230         $relationParameters = $this->relation->getRelationParameters();
 231
 232         /**
 233          * Check if comments were updated
 234          * (must be done before displaying the menu tabs)
 235          */
 236         if (isset($_POST['comment'])) {
 237             $this->relation->setDbComment($GLOBALS['db'], $_POST['comment']);
 238         }
 239
 240         Util::checkParameters(['db']);
 241
 242         $GLOBALS['errorUrl'] = Util::getScriptNameForOption($GLOBALS['cfg']['DefaultTabDatabase'], 'database');
 243         $GLOBALS['errorUrl'] .= Url::getCommon(['db' => $GLOBALS['db']], '&');
 244
 245         if (! $this->hasDatabase()) {
 246             return;
 247         }
 248
 249         $GLOBALS['urlParams']['goto'] = Url::getFromRoute('/database/operations');
 250
 251         // Gets the database structure
 252         $GLOBALS['sub_part'] = '_structure';
 253
 254         [
 255             $GLOBALS['tables'],
 256             $GLOBALS['num_tables'],
 257             $GLOBALS['total_num_tables'],
 258             $GLOBALS['sub_part'],,
 259             $isSystemSchema,
 260             $GLOBALS['tooltip_truename'],
 261             $GLOBALS['tooltip_aliasname'],
 262             $GLOBALS['pos'],
 263         ] = Util::getDbInfo($GLOBALS['db'], $GLOBALS['sub_part']);
 264
 265         $oldMessage = '';
 266         if (isset($GLOBALS['message'])) {
 267             $oldMessage = Generator::getMessage($GLOBALS['message'], $GLOBALS['sql_query']);
 268             unset($GLOBALS['message']);
 269         }
 270
 271         $GLOBALS['db_collation'] = $this->dbi->getDbCollation($GLOBALS['db']);
 272         $GLOBALS['is_information_schema'] = Utilities::isSystemSchema($GLOBALS['db']);
 273
 274         if ($GLOBALS['is_information_schema']) {
 275             return;
 276         }
 277
 278         $databaseComment = '';
 279         if ($relationParameters->columnCommentsFeature !== null) {
 280             $databaseComment = $this->relation->getDbComment($GLOBALS['db']);
 281         }
 282
 283         $hasAdjustPrivileges = $GLOBALS['db_priv'] && $GLOBALS['table_priv']
 284             && $GLOBALS['col_priv'] && $GLOBALS['proc_priv'] && $GLOBALS['is_reload_priv'];
 285
 286         $isDropDatabaseAllowed = ($this->dbi->isSuperUser() || $GLOBALS['cfg']['AllowUserDropDatabase'])
 287             && ! $isSystemSchema && $GLOBALS['db'] !== 'mysql';
 288
 289         $switchToNew = isset($_SESSION['pma_switch_to_new']) && $_SESSION['pma_switch_to_new'];
 290
 291         $charsets = Charsets::getCharsets($this->dbi, $GLOBALS['cfg']['Server']['DisableIS']);
 292         $collations = Charsets::getCollations($this->dbi, $GLOBALS['cfg']['Server']['DisableIS']);
 293
 294         if (! $relationParameters->hasAllFeatures() && $GLOBALS['cfg']['PmaNoRelation_DisableWarning'] == false) {
 295             $GLOBALS['message'] = Message::notice(
 296                 __(
 297                     'The phpMyAdmin configuration storage has been deactivated. %sFind out why%s.'
 298                 )
 299             );
 300             $GLOBALS['message']->addParamHtml(
 301                 '<a href="' . Url::getFromRoute('/check-relations')
 302                 . '" data-post="' . Url::getCommon(['db' => $GLOBALS['db']]) . '">'
 303             );
 304             $GLOBALS['message']->addParamHtml('</a>');
 305             /* Show error if user has configured something, notice elsewhere */
 306             if (! empty($GLOBALS['cfg']['Servers'][$GLOBALS['server']]['pmadb'])) {
 307                 $GLOBALS['message']->isError(true);
 308             }
 309         }
 310
 311         $this->render('database/operations/index', [
 312             'message' => $oldMessage,
 313             'db' => $GLOBALS['db'],
 314             'has_comment' => $relationParameters->columnCommentsFeature !== null,
 315             'db_comment' => $databaseComment,
 316             'db_collation' => $GLOBALS['db_collation'],
 317             'has_adjust_privileges' => $hasAdjustPrivileges,
 318             'is_drop_database_allowed' => $isDropDatabaseAllowed,
 319             'switch_to_new' => $switchToNew,
 320             'charsets' => $charsets,
 321             'collations' => $collations,
 322         ]);
 323     }
 324 }