diff options
author | Christian Foellmann <foellmann@foe-services.de> | 2014-04-05 17:35:38 +0400 |
---|---|---|
committer | Christian Foellmann <foellmann@foe-services.de> | 2014-04-05 17:35:38 +0400 |
commit | 9eb27ef6ebc763ddc6f6278462b8ffeed6de0e36 (patch) | |
tree | d3b4a1c7ae68cafb05b9d60040c9c22d457cee62 /libraries/replication.inc.php | |
parent | d472216554769ba596795f23a70c1809fa8897a3 (diff) |
INIT phpmyadmin 4.1.12 multilanguage
Diffstat (limited to 'libraries/replication.inc.php')
-rw-r--r-- | libraries/replication.inc.php | 288 |
1 files changed, 288 insertions, 0 deletions
diff --git a/libraries/replication.inc.php b/libraries/replication.inc.php new file mode 100644 index 0000000000..777a17cf8e --- /dev/null +++ b/libraries/replication.inc.php @@ -0,0 +1,288 @@ +<?php +/* vim: set expandtab sw=4 ts=4 sts=4: */ +/** + * Replication helpers + * + * @package PhpMyAdmin + */ + +if (! defined('PHPMYADMIN')) { + exit; +} + +/** + * get master replication from server + */ +$server_master_replication = $GLOBALS['dbi']->fetchResult('SHOW MASTER STATUS'); + +/** + * get slave replication from server + */ +$server_slave_replication = $GLOBALS['dbi']->fetchResult('SHOW SLAVE STATUS'); + +/** + * replication types + */ +$replication_types = array('master', 'slave'); + + +/** + * define variables for master status + */ +$master_variables = array( + 'File', + 'Position', + 'Binlog_Do_DB', + 'Binlog_Ignore_DB', +); + +/** + * Define variables for slave status + */ +$slave_variables = array( + '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 PMA_getHtmlForReplicationStatusTable() + */ +// TODO change to regexp or something, to allow for negative match. +// To e.g. highlight 'Last_Error' +// +$slave_variables_alerts = array( + 'Slave_IO_Running' => 'No', + 'Slave_SQL_Running' => 'No', +); +$slave_variables_oks = array( + '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 +/* + * @todo use $replication_info everywhere instead of the generated variable names + */ +$replication_info = array(); + +foreach ($replication_types as $type) { + if (count(${"server_{$type}_replication"}) > 0) { + ${"server_{$type}_status"} = true; + $replication_info[$type]['status'] = true; + } else { + ${"server_{$type}_status"} = false; + $replication_info[$type]['status'] = false; + } + if (${"server_{$type}_status"}) { + if ($type == "master") { + ${"server_{$type}_Do_DB"} = explode( + ",", $server_master_replication[0]["Binlog_Do_DB"] + ); + $replication_info[$type]['Do_DB'] = ${"server_{$type}_Do_DB"}; + + ${"server_{$type}_Ignore_DB"} = explode( + ",", $server_master_replication[0]["Binlog_Ignore_DB"] + ); + $replication_info[$type]['Ignore_DB'] = ${"server_{$type}_Ignore_DB"}; + } elseif ($type == "slave") { + ${"server_{$type}_Do_DB"} = explode( + ",", $server_slave_replication[0]["Replicate_Do_DB"] + ); + if (! empty(${"server_{$type}_Do_DB"})) { + $replication_info[$type]['Do_DB'] = ${"server_{$type}_Do_DB"}; + } + + ${"server_{$type}_Ignore_DB"} = explode( + ",", $server_slave_replication[0]["Replicate_Ignore_DB"] + ); + $replication_info[$type]['Ignore_DB'] = ${"server_{$type}_Ignore_DB"}; + + ${"server_{$type}_Do_Table"} = explode( + ",", $server_slave_replication[0]["Replicate_Do_Table"] + ); + $replication_info[$type]['Do_Table'] = ${"server_{$type}_Do_Table"}; + + ${"server_{$type}_Ignore_Table"} = explode( + ",", $server_slave_replication[0]["Replicate_Ignore_Table"] + ); + $replication_info[$type]['Ignore_Table'] + = ${"server_{$type}_Ignore_Table"}; + + ${"server_{$type}_Wild_Do_Table"} = explode( + ",", $server_slave_replication[0]["Replicate_Wild_Do_Table"] + ); + $replication_info[$type]['Wild_Do_Table'] + = ${"server_{$type}_Wild_Do_Table"}; + + ${"server_{$type}_Wild_Ignore_Table"} = explode( + ",", $server_slave_replication[0]["Replicate_Wild_Ignore_Table"] + ); + $replication_info[$type]['Wild_Ignore_Table'] + = ${"server_{$type}_Wild_Ignore_Table"}; + } + } +} + +/** + * 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 + */ +function PMA_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 mixed $link mysql link + * + * @return mixed output of DatabaseInterface::tryQuery + */ +function PMA_Replication_Slave_control($action, $control = null, $link = null) +{ + $action = strtoupper($action); + $control = strtoupper($control); + + if ($action != "START" && $action != "STOP") { + return -1; + } + if ($control != "SQL_THREAD" && $control != "IO_THREAD" && $control != null) { + return -1; + } + + return $GLOBALS['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 + */ +function PMA_Replication_Slave_changeMaster($user, $password, $host, $port, + $pos, $stop = true, $start = true, $link = null +) { + if ($stop) { + PMA_Replication_Slave_control("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) { + PMA_Replication_Slave_control("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 $link mysql link on success + */ +function PMA_Replication_connectToMaster( + $user, $password, $host = null, $port = null, $socket = null +) { + $server = array(); + $server["host"] = $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($user, $password, false, $server, true); +} +/** + * 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 PMA_Replication_Slave_changeMaster + */ +function PMA_Replication_Slave_binLogMaster($link = null) +{ + $data = $GLOBALS['dbi']->fetchResult('SHOW MASTER STATUS', null, null, $link); + $output = array(); + + if (! empty($data)) { + $output["File"] = $data[0]["File"]; + $output["Position"] = $data[0]["Position"]; + } + return $output; +} +?> |