init web ems all

2024-09-27 17:13:36 +08:00
parent 81c97acbe9
commit 5cc56f8078
4263 changed files with 798779 additions and 0 deletions
--- a/phpMyAdmin/libraries/classes/Replication.php
+++ b/phpMyAdmin/libraries/classes/Replication.php
@@ -0,0 +1,173 @@
+<?php
+/* vim: set expandtab sw=4 ts=4 sts=4: */
+/**
+ * Replication helpers
+ *
+ * @package PhpMyAdmin
+ */
+namespace PhpMyAdmin;
+
+use PhpMyAdmin\Core;
+use PhpMyAdmin\DatabaseInterface;
+
+/**
+ * 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 static function fillInfo(
+        $type, $replicationInfoKey, array $mysqlInfo, $mysqlKey
+    ) {
+        $GLOBALS['replication_info'][$type][$replicationInfoKey]
+            = empty($mysqlInfo[$mysqlKey])
+                ? array()
+                : 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 static 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 mixed  $link    mysql link
+     *
+     * @return mixed output of DatabaseInterface::tryQuery
+     */
+    public static function slaveControl($action, $control = null, $link = null)
+    {
+        $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 $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
+     */
+    public static function slaveChangeMaster($user, $password, $host, $port,
+        array $pos, $stop = true, $start = true, $link = null
+    ) {
+        if ($stop) {
+            self::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) {
+            self::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 $link mysql link on success
+     */
+    public static function connectToMaster(
+        $user, $password, $host = null, $port = null, $socket = null
+    ) {
+        $server = array();
+        $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 self::slaveChangeMaster
+     */
+    public static function slaveBinLogMaster($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;
+    }
+}