Merge pull request #15759 from mauriciofauth/replication-include
Remove replication.inc.php file
This commit is contained in:
commit
2e2c20ac31
@ -18,6 +18,7 @@ use PhpMyAdmin\Message;
|
||||
use PhpMyAdmin\RecentFavoriteTable;
|
||||
use PhpMyAdmin\Relation;
|
||||
use PhpMyAdmin\Replication;
|
||||
use PhpMyAdmin\ReplicationInfo;
|
||||
use PhpMyAdmin\Response;
|
||||
use PhpMyAdmin\Sanitize;
|
||||
use PhpMyAdmin\Template;
|
||||
@ -149,7 +150,7 @@ class StructureController extends AbstractController
|
||||
Core::sendHeaderLocation($uri);
|
||||
}
|
||||
|
||||
include_once ROOT_PATH . 'libraries/replication.inc.php';
|
||||
ReplicationInfo::load();
|
||||
|
||||
PageSettings::showGroup('DbStructure');
|
||||
|
||||
|
||||
@ -16,6 +16,7 @@ use PhpMyAdmin\Controllers\AbstractController;
|
||||
use PhpMyAdmin\DatabaseInterface;
|
||||
use PhpMyAdmin\Html\Generator;
|
||||
use PhpMyAdmin\Message;
|
||||
use PhpMyAdmin\ReplicationInfo;
|
||||
use PhpMyAdmin\Response;
|
||||
use PhpMyAdmin\Template;
|
||||
use PhpMyAdmin\Url;
|
||||
@ -87,8 +88,8 @@ class DatabasesController extends AbstractController
|
||||
$scripts = $header->getScripts();
|
||||
$scripts->addFile('server/databases.js');
|
||||
|
||||
include_once ROOT_PATH . 'libraries/replication.inc.php';
|
||||
include_once ROOT_PATH . 'libraries/server_common.inc.php';
|
||||
ReplicationInfo::load();
|
||||
|
||||
$this->setSortDetails($params['sort_by'], $params['sort_order']);
|
||||
$this->hasStatistics = ! empty($params['statistics']);
|
||||
|
||||
@ -11,6 +11,7 @@ namespace PhpMyAdmin\Controllers\Server;
|
||||
use PhpMyAdmin\Controllers\AbstractController;
|
||||
use PhpMyAdmin\DatabaseInterface;
|
||||
use PhpMyAdmin\ReplicationGui;
|
||||
use PhpMyAdmin\ReplicationInfo;
|
||||
use PhpMyAdmin\Response;
|
||||
use PhpMyAdmin\Template;
|
||||
|
||||
@ -46,7 +47,7 @@ class ReplicationController extends AbstractController
|
||||
global $replication_info, $server_slave_replication, $url_params;
|
||||
|
||||
require_once ROOT_PATH . 'libraries/server_common.inc.php';
|
||||
require_once ROOT_PATH . 'libraries/replication.inc.php';
|
||||
ReplicationInfo::load();
|
||||
|
||||
$header = $this->response->getHeader();
|
||||
$scripts = $header->getScripts();
|
||||
|
||||
@ -15,33 +15,6 @@ namespace PhpMyAdmin;
|
||||
*/
|
||||
class Replication
|
||||
{
|
||||
/**
|
||||
* Fill global replication_info variable.
|
||||
*
|
||||
* @param string $type Type: master, slave
|
||||
* @param string $replicationInfoKey Key in replication_info variable
|
||||
* @param array $mysqlInfo MySQL data about replication
|
||||
* @param string $mysqlKey MySQL key
|
||||
*
|
||||
* @return array
|
||||
*/
|
||||
public function fillInfo(
|
||||
$type,
|
||||
$replicationInfoKey,
|
||||
array $mysqlInfo,
|
||||
$mysqlKey
|
||||
) {
|
||||
$GLOBALS['replication_info'][$type][$replicationInfoKey]
|
||||
= empty($mysqlInfo[$mysqlKey])
|
||||
? []
|
||||
: explode(
|
||||
',',
|
||||
$mysqlInfo[$mysqlKey]
|
||||
);
|
||||
|
||||
return $GLOBALS['replication_info'][$type][$replicationInfoKey];
|
||||
}
|
||||
|
||||
/**
|
||||
* Extracts database or table name from string
|
||||
*
|
||||
|
||||
230
libraries/classes/ReplicationInfo.php
Normal file
230
libraries/classes/ReplicationInfo.php
Normal file
@ -0,0 +1,230 @@
|
||||
<?php
|
||||
/**
|
||||
* @package PhpMyAdmin
|
||||
*/
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace PhpMyAdmin;
|
||||
|
||||
/**
|
||||
* @package PhpMyAdmin
|
||||
*/
|
||||
final class ReplicationInfo
|
||||
{
|
||||
/**
|
||||
* @return void
|
||||
*/
|
||||
public static function load(): void
|
||||
{
|
||||
global $dbi, $url_params;
|
||||
global $server_master_replication, $server_slave_replication, $server_slave_multi_replication;
|
||||
global $replication_types, $replication_info;
|
||||
global $master_variables, $slave_variables, $slave_variables_alerts, $slave_variables_oks;
|
||||
|
||||
/**
|
||||
* get master replication from server
|
||||
*/
|
||||
$server_master_replication = $dbi->fetchResult('SHOW MASTER STATUS');
|
||||
|
||||
/**
|
||||
* set selected master server
|
||||
*/
|
||||
if (! empty($_POST['master_connection'])) {
|
||||
/**
|
||||
* check for multi-master replication functionality
|
||||
*/
|
||||
$server_slave_multi_replication = $dbi->fetchResult(
|
||||
'SHOW ALL SLAVES STATUS'
|
||||
);
|
||||
if ($server_slave_multi_replication) {
|
||||
$dbi->query(
|
||||
"SET @@default_master_connection = '"
|
||||
. $dbi->escapeString(
|
||||
$_POST['master_connection']
|
||||
) . "'"
|
||||
);
|
||||
$url_params['master_connection'] = $_POST['master_connection'];
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* get slave replication from server
|
||||
*/
|
||||
$server_slave_replication = $dbi->fetchResult('SHOW SLAVE STATUS');
|
||||
|
||||
/**
|
||||
* replication types
|
||||
*/
|
||||
$replication_types = [
|
||||
'master',
|
||||
'slave',
|
||||
];
|
||||
|
||||
/**
|
||||
* define variables for master status
|
||||
*/
|
||||
$master_variables = [
|
||||
'File',
|
||||
'Position',
|
||||
'Binlog_Do_DB',
|
||||
'Binlog_Ignore_DB',
|
||||
];
|
||||
|
||||
/**
|
||||
* Define variables for slave status
|
||||
*/
|
||||
$slave_variables = [
|
||||
'Slave_IO_State',
|
||||
'Master_Host',
|
||||
'Master_User',
|
||||
'Master_Port',
|
||||
'Connect_Retry',
|
||||
'Master_Log_File',
|
||||
'Read_Master_Log_Pos',
|
||||
'Relay_Log_File',
|
||||
'Relay_Log_Pos',
|
||||
'Relay_Master_Log_File',
|
||||
'Slave_IO_Running',
|
||||
'Slave_SQL_Running',
|
||||
'Replicate_Do_DB',
|
||||
'Replicate_Ignore_DB',
|
||||
'Replicate_Do_Table',
|
||||
'Replicate_Ignore_Table',
|
||||
'Replicate_Wild_Do_Table',
|
||||
'Replicate_Wild_Ignore_Table',
|
||||
'Last_Errno',
|
||||
'Last_Error',
|
||||
'Skip_Counter',
|
||||
'Exec_Master_Log_Pos',
|
||||
'Relay_Log_Space',
|
||||
'Until_Condition',
|
||||
'Until_Log_File',
|
||||
'Until_Log_Pos',
|
||||
'Master_SSL_Allowed',
|
||||
'Master_SSL_CA_File',
|
||||
'Master_SSL_CA_Path',
|
||||
'Master_SSL_Cert',
|
||||
'Master_SSL_Cipher',
|
||||
'Master_SSL_Key',
|
||||
'Seconds_Behind_Master',
|
||||
];
|
||||
/**
|
||||
* define important variables, which need to be watched for
|
||||
* correct running of replication in slave mode
|
||||
*
|
||||
* @usedby PhpMyAdmin\ReplicationGui->getHtmlForReplicationStatusTable()
|
||||
*/
|
||||
// TODO change to regexp or something, to allow for negative match.
|
||||
// To e.g. highlight 'Last_Error'
|
||||
//
|
||||
$slave_variables_alerts = [
|
||||
'Slave_IO_Running' => 'No',
|
||||
'Slave_SQL_Running' => 'No',
|
||||
];
|
||||
$slave_variables_oks = [
|
||||
'Slave_IO_Running' => 'Yes',
|
||||
'Slave_SQL_Running' => 'Yes',
|
||||
];
|
||||
|
||||
// check which replication is available and
|
||||
// set $server_{master/slave}_status and assign values
|
||||
|
||||
// replication info is more easily passed to functions
|
||||
$replication_info = [];
|
||||
|
||||
foreach ($replication_types as $type) {
|
||||
if (count(${'server_' . $type . '_replication'}) > 0) {
|
||||
$replication_info[$type]['status'] = true;
|
||||
} else {
|
||||
$replication_info[$type]['status'] = false;
|
||||
}
|
||||
if ($replication_info[$type]['status']) {
|
||||
if ($type == 'master') {
|
||||
self::fill(
|
||||
$type,
|
||||
'Do_DB',
|
||||
$server_master_replication[0],
|
||||
'Binlog_Do_DB'
|
||||
);
|
||||
|
||||
self::fill(
|
||||
$type,
|
||||
'Ignore_DB',
|
||||
$server_master_replication[0],
|
||||
'Binlog_Ignore_DB'
|
||||
);
|
||||
} elseif ($type == 'slave') {
|
||||
self::fill(
|
||||
$type,
|
||||
'Do_DB',
|
||||
$server_slave_replication[0],
|
||||
'Replicate_Do_DB'
|
||||
);
|
||||
|
||||
self::fill(
|
||||
$type,
|
||||
'Ignore_DB',
|
||||
$server_slave_replication[0],
|
||||
'Replicate_Ignore_DB'
|
||||
);
|
||||
|
||||
self::fill(
|
||||
$type,
|
||||
'Do_Table',
|
||||
$server_slave_replication[0],
|
||||
'Replicate_Do_Table'
|
||||
);
|
||||
|
||||
self::fill(
|
||||
$type,
|
||||
'Ignore_Table',
|
||||
$server_slave_replication[0],
|
||||
'Replicate_Ignore_Table'
|
||||
);
|
||||
|
||||
self::fill(
|
||||
$type,
|
||||
'Wild_Do_Table',
|
||||
$server_slave_replication[0],
|
||||
'Replicate_Wild_Do_Table'
|
||||
);
|
||||
|
||||
self::fill(
|
||||
$type,
|
||||
'Wild_Ignore_Table',
|
||||
$server_slave_replication[0],
|
||||
'Replicate_Wild_Ignore_Table'
|
||||
);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Fill global replication_info variable.
|
||||
*
|
||||
* @param string $type Type: master, slave
|
||||
* @param string $replicationInfoKey Key in replication_info variable
|
||||
* @param array $mysqlInfo MySQL data about replication
|
||||
* @param string $mysqlKey MySQL key
|
||||
*
|
||||
* @return array
|
||||
*/
|
||||
private static function fill(
|
||||
$type,
|
||||
$replicationInfoKey,
|
||||
array $mysqlInfo,
|
||||
$mysqlKey
|
||||
) {
|
||||
global $replication_info;
|
||||
|
||||
$replication_info[$type][$replicationInfoKey] = empty($mysqlInfo[$mysqlKey])
|
||||
? []
|
||||
: explode(
|
||||
',',
|
||||
$mysqlInfo[$mysqlKey]
|
||||
);
|
||||
|
||||
return $replication_info[$type][$replicationInfoKey];
|
||||
}
|
||||
}
|
||||
@ -9,6 +9,7 @@ declare(strict_types=1);
|
||||
|
||||
namespace PhpMyAdmin\Server\Status;
|
||||
|
||||
use PhpMyAdmin\ReplicationInfo;
|
||||
use PhpMyAdmin\Url;
|
||||
|
||||
/**
|
||||
@ -316,7 +317,7 @@ class Data
|
||||
global $replication_info;
|
||||
|
||||
if (! isset($replication_info)) {
|
||||
require_once ROOT_PATH . 'libraries/replication.inc.php';
|
||||
ReplicationInfo::load();
|
||||
}
|
||||
|
||||
$this->selfUrl = basename($GLOBALS['PMA_PHP_SELF']);
|
||||
|
||||
@ -1,197 +0,0 @@
|
||||
<?php
|
||||
/**
|
||||
* Replication helpers
|
||||
*
|
||||
* @package PhpMyAdmin
|
||||
*/
|
||||
declare(strict_types=1);
|
||||
|
||||
use PhpMyAdmin\Replication;
|
||||
|
||||
if (! defined('PHPMYADMIN')) {
|
||||
exit;
|
||||
}
|
||||
|
||||
global $replication_types, $server_slave_replication, $master_variables, $slave_variables;
|
||||
global $replication_info, $slave_variables_alerts, $slave_variables_oks, $dbi, $url_params;
|
||||
|
||||
$replication = new Replication();
|
||||
|
||||
/**
|
||||
* get master replication from server
|
||||
*/
|
||||
$server_master_replication = $dbi->fetchResult('SHOW MASTER STATUS');
|
||||
|
||||
/**
|
||||
* set selected master server
|
||||
*/
|
||||
if (! empty($_POST['master_connection'])) {
|
||||
/**
|
||||
* check for multi-master replication functionality
|
||||
*/
|
||||
$server_slave_multi_replication = $dbi->fetchResult(
|
||||
'SHOW ALL SLAVES STATUS'
|
||||
);
|
||||
if ($server_slave_multi_replication) {
|
||||
$dbi->query(
|
||||
"SET @@default_master_connection = '"
|
||||
. $dbi->escapeString(
|
||||
$_POST['master_connection']
|
||||
) . "'"
|
||||
);
|
||||
$url_params['master_connection'] = $_POST['master_connection'];
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* get slave replication from server
|
||||
*/
|
||||
$server_slave_replication = $dbi->fetchResult('SHOW SLAVE STATUS');
|
||||
|
||||
/**
|
||||
* replication types
|
||||
*/
|
||||
$replication_types = [
|
||||
'master',
|
||||
'slave',
|
||||
];
|
||||
|
||||
|
||||
/**
|
||||
* define variables for master status
|
||||
*/
|
||||
$master_variables = [
|
||||
'File',
|
||||
'Position',
|
||||
'Binlog_Do_DB',
|
||||
'Binlog_Ignore_DB',
|
||||
];
|
||||
|
||||
/**
|
||||
* Define variables for slave status
|
||||
*/
|
||||
$slave_variables = [
|
||||
'Slave_IO_State',
|
||||
'Master_Host',
|
||||
'Master_User',
|
||||
'Master_Port',
|
||||
'Connect_Retry',
|
||||
'Master_Log_File',
|
||||
'Read_Master_Log_Pos',
|
||||
'Relay_Log_File',
|
||||
'Relay_Log_Pos',
|
||||
'Relay_Master_Log_File',
|
||||
'Slave_IO_Running',
|
||||
'Slave_SQL_Running',
|
||||
'Replicate_Do_DB',
|
||||
'Replicate_Ignore_DB',
|
||||
'Replicate_Do_Table',
|
||||
'Replicate_Ignore_Table',
|
||||
'Replicate_Wild_Do_Table',
|
||||
'Replicate_Wild_Ignore_Table',
|
||||
'Last_Errno',
|
||||
'Last_Error',
|
||||
'Skip_Counter',
|
||||
'Exec_Master_Log_Pos',
|
||||
'Relay_Log_Space',
|
||||
'Until_Condition',
|
||||
'Until_Log_File',
|
||||
'Until_Log_Pos',
|
||||
'Master_SSL_Allowed',
|
||||
'Master_SSL_CA_File',
|
||||
'Master_SSL_CA_Path',
|
||||
'Master_SSL_Cert',
|
||||
'Master_SSL_Cipher',
|
||||
'Master_SSL_Key',
|
||||
'Seconds_Behind_Master',
|
||||
];
|
||||
/**
|
||||
* define important variables, which need to be watched for
|
||||
* correct running of replication in slave mode
|
||||
*
|
||||
* @usedby PhpMyAdmin\ReplicationGui->getHtmlForReplicationStatusTable()
|
||||
*/
|
||||
// TODO change to regexp or something, to allow for negative match.
|
||||
// To e.g. highlight 'Last_Error'
|
||||
//
|
||||
$slave_variables_alerts = [
|
||||
'Slave_IO_Running' => 'No',
|
||||
'Slave_SQL_Running' => 'No',
|
||||
];
|
||||
$slave_variables_oks = [
|
||||
'Slave_IO_Running' => 'Yes',
|
||||
'Slave_SQL_Running' => 'Yes',
|
||||
];
|
||||
|
||||
// check which replication is available and
|
||||
// set $server_{master/slave}_status and assign values
|
||||
|
||||
// replication info is more easily passed to functions
|
||||
$replication_info = [];
|
||||
|
||||
foreach ($replication_types as $type) {
|
||||
if (count(${'server_' . $type . '_replication'}) > 0) {
|
||||
$replication_info[$type]['status'] = true;
|
||||
} else {
|
||||
$replication_info[$type]['status'] = false;
|
||||
}
|
||||
if ($replication_info[$type]['status']) {
|
||||
if ($type == 'master') {
|
||||
$replication->fillInfo(
|
||||
$type,
|
||||
'Do_DB',
|
||||
$server_master_replication[0],
|
||||
'Binlog_Do_DB'
|
||||
);
|
||||
|
||||
$replication->fillInfo(
|
||||
$type,
|
||||
'Ignore_DB',
|
||||
$server_master_replication[0],
|
||||
'Binlog_Ignore_DB'
|
||||
);
|
||||
} elseif ($type == 'slave') {
|
||||
$replication->fillInfo(
|
||||
$type,
|
||||
'Do_DB',
|
||||
$server_slave_replication[0],
|
||||
'Replicate_Do_DB'
|
||||
);
|
||||
|
||||
$replication->fillInfo(
|
||||
$type,
|
||||
'Ignore_DB',
|
||||
$server_slave_replication[0],
|
||||
'Replicate_Ignore_DB'
|
||||
);
|
||||
|
||||
$replication->fillInfo(
|
||||
$type,
|
||||
'Do_Table',
|
||||
$server_slave_replication[0],
|
||||
'Replicate_Do_Table'
|
||||
);
|
||||
|
||||
$replication->fillInfo(
|
||||
$type,
|
||||
'Ignore_Table',
|
||||
$server_slave_replication[0],
|
||||
'Replicate_Ignore_Table'
|
||||
);
|
||||
|
||||
$replication->fillInfo(
|
||||
$type,
|
||||
'Wild_Do_Table',
|
||||
$server_slave_replication[0],
|
||||
'Replicate_Wild_Do_Table'
|
||||
);
|
||||
|
||||
$replication->fillInfo(
|
||||
$type,
|
||||
'Wild_Ignore_Table',
|
||||
$server_slave_replication[0],
|
||||
'Replicate_Wild_Ignore_Table'
|
||||
);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -12,6 +12,7 @@ use PhpMyAdmin\Advisor;
|
||||
use PhpMyAdmin\Config;
|
||||
use PhpMyAdmin\Controllers\Server\Status\AdvisorController;
|
||||
use PhpMyAdmin\DatabaseInterface;
|
||||
use PhpMyAdmin\ReplicationInfo;
|
||||
use PhpMyAdmin\Response;
|
||||
use PhpMyAdmin\Server\Status\Data;
|
||||
use PhpMyAdmin\Template;
|
||||
@ -40,7 +41,7 @@ class AdvisorControllerTest extends TestCase
|
||||
$GLOBALS['cfg']['Server']['DisableIS'] = false;
|
||||
$GLOBALS['cfg']['Server']['host'] = 'localhost';
|
||||
|
||||
require_once ROOT_PATH . 'libraries/replication.inc.php';
|
||||
ReplicationInfo::load();
|
||||
|
||||
//this data is needed when PhpMyAdmin\Server\Status\Data constructs
|
||||
$serverStatus = [
|
||||
|
||||
@ -11,14 +11,10 @@ namespace PhpMyAdmin\Tests;
|
||||
use PhpMyAdmin\DatabaseInterface;
|
||||
use PhpMyAdmin\Replication;
|
||||
use PhpMyAdmin\ReplicationGui;
|
||||
use PhpMyAdmin\ReplicationInfo;
|
||||
use PhpMyAdmin\Template;
|
||||
use PHPUnit\Framework\TestCase;
|
||||
|
||||
/*
|
||||
* Include to test.
|
||||
*/
|
||||
require_once ROOT_PATH . 'libraries/replication.inc.php';
|
||||
|
||||
/**
|
||||
* PhpMyAdmin\Tests\ReplicationGuiTest class
|
||||
*
|
||||
@ -60,6 +56,8 @@ class ReplicationGuiTest extends TestCase
|
||||
$GLOBALS['table'] = 'table';
|
||||
$GLOBALS['url_params'] = [];
|
||||
|
||||
ReplicationInfo::load();
|
||||
|
||||
$this->replicationGui = new ReplicationGui(new Replication(), new Template());
|
||||
|
||||
//$_SESSION
|
||||
|
||||
Loading…
Reference in New Issue
Block a user