diff --git a/db_structure.php b/db_structure.php index 6c6a647b2..3a9b35c95 100644 --- a/db_structure.php +++ b/db_structure.php @@ -339,28 +339,31 @@ foreach ($tables as $keyname => $each_table) { $do = false; if ($server_slave_status) { - //////////////////////////////////////////////////////////////// - - if ((strlen(array_search($truename, $server_slave_Do_Table))>0) || (strlen(array_search($db, $server_slave_Do_DB))>0) || (count($server_slave_Do_DB)==1 && count($server_slave_Ignore_DB)==1)) { - $do = true; - } - foreach ($server_slave_Wild_Do_Table as $table) { - if (($db == PMA_replication_strout($table)) && (ereg("^".substr(PMA_replication_strout($table, true), 0, strlen(PMA_replication_strout($table, true))-1), $truename))) - $do = true; - } - //////////////////////////////////////////////////////////////////// - if ((strlen(array_search($truename, $server_slave_Ignore_Table))>0) || (strlen(array_search($db, $server_slave_Ignore_DB))>0)) { - $ignored = true; - } - foreach ($server_slave_Wild_Ignore_Table as $table) { - if (($db == PMA_replication_strout($table)) && (ereg("^".substr(PMA_replication_strout($table, true), 0, strlen(PMA_replication_strout($table, true))-1), $truename))) - $ignored = true; - } + //////////////////////////////////////////////////////////////// + + if ((strlen(array_search($truename, $server_slave_Do_Table)) > 0) + || (strlen(array_search($db, $server_slave_Do_DB))>0) + || (count($server_slave_Do_DB)==1 && count($server_slave_Ignore_DB)==1) + ) { + $do = true; + } + foreach ($server_slave_Wild_Do_Table as $table) { + if (($db == PMA_replication_strout($table)) && (ereg("^".substr(PMA_replication_strout($table, true), 0, strlen(PMA_replication_strout($table, true))-1), $truename))) + $do = true; + } + //////////////////////////////////////////////////////////////////// + if ((strlen(array_search($truename, $server_slave_Ignore_Table))>0) || (strlen(array_search($db, $server_slave_Ignore_DB))>0)) { + $ignored = true; + } + foreach ($server_slave_Wild_Ignore_Table as $table) { + if (($db == PMA_replication_strout($table)) && (ereg("^".substr(PMA_replication_strout($table, true), 0, strlen(PMA_replication_strout($table, true))-1), $truename))) + $ignored = true; + } }/* elseif ($server_master_status) { - if ((strlen(array_search($db, $server_master_Do_DB))>0) || count($server_master_Do_DB)==1) - $do = true; - elseif ((strlen(array_search($db, $server_master_Ignore_DB))>0) || count($server_master_Ignore_DB)==1) - $ignored = true; + if ((strlen(array_search($db, $server_master_Do_DB))>0) || count($server_master_Do_DB)==1) + $do = true; + elseif ((strlen(array_search($db, $server_master_Ignore_DB))>0) || count($server_master_Ignore_DB)==1) + $ignored = true; }*/ ?> diff --git a/libraries/replication.inc.php b/libraries/replication.inc.php index c590c846e..d11b709eb 100644 --- a/libraries/replication.inc.php +++ b/libraries/replication.inc.php @@ -21,352 +21,357 @@ $server_master_replication = PMA_DBI_fetch_result('SHOW MASTER STATUS'); $server_slave_replication = PMA_DBI_fetch_result('SHOW SLAVE STATUS'); /** - * replication types - */ + * replication types + */ $replication_types = array('master', 'slave'); /** - * define variables for master status - */ + * define variables for master status + */ $master_variables = array( - 'File', - 'Position', - 'Binlog_Do_DB', - 'Binlog_Ignore_DB' + 'File', + 'Position', + 'Binlog_Do_DB', + 'Binlog_Ignore_DB' ); /** - * Define variables for slave status - */ + * 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' + '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 - */ + * define important variables, which need to be watched for correct running of replication in slave mode + */ $slave_variables_alerts = array( - 'Slave_IO_Running' => 'No', - 'Slave_SQL_Running' => 'No' - ); + 'Slave_IO_Running' => 'No', + 'Slave_SQL_Running' => 'No' +); $slave_variables_oks = array( - 'Slave_IO_Running' => 'Yes', - 'Slave_SQL_Running' => 'Yes' - ); - + 'Slave_IO_Running' => 'Yes', + 'Slave_SQL_Running' => 'Yes' +); + $serverid = time(); // check which replication is available and set $server_{master/slave}_status and assign values foreach ($replication_types as $type) { - if (count(${"server_{$type}_replication"}) > 0) - ${"server_{$type}_status"} = true; - else - ${"server_{$type}_status"} = false; + if (count(${"server_{$type}_replication"}) > 0) + ${"server_{$type}_status"} = true; + else + ${"server_{$type}_status"} = false; - if (${"server_{$type}_status"}) { - if ($type=="master") { - ${"server_{$type}_Do_DB"} = explode (",", $server_master_replication[0]["Binlog_Do_DB"]); - ${"server_{$type}_Ignore_DB"} = explode (",", $server_master_replication[0]["Binlog_Ignore_DB"]); - } elseif ($type=="slave") { - ${"server_{$type}_Do_DB"} = explode (",", $server_slave_replication[0]["Replicate_Do_DB"]); - ${"server_{$type}_Ignore_DB"} = explode (",", $server_slave_replication[0]["Replicate_Ignore_DB"]); - - ${"server_{$type}_Do_Table"} = explode (",", $server_slave_replication[0]["Replicate_Do_Table"]); - ${"server_{$type}_Ignore_Table"} = explode (",", $server_slave_replication[0]["Replicate_Ignore_Table"]); - - ${"server_{$type}_Wild_Do_Table"} = explode (",", $server_slave_replication[0]["Replicate_Wild_Do_Table"]); - ${"server_{$type}_Wild_Ignore_Table"} = explode (",", $server_slave_replication[0]["Replicate_Wild_Ignore_Table"]); - } - } -} + if (${"server_{$type}_status"}) { + if ($type == "master") { + ${"server_{$type}_Do_DB"} = explode (",", $server_master_replication[0]["Binlog_Do_DB"]); + ${"server_{$type}_Ignore_DB"} = explode (",", $server_master_replication[0]["Binlog_Ignore_DB"]); + } elseif ($type == "slave") { + ${"server_{$type}_Do_DB"} = explode (",", $server_slave_replication[0]["Replicate_Do_DB"]); + ${"server_{$type}_Ignore_DB"} = explode (",", $server_slave_replication[0]["Replicate_Ignore_DB"]); + ${"server_{$type}_Do_Table"} = explode (",", $server_slave_replication[0]["Replicate_Do_Table"]); + ${"server_{$type}_Ignore_Table"} = explode (",", $server_slave_replication[0]["Replicate_Ignore_Table"]); -/** - * @param $string - - * @param $table - - * @return - */ -function PMA_replication_strout($string, $table=false) { - $list = explode(".", $string); - - return $list[(int)$table]; -} -/** - * @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 PMA_DBI_try_query - */ -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 PMA_DBI_try_query($action." SLAVE ".$control.";", $link); -} -/** - * @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 boolean $stop - shall we stop slave? - * @param boolean $start - shall we start slave? - * @param mixed $link - mysql link - * - * @return output of CHANGE MASTER mysql command - */ -function PMA_replication_slave_change_master($user, $password, $host, $port, $pos, $stop=true, $start=true, $link=null) -{ - if ($stop) - PMA_replication_slave_control("STOP", null, $link); - - $out = PMA_DBI_try_query('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_connect_to_master($user, $password, $host=null, $port=null, $socket=null) -{ - $server = array(); - $server["host"] = $host; - $server["port"] = $port; - $server["socket"] = $socket; - - return PMA_DBI_connect($user, $password, false, $server); -} -/** - * @param $link - mysql link - * - * @return array - containing File and Position in MySQL replication on master server, useful for PMA_replication_slave_change_master - */ -function PMA_replication_slave_bin_log_master($link=null) -{ - $data = PMA_DBI_fetch_result('SHOW MASTER STATUS', null, null, $link); - - $output = array(); - $output["File"] = $data[0]["File"]; - $output["Position"] = $data[0]["Position"]; - - return $output; -} - -/** - * Get list of replicated databases on master server - * - * @param mixed mysql link - * - * @return array array of replicated databases - */ - -function PMA_replication_master_replicated_dbs($link=null) -{ - $data = PMA_DBI_fetch_result('SHOW MASTER STATUS', null, null, $link); // let's find out, which databases are replicated - - $do_db = array(); - $ignore_db = array(); - - if (!empty($data[0]['Binlog_Do_DB'])) - $do_db = explode($data[0]['Binlog_Do_DB'], ','); - if (!empty($data[0]['Binlog_Ignore_DB'])) - $ignore_db = explode($data[0]['Binlog_Ignore_DB'], ','); - - $tmp_alldbs = PMA_DBI_query('SHOW DATABASES;', $link); - while ($tmp_row = PMA_DBI_fetch_row($tmp_alldbs)) { - if ($tmp_row[0] == 'information_schema') - continue; - if (count($do_db)==0) { - if (array_search($tmp_row[0], $ignore_db)!==false) { - continue; - } - $dblist[] = $tmp_row[0]; - - } else { - if (array_search($tmp_row[0], $do_db)!==false) { - $dblist[] = $tmp_row[0]; - } - } - } // end while - - return $link; -} -/** - * This function provides synchronization of structure and data between two mysql servers. - * TODO: improve code sharing between the function and synchronization - * - * @param String $db - name of database, which should be synchronized - * @param mixed $src_link - link of source server, note: if the server is current PMA server, use null - * @param mixed $trg_link - link of target server, note: if the server is current PMA server, use null - * @param boolean $data - if true, then data will be copied as well - */ - -function PMA_replication_synchronize_DB($db, $src_link, $trg_link, $data=true) -{ - $src_db = $db; - $trg_db = $db; - $src_connection = PMA_DBI_select_db($db, $src_link); - $trg_connection = PMA_DBI_select_db($db, $trg_link); - - $src_tables = PMA_DBI_get_tables($src_db, $src_link); - $source_tables_num = sizeof($src_tables); - - $trg_tables = PMA_DBI_get_tables($trg_db, $trg_link); - $target_tables_num = sizeof($trg_tables); - /** - * initializing arrays to save table names - */ - $unmatched_num_src = 0; - $source_tables_uncommon = array(); - $unmatched_num_trg = 0; - $target_tables_uncommon = array(); - $matching_tables = array(); - $matching_tables_num = 0; - - /** - * Criterion for matching tables is just their names. - * Finding the uncommon tables for the source database - * BY comparing the matching tables with all the tables in the source database - */ - PMA_getMatchingTables($trg_tables, $src_tables, $matching_tables, $source_tables_uncommon); - - /** - * Finding the uncommon tables for the target database - * BY comparing the matching tables with all the tables in the target database - */ - PMA_getNonMatchingTargetTables($trg_tables, $matching_tables, $target_tables_uncommon); - - /** - * - * ********************************************* Comparing Data In the Matching Tables ****************************************** - * *********************It is assumed that the matching tables are structurally and typely exactly the same ********************* - */ - $fields_num = array(); - $matching_tables_fields = array(); - $matching_tables_keys = array(); - $insert_array = array(array(array())); - $update_array = array(array(array())); - $delete_array = array(); - $row_count = array(); - $uncommon_tables_fields = array(); - $matching_tables_num = sizeof($matching_tables); - - for($i=0; $i< sizeof($matching_tables); $i++) - { - PMA_dataDiffInTables($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $matching_tables_fields, $update_array, $insert_array, - $delete_array, $fields_num, $i, $matching_tables_keys); + ${"server_{$type}_Wild_Do_Table"} = explode (",", $server_slave_replication[0]["Replicate_Wild_Do_Table"]); + ${"server_{$type}_Wild_Ignore_Table"} = explode (",", $server_slave_replication[0]["Replicate_Wild_Ignore_Table"]); } - for($j=0; $j< sizeof($source_tables_uncommon); $j++) - { - PMA_dataDiffInUncommonTables($source_tables_uncommon, $src_db, $src_link, $j, $row_count); - } - /** - * INTEGRATION OF STRUCTURE DIFFERENCE CODE - * - */ - $source_columns = array(); - $target_columns = array(); - $alter_str_array = array(array()); - $add_column_array = array(array()); - $uncommon_columns = array(); - $target_tables_keys = array(); - $source_indexes = array(); - $target_indexes = array(); - $add_indexes_array = array(); - $remove_indexes_array = array(); - $criteria = array('Field', 'Type', 'Null', 'Collation', 'Key', 'Default', 'Comment'); - - for ($counter= 0; $counter< $matching_tables_num; $counter++) - { -// PMA_structureDiffInTables($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $source_columns, -// $target_columns, $alter_str_array, $add_column_array, $uncommon_columns, $criteria, $matching_tables_keys, -// $target_tables_keys, $matching_tables_fields, $counter); -// -// PMA_indexesDiffInTables($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $source_indexes, $target_indexes, -// $add_indexes_array, $remove_indexes_array, $counter); - PMA_structureDiffInTables($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $source_columns, - $target_columns, $alter_str_array, $add_column_array, $uncommon_columns, $criteria, $target_tables_keys, $counter); - - PMA_indexesDiffInTables($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $source_indexes, $target_indexes, - $add_indexes_array, $alter_indexes_array,$remove_indexes_array, $counter); - } - + } +} - - $matching_table_data_diff = array(); - $matching_table_structure_diff = array(); - $uncommon_table_structure_diff = array(); - $uncommon_table_data_diff = array(); - $uncommon_tables = $source_tables_uncommon; - - /** - * Generating Create Table query for all the non-matching tables present in Source but not in Target and populating tables. - */ - for($q=0; $q < sizeof($source_tables_uncommon) ;$q++) - { - if (isset($uncommon_tables[$q])) { - PMA_createTargetTables($src_db, $trg_db, $src_link, $trg_link, $source_tables_uncommon, $q, $uncommon_tables_fields, false); - } - if (isset($row_count[$q]) && $data) { - PMA_populateTargetTables($src_db, $trg_db, $src_link, $trg_link, $source_tables_uncommon, $q, $uncommon_tables_fields, false); - } - } + +/** + * @param $string - + * @param $table - + * @return + */ +function PMA_replication_strout($string, $table = false) { + $list = explode(".", $string); + + return $list[(int)$table]; +} +/** + * @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 PMA_DBI_try_query + */ +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 PMA_DBI_try_query($action." SLAVE ".$control.";", $link); +} +/** + * @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 boolean $stop - shall we stop slave? + * @param boolean $start - shall we start slave? + * @param mixed $link - mysql link + * + * @return output of CHANGE MASTER mysql command + */ +function PMA_replication_slave_change_master($user, $password, $host, $port, $pos, $stop = true, $start = true, $link = null) +{ + if ($stop) { + PMA_replication_slave_control("STOP", null, $link); + } + + $out = PMA_DBI_try_query('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_connect_to_master($user, $password, $host = null, $port = null, $socket = null) +{ + $server = array(); + $server["host"] = $host; + $server["port"] = $port; + $server["socket"] = $socket; + + return PMA_DBI_connect($user, $password, false, $server); +} +/** + * @param $link - mysql link + * + * @return array - containing File and Position in MySQL replication on master server, useful for PMA_replication_slave_change_master + */ +function PMA_replication_slave_bin_log_master($link = null) +{ + $data = PMA_DBI_fetch_result('SHOW MASTER STATUS', null, null, $link); + + $output = array(); + $output["File"] = $data[0]["File"]; + $output["Position"] = $data[0]["Position"]; + + return $output; +} + +/** + * Get list of replicated databases on master server + * + * @param mixed mysql link + * + * @return array array of replicated databases + */ + +function PMA_replication_master_replicated_dbs($link = null) +{ + $data = PMA_DBI_fetch_result('SHOW MASTER STATUS', null, null, $link); // let's find out, which databases are replicated + + $do_db = array(); + $ignore_db = array(); + + if (!empty($data[0]['Binlog_Do_DB'])) { + $do_db = explode($data[0]['Binlog_Do_DB'], ','); + } + if (!empty($data[0]['Binlog_Ignore_DB'])) { + $ignore_db = explode($data[0]['Binlog_Ignore_DB'], ','); + } + + $tmp_alldbs = PMA_DBI_query('SHOW DATABASES;', $link); + while ($tmp_row = PMA_DBI_fetch_row($tmp_alldbs)) { + if ($tmp_row[0] == 'information_schema') + continue; + if (count($do_db) == 0) { + if (array_search($tmp_row[0], $ignore_db) !== false) { + continue; + } + $dblist[] = $tmp_row[0]; + + } else { + if (array_search($tmp_row[0], $do_db) !== false) { + $dblist[] = $tmp_row[0]; + } + } + } // end while + + return $link; +} +/** + * This function provides synchronization of structure and data between two mysql servers. + * TODO: improve code sharing between the function and synchronization + * + * @param String $db - name of database, which should be synchronized + * @param mixed $src_link - link of source server, note: if the server is current PMA server, use null + * @param mixed $trg_link - link of target server, note: if the server is current PMA server, use null + * @param boolean $data - if true, then data will be copied as well + */ + +function PMA_replication_synchronize_DB($db, $src_link, $trg_link, $data = true) +{ + $src_db = $db; + $trg_db = $db; + $src_connection = PMA_DBI_select_db($db, $src_link); + $trg_connection = PMA_DBI_select_db($db, $trg_link); + + $src_tables = PMA_DBI_get_tables($src_db, $src_link); + $source_tables_num = sizeof($src_tables); + + $trg_tables = PMA_DBI_get_tables($trg_db, $trg_link); + $target_tables_num = sizeof($trg_tables); + + /** + * initializing arrays to save table names + */ + $unmatched_num_src = 0; + $source_tables_uncommon = array(); + $unmatched_num_trg = 0; + $target_tables_uncommon = array(); + $matching_tables = array(); + $matching_tables_num = 0; + + /** + * Criterion for matching tables is just their names. + * Finding the uncommon tables for the source database + * BY comparing the matching tables with all the tables in the source database + */ + PMA_getMatchingTables($trg_tables, $src_tables, $matching_tables, $source_tables_uncommon); + + /** + * Finding the uncommon tables for the target database + * BY comparing the matching tables with all the tables in the target database + */ + PMA_getNonMatchingTargetTables($trg_tables, $matching_tables, $target_tables_uncommon); + + /** + * + * ********************************************* Comparing Data In the Matching Tables ****************************************** + * *********************It is assumed that the matching tables are structurally and typely exactly the same ********************* + */ + $fields_num = array(); + $matching_tables_fields = array(); + $matching_tables_keys = array(); + $insert_array = array(array(array())); + $update_array = array(array(array())); + $delete_array = array(); + $row_count = array(); + $uncommon_tables_fields = array(); + $matching_tables_num = sizeof($matching_tables); + + for ($i=0; $i< sizeof($matching_tables); $i++) + { + PMA_dataDiffInTables($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $matching_tables_fields, $update_array, $insert_array, + $delete_array, $fields_num, $i, $matching_tables_keys); + } + for ($j=0; $j< sizeof($source_tables_uncommon); $j++) + { + PMA_dataDiffInUncommonTables($source_tables_uncommon, $src_db, $src_link, $j, $row_count); + } + /** + * INTEGRATION OF STRUCTURE DIFFERENCE CODE + * + */ + $source_columns = array(); + $target_columns = array(); + $alter_str_array = array(array()); + $add_column_array = array(array()); + $uncommon_columns = array(); + $target_tables_keys = array(); + $source_indexes = array(); + $target_indexes = array(); + $add_indexes_array = array(); + $remove_indexes_array = array(); + $criteria = array('Field', 'Type', 'Null', 'Collation', 'Key', 'Default', 'Comment'); + + for ($counter = 0; $counter < $matching_tables_num; $counter++) + { + // PMA_structureDiffInTables($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $source_columns, + // $target_columns, $alter_str_array, $add_column_array, $uncommon_columns, $criteria, $matching_tables_keys, + // $target_tables_keys, $matching_tables_fields, $counter); + // + // PMA_indexesDiffInTables($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $source_indexes, $target_indexes, + // $add_indexes_array, $remove_indexes_array, $counter); + PMA_structureDiffInTables($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $source_columns, + $target_columns, $alter_str_array, $add_column_array, $uncommon_columns, $criteria, $target_tables_keys, $counter); + + PMA_indexesDiffInTables($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $source_indexes, $target_indexes, + $add_indexes_array, $alter_indexes_array,$remove_indexes_array, $counter); + } + + $matching_table_data_diff = array(); + $matching_table_structure_diff = array(); + $uncommon_table_structure_diff = array(); + $uncommon_table_data_diff = array(); + $uncommon_tables = $source_tables_uncommon; + + /** + * Generating Create Table query for all the non-matching tables present in Source but not in Target and populating tables. + */ + for($q = 0; $q < sizeof($source_tables_uncommon); $q++) + { + if (isset($uncommon_tables[$q])) { + PMA_createTargetTables($src_db, $trg_db, $src_link, $trg_link, $source_tables_uncommon, $q, $uncommon_tables_fields, false); + } + if (isset($row_count[$q]) && $data) { + PMA_populateTargetTables($src_db, $trg_db, $src_link, $trg_link, $source_tables_uncommon, $q, $uncommon_tables_fields, false); + } + } } ?> diff --git a/libraries/replication_gui.lib.php b/libraries/replication_gui.lib.php index f89e33d98..2105abb3c 100644 --- a/libraries/replication_gui.lib.php +++ b/libraries/replication_gui.lib.php @@ -16,7 +16,7 @@ $jscode['configure_master'] = 'var c_text = "server-id='.$serverid.'
log-bin=mysql-bin
log-error=mysql-bin.err
";'."\n". 'var c_ignore = "binlog_ignore_db=";'."\n". 'var c_do = "binlog_do_db=";'."\n". - + '$(\'db_reset_href\').addEvent(\'click\', function() {'."\n". ' $(\'db_select\').getSelected().each(function(el) {'."\n". ' el.selected = false;'."\n". @@ -29,18 +29,18 @@ $jscode['configure_master'] = ' else'."\n". ' $(\'rep\').set(\'html\', c_text+c_do+c_output+\';\');'."\n". '});'."\n". - + '$(\'db_select\').addEvent(\'change\',function() {'."\n". ' var count = 0;'."\n". - + ' $(\'db_select\').getSelected().each(function(el) { '."\n". ' if (count==0)'."\n". ' c_output = el.get(\'value\');'."\n". ' else'."\n". ' c_output = c_output + \',\' +el.get(\'value\');'."\n". - + ' count=count+1;'."\n". - + ' if ($(\'db_select\').getSelected().length==count) {'."\n". ' if ($(\'db_type\').getSelected().get(\'value\')=="all")'."\n". ' $(\'rep\').set(\'html\', c_text+c_ignore+c_output);'."\n". @@ -52,12 +52,12 @@ $jscode['configure_master'] = '});'."\n"; $jscode['slave_control'] = - 'divShowHideFunc(\'slave_status_href\', \'replication_slave_section\');'."\n". - 'divShowHideFunc(\'slave_control_href\', \'slave_control_gui\');'."\n". - 'divShowHideFunc(\'slave_errormanagement_href\',\'slave_errormanagement_gui\'); '."\n"; + 'divShowHideFunc(\'slave_status_href\', \'replication_slave_section\');'."\n". + 'divShowHideFunc(\'slave_control_href\', \'slave_control_gui\');'."\n". + 'divShowHideFunc(\'slave_errormanagement_href\',\'slave_errormanagement_gui\'); '."\n"; $jscode['slave_control_sync'] = - 'divShowHideFunc(\'slave_synchronization_href\', \'slave_synchronization_gui\');'."\n"; + 'divShowHideFunc(\'slave_synchronization_href\', \'slave_synchronization_gui\');'."\n"; /** * returns code for selecting databases * @@ -65,24 +65,24 @@ $jscode['slave_control_sync'] = */ function PMA_replication_db_multibox() { - $multi_values = ''; - $multi_values .= ''; + $multi_values .= "\n"; - foreach ($GLOBALS['pma']->databases as $current_db) { - if (!empty($selectall) || (isset($tmp_select) && strpos(' ' . $tmp_select, '|' . $current_db . '|'))) { - $is_selected = ' selected="selected"'; - } else { - $is_selected = ''; - } - $current_db = htmlspecialchars($current_db); - $multi_values .= ' ' . "\n"; - } // end while - $multi_values .= "\n"; - $multi_values .= ''; - $multi_values .= '
Uncheck all'; - - return $multi_values; + foreach ($GLOBALS['pma']->databases as $current_db) { + if (!empty($selectall) || (isset($tmp_select) && strpos(' ' . $tmp_select, '|' . $current_db . '|'))) { + $is_selected = ' selected="selected"'; + } else { + $is_selected = ''; + } + $current_db = htmlspecialchars($current_db); + $multi_values .= ' ' . "\n"; + } // end while + $multi_values .= "\n"; + $multi_values .= ''; + $multi_values .= '
Uncheck all'; + + return $multi_values; } /** @@ -92,98 +92,105 @@ function PMA_replication_db_multibox() */ function PMA_replication_gui_changemaster($submitname) { - global $username_length; - global $hostname_length; + global $username_length; + global $hostname_length; - echo '
'."\n"; - echo PMA_generate_common_hidden_inputs('', ''); - echo '
'."\n"; - echo ' Slave configuration - change master server'."\n"; - echo $GLOBALS['strSlaveConfigure'].'
'."\n"; - echo '
server-id='.time().'
'."\n"; - echo '
'."\n"; - echo ' '."\n"; - echo ' '."\n"; - echo '
'."\n"; - echo '
'."\n"; - echo ' '."\n"; - echo ' '."\n"; - echo '
'."\n"; - echo '
'."\n"; - echo ' '."\n"; - echo ' '."\n"; - echo '
'."\n"; - echo '
'."\n"; - echo ' '."\n"; - echo ' '."\n"; - echo '
'."\n"; - echo '
'."\n"; - echo ' '."\n"; - echo '
'."\n"; + echo '
'."\n"; + echo PMA_generate_common_hidden_inputs('', ''); + echo '
'."\n"; + echo ' Slave configuration - change master server'."\n"; + echo $GLOBALS['strSlaveConfigure'].'
'."\n"; + echo '
server-id='.time().'
'."\n"; + echo '
'."\n"; + echo ' '."\n"; + echo ' '."\n"; + echo '
'."\n"; + echo '
'."\n"; + echo ' '."\n"; + echo ' '."\n"; + echo '
'."\n"; + echo '
'."\n"; + echo ' '."\n"; + echo ' '."\n"; + echo '
'."\n"; + echo '
'."\n"; + echo ' '."\n"; + echo ' '."\n"; + echo '
'."\n"; + echo '
'."\n"; + echo ' '."\n"; + echo '
'."\n"; } /** - * This function prints out table with replication status. - * - * @param String type - either master or slave - * @param boolean $hidden - if true, then default style is set to hidden, default value false - * @param boolen $title - if true, then title is displayed, default true - */ -function PMA_replication_print_status_table ($type, $hidden=false, $title=true) { - global ${"{$type}_variables"}; - global ${"{$type}_variables_alerts"}; - global ${"{$type}_variables_oks"}; - global ${"server_{$type}_replication"}; - global ${"strReplicationStatus_{$type}"}; - - echo '
'."\n"; - - if ($title) { - echo '

'.${"strReplicationStatus_{$type}"} .'

'."\n"; - } else { - echo '
'."\n"; - } + * This function prints out table with replication status. + * + * @param String type - either master or slave + * @param boolean $hidden - if true, then default style is set to hidden, default value false + * @param boolen $title - if true, then title is displayed, default true + */ +function PMA_replication_print_status_table ($type, $hidden = false, $title = true) { + global ${"{$type}_variables"}; + global ${"{$type}_variables_alerts"}; + global ${"{$type}_variables_oks"}; + global ${"server_{$type}_replication"}; + global ${"strReplicationStatus_{$type}"}; - echo ' '."\n"; - echo ' '."\n"; - echo ' '."\n"; - echo ' '."\n"; - echo ' '."\n"; - echo ' '."\n"; - echo ' '."\n"; - echo ' '."\n"; - - $odd_row = true; - foreach(${"{$type}_variables"} as $variable) { - echo ' '."\n"; - echo ' '."\n"; - echo ' '."\n"; - echo ' '."\n"; + if ($title) { + echo '

'.${"strReplicationStatus_{$type}"} .'

'."\n"; + } else { + echo '
'."\n"; + } + + echo '
'. $GLOBALS['strVar'] .''. $GLOBALS['strValue'] .'
'."\n"; - echo $variable."\n"; - echo ' '."\n"; + echo '
'."\n"; - if (isset(${"{$type}_variables_alerts"}[$variable]) && ${"{$type}_variables_alerts"}[$variable] == ${"server_{$type}_replication"}[0][$variable]) - echo ''."\n"; - if (isset(${"{$type}_variables_oks"}[$variable]) && ${"{$type}_variables_oks"}[$variable] == ${"server_{$type}_replication"}[0][$variable]) - echo ''."\n"; - else - echo ''."\n"; - echo ${"server_{$type}_replication"}[0][$variable]; - echo ''."\n"; - - echo '
'."\n"; + echo ' '."\n"; + echo ' '."\n"; + echo ' '."\n"; + echo ' '."\n"; + echo ' '."\n"; + echo ' '."\n"; + echo ' '."\n"; + + $odd_row = true; + foreach (${"{$type}_variables"} as $variable) { + echo ' '."\n"; + echo ' '."\n"; + echo ' '."\n"; + echo ' '."\n"; + + $odd_row = !$odd_row; + } + + echo ' '."\n"; + echo '
'. $GLOBALS['strVar'] .''. $GLOBALS['strValue'] .'
'."\n"; + echo $variable."\n"; + echo ' '."\n"; + + if (isset(${"{$type}_variables_alerts"}[$variable]) + && ${"{$type}_variables_alerts"}[$variable] == ${"server_{$type}_replication"}[0][$variable] + ) { + echo ''."\n"; + } + + if (isset(${"{$type}_variables_oks"}[$variable]) + && ${"{$type}_variables_oks"}[$variable] == ${"server_{$type}_replication"}[0][$variable] + ) { + echo ''."\n"; + } else { + echo ''."\n"; + } + echo ${"server_{$type}_replication"}[0][$variable]; + echo ''."\n"; + + echo '
'."\n"; + echo '
'."\n"; + echo '
'."\n"; - $odd_row = !$odd_row; - } - - echo ' '."\n"; - echo ' '."\n"; - echo '
'."\n"; - echo ''."\n"; - } ?> diff --git a/server_databases.php b/server_databases.php index 27026c4e2..b8c89922c 100644 --- a/server_databases.php +++ b/server_databases.php @@ -260,24 +260,26 @@ if ($databases_count > 0) { } } foreach ($replication_types as $type) { - if (${"server_{$type}_status"}) { - echo '' . "\n"; - - if (strlen(array_search($current["SCHEMA_NAME"], ${"server_{$type}_Ignore_DB"}))>0) { - echo 'REPLICATED' . "\n"; - } else { - $key = array_search($current["SCHEMA_NAME"], ${"server_{$type}_Do_DB"}); - - if (strlen($key)>0 || (${"server_{$type}_Do_DB"}[0]=="" && count(${"server_{$type}_Do_DB"})==1)) // if ($key != null) did not work for index "0" - echo 'REPLICATED' . "\n"; - else - echo ''; + if (${"server_{$type}_status"}) { + echo '' . "\n"; + + if (strlen(array_search($current["SCHEMA_NAME"], ${"server_{$type}_Ignore_DB"}))>0) { + echo 'REPLICATED' . "\n"; + } else { + $key = array_search($current["SCHEMA_NAME"], ${"server_{$type}_Do_DB"}); + + if (strlen($key) > 0 || (${"server_{$type}_Do_DB"}[0] == "" && count(${"server_{$type}_Do_DB"}) == 1)) { + // if ($key != null) did not work for index "0" + echo 'REPLICATED' . "\n"; + } else { + echo ''; + } + } + + echo ''; } - - echo ''; - } } - + if ($is_superuser) { echo ' ' . "\n" . ' ' . "\n"; + . PMA_getIcon('s_replication.png') + . $GLOBALS['strReplication'] . "\n" + . '' . "\n"; PMA_Message::error('strNoPrivileges')->display(); require_once './libraries/footer.inc.php'; } @@ -42,213 +42,215 @@ if (!$is_superuser) { */ if (isset($GLOBALS['sr_take_action'])) { - $refresh = false; - if (isset($GLOBALS['slave_chagemaster'])) { - $_SESSION['replication']['m_username'] = $sr['username'] = PMA_sqlAddslashes($GLOBALS['username']); - $_SESSION['replication']['m_password'] = $sr['pma_pw'] = PMA_sqlAddslashes($GLOBALS['pma_pw']); - $_SESSION['replication']['m_hostname'] = $sr['hostname'] = PMA_sqlAddslashes($GLOBALS['hostname']); - $_SESSION['replication']['m_port'] = $sr['port'] = PMA_sqlAddslashes($GLOBALS['port']); - $_SESSION['replication']['m_correct'] = ''; - $_SESSION['replication']['sr_action_status'] = 'error'; - $_SESSION['replication']['sr_action_info'] = $strReplicationUnknownError; - $url = $sr['hostname']; - - if ($sr['port']!='') - $url .= ':'.$sr['port']; - - $check_master = null; - error_reporting(0); - $check_master = @mysql_connect($url, $sr['username'], $sr['pma_pw']); - error_reporting(15); - unset($url); - - if (!$check_master) { - $_SESSION['replication']['sr_action_status'] = 'error'; - $_SESSION['replication']['sr_action_info'] = 'Unable to connect to master '. $sr['hostname'] .'. '; - } else { - $link_to_master = PMA_replication_connect_to_master($sr['username'], $sr['pma_pw'], $sr['hostname'], $sr['port']); - $position = PMA_replication_slave_bin_log_master($link_to_master); - - $_SESSION['replication']['m_correct'] = true; - - if (PMA_replication_slave_change_master($sr['username'], $sr['pma_pw'], $sr['hostname'], $sr['port'], $position, true, false)) { - $_SESSION['replication']['sr_action_status'] = 'error'; - $_SESSION['replication']['sr_action_info'] = $GLOBALS['strReplicationUnableToChange']; - } else { - $_SESSION['replication']['sr_action_status'] = 'success'; - $_SESSION['replication']['sr_action_info'] = sprintf($GLOBALS['strReplicationChangedSuccesfully'], $sr['hostname']); - } - } - } elseif (isset($GLOBALS['sr_slave_server_control'])) { - if ($GLOBALS['sr_slave_action']=='reset') { - PMA_replication_slave_control("STOP"); - PMA_DBI_try_query("RESET SLAVE;"); - PMA_replication_slave_control("START"); - } else { - PMA_replication_slave_control($GLOBALS['sr_slave_action'], $GLOBALS['sr_slave_control_parm']); - } - $refresh = true; - } elseif (isset($GLOBALS['sr_slave_skip_error'])) { - $count = 1; - if (isset($GLOBALS['sr_skip_errors_count'])) { - $count = $GLOBALS['sr_skip_errors_count']*1; - } - PMA_replication_slave_control("STOP"); - PMA_DBI_try_query("SET GLOBAL SQL_SLAVE_SKIP_COUNTER = ".$count.";"); - PMA_replication_slave_control("START"); - } elseif (isset($GLOBALS['sl_sync'])) { + $refresh = false; + if (isset($GLOBALS['slave_chagemaster'])) { + $_SESSION['replication']['m_username'] = $sr['username'] = PMA_sqlAddslashes($GLOBALS['username']); + $_SESSION['replication']['m_password'] = $sr['pma_pw'] = PMA_sqlAddslashes($GLOBALS['pma_pw']); + $_SESSION['replication']['m_hostname'] = $sr['hostname'] = PMA_sqlAddslashes($GLOBALS['hostname']); + $_SESSION['replication']['m_port'] = $sr['port'] = PMA_sqlAddslashes($GLOBALS['port']); + $_SESSION['replication']['m_correct'] = ''; + $_SESSION['replication']['sr_action_status'] = 'error'; + $_SESSION['replication']['sr_action_info'] = $strReplicationUnknownError; + $url = $sr['hostname']; + + if ($sr['port'] != '') { + $url .= ':' . $sr['port']; + } + + $check_master = null; + error_reporting(0); + $check_master = @mysql_connect($url, $sr['username'], $sr['pma_pw']); + error_reporting(15); + unset($url); + + if (!$check_master) { + $_SESSION['replication']['sr_action_status'] = 'error'; + $_SESSION['replication']['sr_action_info'] = 'Unable to connect to master '. $sr['hostname'] .'. '; + } else { + $link_to_master = PMA_replication_connect_to_master($sr['username'], $sr['pma_pw'], $sr['hostname'], $sr['port']); + $position = PMA_replication_slave_bin_log_master($link_to_master); + + $_SESSION['replication']['m_correct'] = true; + + if (PMA_replication_slave_change_master($sr['username'], $sr['pma_pw'], $sr['hostname'], $sr['port'], $position, true, false)) { + $_SESSION['replication']['sr_action_status'] = 'error'; + $_SESSION['replication']['sr_action_info'] = $GLOBALS['strReplicationUnableToChange']; + } else { + $_SESSION['replication']['sr_action_status'] = 'success'; + $_SESSION['replication']['sr_action_info'] = sprintf($GLOBALS['strReplicationChangedSuccesfully'], $sr['hostname']); + } + } + } elseif (isset($GLOBALS['sr_slave_server_control'])) { + if ($GLOBALS['sr_slave_action'] == 'reset') { + PMA_replication_slave_control("STOP"); + PMA_DBI_try_query("RESET SLAVE;"); + PMA_replication_slave_control("START"); + } else { + PMA_replication_slave_control($GLOBALS['sr_slave_action'], $GLOBALS['sr_slave_control_parm']); + } + $refresh = true; + } elseif (isset($GLOBALS['sr_slave_skip_error'])) { + $count = 1; + if (isset($GLOBALS['sr_skip_errors_count'])) { + $count = $GLOBALS['sr_skip_errors_count'] * 1; + } + PMA_replication_slave_control("STOP"); + PMA_DBI_try_query("SET GLOBAL SQL_SLAVE_SKIP_COUNTER = ".$count.";"); + PMA_replication_slave_control("START"); + } elseif (isset($GLOBALS['sl_sync'])) { $src_link = PMA_replication_connect_to_master($_SESSION['replication']['m_username'], $_SESSION['replication']['m_password'], $_SESSION['replication']['m_hostname'], $_SESSION['replication']['m_port']); $trg_link = null; - + $data = PMA_DBI_fetch_result('SHOW MASTER STATUS', null, null, $src_link); // let's find out, which databases are replicated - - $do_db = array(); - $ignore_db = array(); - - if (!empty($data[0]['Binlog_Do_DB'])) - $do_db = explode($data[0]['Binlog_Do_DB'], ','); - if (!empty($data[0]['Binlog_Ignore_DB'])) - $ignore_db = explode($data[0]['Binlog_Ignore_DB'], ','); + + $do_db = array(); + $ignore_db = array(); + + if (!empty($data[0]['Binlog_Do_DB'])) + $do_db = explode($data[0]['Binlog_Do_DB'], ','); + if (!empty($data[0]['Binlog_Ignore_DB'])) + $ignore_db = explode($data[0]['Binlog_Ignore_DB'], ','); $tmp_alldbs = PMA_DBI_query('SHOW DATABASES;', $src_link); while ($tmp_row = PMA_DBI_fetch_row($tmp_alldbs)) { - if ($tmp_row[0] == 'information_schema') - continue; - if (count($do_db)==0) { - if (array_search($tmp_row[0], $ignore_db)!==false) { - continue; - } - $dblist[] = $tmp_row[0]; - - PMA_DBI_query('CREATE DATABASE IF NOT EXISTS '.$tmp_row[0], $trg_link); - } else { - if (array_search($tmp_row[0], $do_db)!==false) { - $dblist[] = $tmp_row[0]; - PMA_DBI_query('CREATE DATABASE IF NOT EXISTS '.$tmp_row[0], $trg_link); - } - } + if ($tmp_row[0] == 'information_schema') + continue; + if (count($do_db) == 0) { + if (array_search($tmp_row[0], $ignore_db) !== false) { + continue; + } + $dblist[] = $tmp_row[0]; + + PMA_DBI_query('CREATE DATABASE IF NOT EXISTS '.$tmp_row[0], $trg_link); + } else { + if (array_search($tmp_row[0], $do_db) !== false) { + $dblist[] = $tmp_row[0]; + PMA_DBI_query('CREATE DATABASE IF NOT EXISTS '.$tmp_row[0], $trg_link); + } + } } // end while - if (isset($GLOBALS['repl_data'])) - $data = true; - else - $data = false; - foreach ($dblist as $db) { - PMA_replication_synchronize_db($db, $src_link, $trg_link, $data); - } - } - - if ($refresh) - Header("Location: ". PMA_generate_common_url($GLOBALS['url_params'])); - unset($refresh); + if (isset($GLOBALS['repl_data'])) { + $data = true; + } else { + $data = false; + } + foreach ($dblist as $db) { + PMA_replication_synchronize_db($db, $src_link, $trg_link, $data); + } + } + + if ($refresh) + Header("Location: ". PMA_generate_common_url($GLOBALS['url_params'])); + unset($refresh); } /** * Displays the links */ require './libraries/server_links.inc.php'; - echo '
'."\n"; - echo '

'."\n"; - echo ' '."\n"; - echo $GLOBALS['strReplication']."\n"; - echo '

'."\n"; +echo '
'."\n"; +echo '

'."\n"; +echo ' '."\n"; +echo $GLOBALS['strReplication']."\n"; +echo '

'."\n"; - if (isset($_SESSION['replication']['sr_action_status']) && isset($_SESSION['replication']['sr_action_info'])) { - if ($_SESSION['replication']['sr_action_status']=='error') { - PMA_Message::error($_SESSION['replication']['sr_action_info'])->display(); - $_SESSION['replication']['sr_action_status'] = 'unknown'; - } elseif ($_SESSION['replication']['sr_action_status']=='success') { - PMA_Message::success($_SESSION['replication']['sr_action_info'])->display(); - $_SESSION['replication']['sr_action_status'] = 'unknown'; - } - } +if (isset($_SESSION['replication']['sr_action_status']) && isset($_SESSION['replication']['sr_action_info'])) { + if ($_SESSION['replication']['sr_action_status'] == 'error') { + PMA_Message::error($_SESSION['replication']['sr_action_info'])->display(); + $_SESSION['replication']['sr_action_status'] = 'unknown'; + } elseif ($_SESSION['replication']['sr_action_status'] == 'success') { + PMA_Message::success($_SESSION['replication']['sr_action_info'])->display(); + $_SESSION['replication']['sr_action_status'] = 'unknown'; + } +} - if ($server_master_status) { - if (!isset($GLOBALS['repl_clear_scr'])) { - echo PMA_js_mootools_domready($jscode['master_replication']); - echo '
'."\n"; - echo ''. $GLOBALS['strReplicationMaster'] .''."\n"; - echo $GLOBALS['strReplicationConfiguredMaster']."\n"; - echo '
    '."\n"; - echo '
  • '. $GLOBALS['strReplicationShowMasterStatus'] .'
    • '; - PMA_replication_print_status_table('master', true, false); - $_url_params = $GLOBALS['url_params']; - $_url_params['mr_adduser'] = true; - $_url_params['repl_clear_scr'] = true; - - echo '
  • '. $GLOBALS['strReplicationAddSlaveUser'] .'
    • '; - } - if (isset($GLOBALS['mr_adduser'])) { - $fields_info = PMA_DBI_get_fields('mysql', 'user'); - $username_length = 16; - $hostname_length = 41; - foreach ($fields_info as $key => $val) { - if ($val['Field'] == 'User') { - strtok($val['Type'], '()'); - $v = strtok('()'); - if (is_int($v)) { - $username_length = $v; - } - } elseif ($val['Field'] == 'Host') { - strtok($val['Type'], '()'); - $v = strtok('()'); - if (is_int($v)) { - $hostname_length = $v; +if ($server_master_status) { + if (!isset($GLOBALS['repl_clear_scr'])) { + echo PMA_js_mootools_domready($jscode['master_replication']); + echo '
    '."\n"; + echo ''. $GLOBALS['strReplicationMaster'] .''."\n"; + echo $GLOBALS['strReplicationConfiguredMaster']."\n"; + echo '
      '."\n"; + echo '
    • '. $GLOBALS['strReplicationShowMasterStatus'] .'
      • '; + PMA_replication_print_status_table('master', true, false); + $_url_params = $GLOBALS['url_params']; + $_url_params['mr_adduser'] = true; + $_url_params['repl_clear_scr'] = true; + + echo '
    • '. $GLOBALS['strReplicationAddSlaveUser'] .'
      • '; + } + if (isset($GLOBALS['mr_adduser'])) { + $fields_info = PMA_DBI_get_fields('mysql', 'user'); + $username_length = 16; + $hostname_length = 41; + foreach ($fields_info as $key => $val) { + if ($val['Field'] == 'User') { + strtok($val['Type'], '()'); + $v = strtok('()'); + if (is_int($v)) { + $username_length = $v; + } + } elseif ($val['Field'] == 'Host') { + strtok($val['Type'], '()'); + $v = strtok('()'); + if (is_int($v)) { + $hostname_length = $v; + } } } - } - unset($fields_info); + unset($fields_info); - if (isset($GLOBALS['username']) && strlen($GLOBALS['username']) === 0) { - $GLOBALS['pred_username'] = 'any'; - } - echo '
      '."\n"; - echo '
      '."\n"; - echo PMA_generate_common_hidden_inputs('', ''); - echo '
      ' . "\n" - . ''.$GLOBALS['strReplicationAddSlaveUser'].'' . "\n" - . ''. "\n" - . ''. "\n" - . '
      ' . "\n" - . '' . "\n" - . '' . "\n" - . ' ' . "\n" - . '' . "\n" - . ''."\n"; + echo ''."\n"; + echo PMA_generate_common_hidden_inputs('', ''); + echo '
      ' . "\n" + . ''.$GLOBALS['strReplicationAddSlaveUser'].'' . "\n" + . ''. "\n" + . ''. "\n" + . '
      ' . "\n" + . '' . "\n" + . '' . "\n" + . ' ' . "\n" + . '' . "\n" + . '' . "\n" - . '
      ' . "\n" - . '
      ' . "\n" - . '' . "\n" - . '' . "\n" - . ' ' . "\n"; - unset($_current_user); + echo ' onchange="if (this.value == \'any\') { hostname.value = \'%\'; } else if (this.value == \'localhost\') { hostname.value = \'localhost\'; } ' + . (empty($thishost) ? '' : 'else if (this.value == \'thishost\') { hostname.value = \'' . addslashes(htmlspecialchars($thishost)) . '\'; } ') + . 'else if (this.value == \'hosttable\') { hostname.value = \'\'; } else if (this.value == \'userdefined\') { hostname.focus(); hostname.select(); }">' . "\n"; + unset($_current_user); - // when we start editing a user, $GLOBALS['pred_hostname'] is not defined - if (!isset($GLOBALS['pred_hostname']) && isset($GLOBALS['hostname'])) { - switch (strtolower($GLOBALS['hostname'])) { + // when we start editing a user, $GLOBALS['pred_hostname'] is not defined + if (!isset($GLOBALS['pred_hostname']) && isset($GLOBALS['hostname'])) { + switch (strtolower($GLOBALS['hostname'])) { case 'localhost': case '127.0.0.1': $GLOBALS['pred_hostname'] = 'localhost'; @@ -259,230 +261,238 @@ require './libraries/server_links.inc.php'; default: $GLOBALS['pred_hostname'] = 'userdefined'; break; + } } - } - echo ' ' . "\n" - . ' ' . "\n"; - if (!empty($thishost)) { - echo ' ' . "\n"; - } - unset($thishost); - echo ' ' . "\n"; + } + unset($thishost); + echo ' ' . "\n" - . ' ' . "\n" - . ' ' . "\n" - . '' . "\n" - . '' . "\n" - . PMA_showHint($GLOBALS['strHostTableExplanation']) - . '
      ' . "\n" - . '
      ' . "\n" - . '' . "\n" - . '' . "\n" - . ' ' . "\n" + . '' . "\n" + . '' . "\n" + . PMA_showHint($GLOBALS['strHostTableExplanation']) + . '
      ' . "\n" + . '
      ' . "\n" + . '' . "\n" + . '' . "\n" + . ' ' . "\n" + . '' . "\n" + . '' . "\n" + . '
      ' . "\n" + . '
      ' . "\n" + . '' . "\n" + . ' ' . "\n" + . '' . "\n" + . '
      ' . "\n" + . '
      ' . "\n" + . '' . "\n" + . '' . "\n" + . ' ' . "\n" + . '' . "\n" + . '' . "\n" + . '
      ' . "\n" + . '
      ' . "\n"; + echo '' . "\n"; + echo ''."\n"; + echo '
      '."\n";/////// + } elseif (!isset($GLOBALS['repl_clear_scr'])) { + echo "
    \n"; + echo '
    '."\n"; } - echo '>' . $GLOBALS['strNoPassword'] . '' . "\n" - . ' ' . "\n" - . ' ' . "\n" - . '' . "\n" - . '' . "\n" - . '
' . "\n" - . '
' . "\n" - . '' . "\n" - . ' ' . "\n" - . '' . "\n" - . '
' . "\n" - . '
' . "\n" - . '' . "\n" - . '' . "\n" - . ' ' . "\n" - . '' . "\n" - . '' . "\n" - . '
' . "\n" - . '' . "\n"; - echo '' . "\n"; - echo ''."\n"; - echo '
'."\n";/////// - } elseif (!isset($GLOBALS['repl_clear_scr'])) { - echo "\n"; - echo ''."\n"; - } } elseif (!isset($GLOBALS['mr_configure']) && !isset($GLOBALS['repl_clear_scr'])) { - $_url_params = $GLOBALS['url_params']; - $_url_params['mr_configure'] = true; + $_url_params = $GLOBALS['url_params']; + $_url_params['mr_configure'] = true; - echo '
'."\n"; - echo ''. $GLOBALS['strReplicationMaster'] .''."\n"; - echo sprintf($GLOBALS['strReplicationServernConfiguredMaster'], PMA_generate_common_url($_url_params)) ."\n"; - echo '
'."\n"; + echo '
'."\n"; + echo ''. $GLOBALS['strReplicationMaster'] .''."\n"; + echo sprintf($GLOBALS['strReplicationServernConfiguredMaster'], PMA_generate_common_url($_url_params)) ."\n"; + echo '
'."\n"; } if (isset($GLOBALS['mr_configure'])) { - echo PMA_js_mootools_domready($jscode['configure_master']); - echo '
'."\n"; - echo ''. $GLOBALS['strReplicationMasterConfiguration'] .''."\n"; - echo $GLOBALS['strReplicationMasterChooseMode'].'

'."\n"; + echo PMA_js_mootools_domready($jscode['configure_master']); + echo '
'."\n"; + echo ''. $GLOBALS['strReplicationMasterConfiguration'] .''."\n"; + echo $GLOBALS['strReplicationMasterChooseMode'].'

'."\n"; - echo ''."\n"; - echo '

'."\n"; - echo $GLOBALS['strReplicationSelectDatabases'].'
'."\n"; - echo PMA_replication_db_multibox(); - echo '

'."\n"; - echo $GLOBALS['strReplicationAddLines'].'
'."\n"; - echo '
server-id='. $serverid .'
log-bin=mysql-bin
log-error=mysql-bin.err
'."\n"; - echo $GLOBALS['strReplicationRestartServer'] ."\n"; - echo '
'."\n"; - echo '
'; - echo '
'."\n"; - echo PMA_generate_common_hidden_inputs('', ''); - echo ' '; - echo '
'."\n"; - echo '
'; - - require_once './libraries/footer.inc.php'; - exit; + echo ''."\n"; + echo '

'."\n"; + echo $GLOBALS['strReplicationSelectDatabases'].'
'."\n"; + echo PMA_replication_db_multibox(); + echo '

'."\n"; + echo $GLOBALS['strReplicationAddLines'].'
'."\n"; + echo '
server-id='. $serverid .'
log-bin=mysql-bin
log-error=mysql-bin.err
'."\n"; + echo $GLOBALS['strReplicationRestartServer'] ."\n"; + echo '
'."\n"; + echo '
'; + echo '
'."\n"; + echo PMA_generate_common_hidden_inputs('', ''); + echo ' '; + echo '
'."\n"; + echo '
'; + + require_once './libraries/footer.inc.php'; + exit; } echo ''; if (!isset($GLOBALS['repl_clear_scr'])) { - echo '
'."\n"; - echo 'Server Replication'."\n"; - if ($server_slave_status) { - echo PMA_js_mootools_domready($jscode['slave_control']); - echo '
'."\n"; + echo '
'."\n"; + echo 'Server Replication'."\n"; + if ($server_slave_status) { + echo PMA_js_mootools_domready($jscode['slave_control']); + echo '
'."\n"; - $_url_params = $GLOBALS['url_params']; - $_url_params['sr_take_action'] = true; - $_url_params['sr_slave_server_control'] = true; - - if ($server_slave_replication[0]['Slave_IO_Running']=='No') - $_url_params['sr_slave_action'] = 'start'; - else - $_url_params['sr_slave_action'] = 'stop'; - $_url_params['sr_slave_control_parm'] = 'IO_THREAD'; - $slave_control_io_link = PMA_generate_common_url($_url_params); - - if ($server_slave_replication[0]['Slave_SQL_Running']=='No') - $_url_params['sr_slave_action'] = 'start'; - else - $_url_params['sr_slave_action'] = 'stop'; - $_url_params['sr_slave_control_parm'] = 'SQL_THREAD'; - $slave_control_sql_link = PMA_generate_common_url($_url_params); - - if ($server_slave_replication[0]['Slave_IO_Running']=='No' || $server_slave_replication[0]['Slave_SQL_Running']=='No') - $_url_params['sr_slave_action'] = 'start'; - else - $_url_params['sr_slave_action'] = 'stop'; - $_url_params['sr_slave_control_parm'] = null; - $slave_control_full_link = PMA_generate_common_url($_url_params); - - $_url_params['sr_slave_action'] = 'reset'; - $slave_control_reset_link = PMA_generate_common_url($_url_params); - - $_url_params = $GLOBALS['url_params']; - $_url_params['sr_slave_skip_error'] = true; - $slave_skip_error_link = PMA_generate_common_url($_url_params); - - if ($server_slave_replication[0]['Slave_SQL_Running']=='No') - PMA_Message::warning('Slave SQL Thread not running!')->display(); - if ($server_slave_replication[0]['Slave_IO_Running']=='No') - PMA_Message::warning('Slave IO Thread not running!')->display(); - - $_url_params = $GLOBALS['url_params']; - $_url_params['sl_configure'] = true; - $_url_params['repl_clear_scr'] = true; - - $reconfiguremaster_link = PMA_generate_common_url($_url_params); - - echo $GLOBALS['strReplicationSlaveConfigured']."\n"; - echo '
'."\n"; - echo ''."\n"; - - } elseif (!isset($GLOBALS['sl_configure'])) { - $_url_params = $GLOBALS['url_params']; - $_url_params['sl_configure'] = true; - $_url_params['repl_clear_scr'] = true; - - echo sprintf($GLOBALS['strReplicationSlaveNotConfigured'], PMA_generate_common_url($_url_params))."\n"; - } - echo '
'."\n"; + echo '
'."\n"; } if (isset($GLOBALS['sl_configure'])) { - PMA_replication_gui_changemaster("slave_chagemaster"); + PMA_replication_gui_changemaster("slave_chagemaster"); } echo ''."\n"; require_once './libraries/footer.inc.php'; diff --git a/server_status.php b/server_status.php index 693110352..46858621a 100644 --- a/server_status.php +++ b/server_status.php @@ -351,17 +351,17 @@ echo sprintf($strServerStatusUptime, ' . $type . ' '; + if (${"server_{$type}_status"}) + { + if ($replicationOut != "") + $replicationOut .= $strAndSmall . ' '; + $replicationOut .= '' . $type . ' '; + } } - } - echo sprintf('

' . $strReplicationStatusInfo . '

', $replicationOut); + echo sprintf('

' . $strReplicationStatusInfo . '

', $replicationOut); } ?> @@ -700,19 +700,19 @@ unset($section_name, $section, $sections, $server_status, $odd_row, $alerts); /* if the server works as master or slave in replication process, display useful information */ if ($server_master_status || $server_slave_status) { - ?> +?>

-