libraries/replication.inc.php

   1 <?php
   2 /* vim: set expandtab sw=4 ts=4 sts=4: */
   3 /**
   4  *
   5  * @version $Id$
   6  * @package phpMyAdmin
   7  */
   8
   9 if (! defined('PHPMYADMIN')) {
  10     exit;
  11 }
  12
  13 /**
  14  * get master replication from server
  15  */
  16 $server_master_replication = PMA_DBI_fetch_result('SHOW MASTER STATUS');
  17
  18 /**
  19  * get slave replication from server
  20  */
  21 $server_slave_replication = PMA_DBI_fetch_result('SHOW SLAVE STATUS');
  22
  23 /**
  24  * replication types
  25  */
  26 $replication_types = array('master', 'slave');
  27
  28
  29 /**
  30  * define variables for master status
  31  */
  32 $master_variables = array(
  33     'File',
  34     'Position',
  35     'Binlog_Do_DB',
  36     'Binlog_Ignore_DB',
  37 );
  38
  39 /**
  40  * Define variables for slave status
  41  */
  42 $slave_variables  = array(
  43     'Slave_IO_State',
  44     'Master_Host',
  45     'Master_User',
  46     'Master_Port',
  47     'Connect_Retry',
  48     'Master_Log_File',
  49     'Read_Master_Log_Pos',
  50     'Relay_Log_File',
  51     'Relay_Log_Pos',
  52     'Relay_Master_Log_File',
  53     'Slave_IO_Running',
  54     'Slave_SQL_Running',
  55     'Replicate_Do_DB',
  56     'Replicate_Ignore_DB',
  57     'Replicate_Do_Table',
  58     'Replicate_Ignore_Table',
  59     'Replicate_Wild_Do_Table',
  60     'Replicate_Wild_Ignore_Table',
  61     'Last_Errno',
  62     'Last_Error',
  63     'Skip_Counter',
  64     'Exec_Master_Log_Pos',
  65     'Relay_Log_Space',
  66     'Until_Condition',
  67     'Until_Log_File',
  68     'Until_Log_Pos',
  69     'Master_SSL_Allowed',
  70     'Master_SSL_CA_File',
  71     'Master_SSL_CA_Path',
  72     'Master_SSL_Cert',
  73     'Master_SSL_Cipher',
  74     'Master_SSL_Key',
  75     'Seconds_Behind_Master',
  76 );
  77 /**
  78  * define important variables, which need to be watched for correct running of replication in slave mode
  79  *
  80  * @usedby PMA_replication_print_status_table()
  81  */
  82 // TODO change to regexp or something, to allow for negative match. To e.g. highlight 'Last_Error'
  83 //
  84 $slave_variables_alerts = array(
  85     'Slave_IO_Running' => 'No',
  86     'Slave_SQL_Running' => 'No',
  87 );
  88 $slave_variables_oks = array(
  89     'Slave_IO_Running' => 'Yes',
  90     'Slave_SQL_Running' => 'Yes',
  91 );
  92
  93 $serverid = time();
  94
  95 // check which replication is available and set $server_{master/slave}_status and assign values
  96 foreach ($replication_types as $type) {
  97     if (count(${"server_{$type}_replication"}) > 0)
  98         ${"server_{$type}_status"} = true;
  99     else
 100         ${"server_{$type}_status"} = false;
 101
 102     if (${"server_{$type}_status"}) {
 103         if ($type == "master") {
 104             ${"server_{$type}_Do_DB"} = explode (",", $server_master_replication[0]["Binlog_Do_DB"]);
 105             ${"server_{$type}_Ignore_DB"} = explode (",", $server_master_replication[0]["Binlog_Ignore_DB"]);
 106         } elseif ($type == "slave") {
 107             ${"server_{$type}_Do_DB"} = explode (",", $server_slave_replication[0]["Replicate_Do_DB"]);
 108             ${"server_{$type}_Ignore_DB"} = explode (",", $server_slave_replication[0]["Replicate_Ignore_DB"]);
 109
 110             ${"server_{$type}_Do_Table"} = explode (",", $server_slave_replication[0]["Replicate_Do_Table"]);
 111             ${"server_{$type}_Ignore_Table"} = explode (",", $server_slave_replication[0]["Replicate_Ignore_Table"]);
 112
 113             ${"server_{$type}_Wild_Do_Table"} = explode (",", $server_slave_replication[0]["Replicate_Wild_Do_Table"]);
 114             ${"server_{$type}_Wild_Ignore_Table"} = explode (",", $server_slave_replication[0]["Replicate_Wild_Ignore_Table"]);
 115         }
 116     }
 117 }
 118
 119
 120 /**
 121  * @param $string -
 122  * @param $table -
 123  * @return
 124  */
 125 function PMA_replication_strout($string, $table = false) {
 126     $list = explode(".", $string);
 127
 128     return $list[(int)$table];
 129 }
 130 /**
 131  * @param String $action - possible values: START or STOP
 132  * @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
 133  * @param mixed  $link   - mysql link
 134  *
 135  * @return mixed output of PMA_DBI_try_query
 136  */
 137 function PMA_replication_slave_control ($action, $control = null, $link = null)
 138 {
 139     $action = strtoupper($action);
 140     $control = strtoupper($control);
 141
 142
 143     if ($action != "START" && $action != "STOP") {
 144         return -1;
 145     }
 146     if ($control != "SQL_THREAD" && $control != "IO_THREAD" && $control != null) {
 147         return -1;
 148     }
 149
 150     return PMA_DBI_try_query($action." SLAVE ".$control.";", $link);
 151 }
 152 /**
 153  * @param String $user - replication user on master
 154  * @param String $password - password for the user
 155  * @param String $host - master's hostname or IP
 156  * @param int $port - port, where mysql is running
 157  * @param array $pos - position of mysql replication, array should contain fields File and Position
 158  * @param boolean $stop - shall we stop slave?
 159  * @param boolean $start - shall we start slave?
 160  * @param mixed $link - mysql link
 161  *
 162  * @return output of CHANGE MASTER mysql command
 163  */
 164 function PMA_replication_slave_change_master($user, $password, $host, $port, $pos, $stop = true, $start = true, $link = null)
 165 {
 166     if ($stop) {
 167         PMA_replication_slave_control("STOP", null, $link);
 168     }
 169
 170     $out = PMA_DBI_try_query('CHANGE MASTER TO '.
 171         'MASTER_HOST=\''.$host.'\','.
 172         'MASTER_PORT='.($port*1).','.
 173         'MASTER_USER=\''.$user.'\','.
 174         'MASTER_PASSWORD=\''.$password.'\','.
 175         'MASTER_LOG_FILE=\''.$pos["File"].'\','.
 176         'MASTER_LOG_POS='.$pos["Position"].';', $link);
 177
 178     if ($start) {
 179         PMA_replication_slave_control("START", null, $link);
 180     }
 181
 182     return $out;
 183 }
 184
 185 /**
 186  * This function provides connection to remote mysql server
 187  *
 188  * @param String $user - mysql username
 189  * @param String $password - password for the user
 190  * @param String $host - mysql server's hostname or IP
 191  * @param int $port - mysql remote port
 192  * @param String $socket - path to unix socket
 193  *
 194  * @return mixed $link mysql link on success
 195  */
 196 function PMA_replication_connect_to_master($user, $password, $host = null, $port = null, $socket = null)
 197 {
 198     $server = array();
 199     $server["host"] = $host;
 200     $server["port"] = $port;
 201     $server["socket"] = $socket;
 202
 203     return PMA_DBI_connect($user, $password, false, $server);
 204 }
 205 /**
 206  * @param $link - mysql link
 207  *
 208  * @return array - containing File and Position in MySQL replication on master server, useful for PMA_replication_slave_change_master
 209  */
 210 function PMA_replication_slave_bin_log_master($link = null)
 211 {
 212     $data = PMA_DBI_fetch_result('SHOW MASTER STATUS', null, null, $link);
 213     $output = array();
 214
 215     if (!empty($data)) {
 216         $output["File"] = $data[0]["File"];
 217         $output["Position"] = $data[0]["Position"];
 218     }
 219     return $output;
 220 }
 221
 222 /**
 223  * Get list of replicated databases on master server
 224  *
 225  * @param mixed mysql link
 226  *
 227  * @return array array of replicated databases
 228  */
 229
 230 function PMA_replication_master_replicated_dbs($link = null)
 231 {
 232     $data = PMA_DBI_fetch_result('SHOW MASTER STATUS', null, null, $link); // let's find out, which databases are replicated
 233
 234     $do_db     = array();
 235     $ignore_db = array();
 236
 237     if (!empty($data[0]['Binlog_Do_DB'])) {
 238         $do_db     = explode(',', $data[0]['Binlog_Do_DB']);
 239     }
 240     if (!empty($data[0]['Binlog_Ignore_DB'])) {
 241         $ignore_db = explode(',', $data[0]['Binlog_Ignore_DB']);
 242     }
 243
 244     $tmp_alldbs = PMA_DBI_query('SHOW DATABASES;', $link);
 245     while ($tmp_row = PMA_DBI_fetch_row($tmp_alldbs)) {
 246         if ($tmp_row[0] == 'information_schema')
 247             continue;
 248         if (count($do_db) == 0) {
 249             if (array_search($tmp_row[0], $ignore_db) !== false) {
 250                 continue;
 251             }
 252             $dblist[] = $tmp_row[0];
 253
 254         } else {
 255             if (array_search($tmp_row[0], $do_db) !== false) {
 256                 $dblist[] = $tmp_row[0];
 257             }
 258         }
 259     } // end while
 260
 261     return $link;
 262 }
 263 /**
 264  * This function provides synchronization of structure and data between two mysql servers.
 265  * TODO: improve code sharing between the function and synchronization
 266  *
 267  * @param String $db - name of database, which should be synchronized
 268  * @param mixed $src_link - link of source server, note: if the server is current PMA server, use null
 269  * @param mixed $trg_link - link of target server, note: if the server is current PMA server, use null
 270  * @param boolean $data - if true, then data will be copied as well
 271  */
 272
 273 function PMA_replication_synchronize_db($db, $src_link, $trg_link, $data = true)
 274 {
 275     $src_db = $trg_db = $db;
 276
 277     $src_connection = PMA_DBI_select_db($src_db, $src_link);
 278     $trg_connection = PMA_DBI_select_db($trg_db, $trg_link);
 279
 280     $src_tables = PMA_DBI_get_tables($src_db, $src_link);
 281     $source_tables_num = sizeof($src_tables);
 282
 283     $trg_tables = PMA_DBI_get_tables($trg_db, $trg_link);
 284     $target_tables_num = sizeof($trg_tables);
 285
 286     /**
 287      * initializing arrays to save table names
 288      */
 289     $unmatched_num_src = 0;
 290     $source_tables_uncommon = array();
 291     $unmatched_num_trg = 0;
 292     $target_tables_uncommon = array();
 293     $matching_tables = array();
 294     $matching_tables_num = 0;
 295
 296     /**
 297      * Criterion for matching tables is just their names.
 298      * Finding the uncommon tables for the source database
 299      * BY comparing the matching tables with all the tables in the source database
 300      */
 301     PMA_getMatchingTables($trg_tables, $src_tables, $matching_tables, $source_tables_uncommon);
 302
 303     /**
 304      * Finding the uncommon tables for the target database
 305      * BY comparing the matching tables with all the tables in the target database
 306      */
 307     PMA_getNonMatchingTargetTables($trg_tables, $matching_tables, $target_tables_uncommon);
 308
 309     /**
 310      *
 311      * ********************************************* Comparing Data In the Matching Tables ******************************************
 312      * *********************It is assumed that the matching tables are structurally and typely exactly the same *********************
 313      */
 314     $fields_num = array();
 315     $matching_tables_fields = array();
 316     $matching_tables_keys   = array();
 317     $insert_array = array(array(array()));
 318     $update_array = array(array(array()));
 319     $delete_array = array();
 320     $row_count = array();
 321     $uncommon_tables_fields = array();
 322     $matching_tables_num = sizeof($matching_tables);
 323
 324     for ($i=0; $i< sizeof($matching_tables); $i++)
 325     {
 326         PMA_dataDiffInTables($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $matching_tables_fields, $update_array, $insert_array,
 327             $delete_array, $fields_num, $i, $matching_tables_keys);
 328     }
 329     for ($j=0; $j< sizeof($source_tables_uncommon); $j++)
 330     {
 331         PMA_dataDiffInUncommonTables($source_tables_uncommon, $src_db, $src_link, $j, $row_count);
 332     }
 333
 334     /**
 335      * INTEGRATION OF STRUCTURE DIFFERENCE CODE
 336      *
 337      */
 338     $source_columns = array();
 339     $target_columns = array();
 340     $alter_str_array = array(array());
 341     $add_column_array = array(array());
 342     $uncommon_columns = array();
 343     $target_tables_keys = array();
 344     $source_indexes = array();
 345     $target_indexes = array();
 346     $add_indexes_array = array();
 347     $remove_indexes_array = array();
 348     $criteria = array('Field', 'Type', 'Null', 'Collation', 'Key', 'Default', 'Comment');
 349
 350     for ($counter = 0; $counter < $matching_tables_num; $counter++)
 351     {
 352         //             PMA_structureDiffInTables($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $source_columns,
 353         //             $target_columns, $alter_str_array, $add_column_array, $uncommon_columns, $criteria, $matching_tables_keys,
 354         //             $target_tables_keys, $matching_tables_fields, $counter);
 355         //
 356         //             PMA_indexesDiffInTables($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $source_indexes, $target_indexes,
 357         //             $add_indexes_array, $remove_indexes_array, $counter);
 358         PMA_structureDiffInTables($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $source_columns,
 359             $target_columns, $alter_str_array, $add_column_array, $uncommon_columns, $criteria, $target_tables_keys, $counter);
 360
 361         PMA_indexesDiffInTables($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $source_indexes, $target_indexes,
 362             $add_indexes_array, $alter_indexes_array,$remove_indexes_array, $counter);
 363     }
 364
 365     $matching_table_data_diff = array();
 366     $matching_table_structure_diff = array();
 367     $uncommon_table_structure_diff = array();
 368     $uncommon_table_data_diff = array();
 369     $uncommon_tables = $source_tables_uncommon;
 370
 371     /**
 372      * Generating Create Table query for all the non-matching tables present in Source but not in Target and populating tables.
 373      */
 374     for($q = 0; $q < sizeof($source_tables_uncommon); $q++)
 375     {
 376         if (isset($uncommon_tables[$q])) {
 377             PMA_createTargetTables($src_db, $trg_db, $src_link, $trg_link, $source_tables_uncommon, $q, $uncommon_tables_fields, false);
 378         }
 379         if (isset($row_count[$q]) && $data) {
 380             PMA_populateTargetTables($src_db, $trg_db, $src_link, $trg_link, $source_tables_uncommon, $q, $uncommon_tables_fields, false);
 381         }
 382     }
 383 }
 384 ?>