diff options
Diffstat (limited to 'srcs/phpmyadmin/libraries/classes/Replication.php')
| -rw-r--r-- | srcs/phpmyadmin/libraries/classes/Replication.php | 190 |
1 files changed, 190 insertions, 0 deletions
diff --git a/srcs/phpmyadmin/libraries/classes/Replication.php b/srcs/phpmyadmin/libraries/classes/Replication.php new file mode 100644 index 0000000..4fa68f2 --- /dev/null +++ b/srcs/phpmyadmin/libraries/classes/Replication.php @@ -0,0 +1,190 @@ +<?php +/* vim: set expandtab sw=4 ts=4 sts=4: */ +/** + * Replication helpers + * + * @package PhpMyAdmin + */ +declare(strict_types=1); + +namespace PhpMyAdmin; + +/** + * PhpMyAdmin\Replication class + * + * @package 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 + * + * @param string $string contains "dbname.tablename" + * @param string $what what to extract (db|table) + * + * @return string the extracted part + */ + public function extractDbOrTable($string, $what = 'db') + { + $list = explode(".", $string); + if ('db' == $what) { + return $list[0]; + } else { + return $list[1]; + } + } + + /** + * Configures replication slave + * + * @param string $action possible values: START or STOP + * @param string $control default: null, + * possible values: SQL_THREAD or IO_THREAD or null. + * If it is set to null, it controls both + * SQL_THREAD and IO_THREAD + * @param integer $link mysql link + * + * @return mixed output of DatabaseInterface::tryQuery + */ + public function slaveControl($action, $control = null, $link = null) + { + /** @var DatabaseInterface $dbi */ + global $dbi; + + $action = mb_strtoupper($action); + $control = mb_strtoupper($control); + + if ($action != "START" && $action != "STOP") { + return -1; + } + if ($control != "SQL_THREAD" && $control != "IO_THREAD" && $control != null) { + return -1; + } + + return $dbi->tryQuery($action . " SLAVE " . $control . ";", $link); + } + + /** + * Changes master for replication slave + * + * @param string $user replication user on master + * @param string $password password for the user + * @param string $host master's hostname or IP + * @param int $port port, where mysql is running + * @param array $pos position of mysql replication, + * array should contain fields File and Position + * @param bool $stop shall we stop slave? + * @param bool $start shall we start slave? + * @param mixed $link mysql link + * + * @return string output of CHANGE MASTER mysql command + */ + public function slaveChangeMaster( + $user, + $password, + $host, + $port, + array $pos, + $stop = true, + $start = true, + $link = null + ) { + if ($stop) { + $this->slaveControl("STOP", null, $link); + } + + $out = $GLOBALS['dbi']->tryQuery( + 'CHANGE MASTER TO ' . + 'MASTER_HOST=\'' . $host . '\',' . + 'MASTER_PORT=' . ($port * 1) . ',' . + 'MASTER_USER=\'' . $user . '\',' . + 'MASTER_PASSWORD=\'' . $password . '\',' . + 'MASTER_LOG_FILE=\'' . $pos["File"] . '\',' . + 'MASTER_LOG_POS=' . $pos["Position"] . ';', + $link + ); + + if ($start) { + $this->slaveControl("START", null, $link); + } + + return $out; + } + + /** + * This function provides connection to remote mysql server + * + * @param string $user mysql username + * @param string $password password for the user + * @param string $host mysql server's hostname or IP + * @param int $port mysql remote port + * @param string $socket path to unix socket + * + * @return mixed mysql link on success + */ + public function connectToMaster( + $user, + $password, + $host = null, + $port = null, + $socket = null + ) { + $server = []; + $server['user'] = $user; + $server['password'] = $password; + $server["host"] = Core::sanitizeMySQLHost($host); + $server["port"] = $port; + $server["socket"] = $socket; + + // 5th parameter set to true means that it's an auxiliary connection + // and we must not go back to login page if it fails + return $GLOBALS['dbi']->connect(DatabaseInterface::CONNECT_AUXILIARY, $server); + } + + /** + * Fetches position and file of current binary log on master + * + * @param mixed $link mysql link + * + * @return array an array containing File and Position in MySQL replication + * on master server, useful for slaveChangeMaster() + */ + public function slaveBinLogMaster($link = null) + { + $data = $GLOBALS['dbi']->fetchResult('SHOW MASTER STATUS', null, null, $link); + $output = []; + + if (! empty($data)) { + $output["File"] = $data[0]["File"]; + $output["Position"] = $data[0]["Position"]; + } + return $output; + } +} |