The branch, master has been updated
via cbca7757387adb91e77a61c3bf673b3d0692d482 (commit)
from 3e342bceace595aaa5b34227618c65c5a3651814 (commit)
- Log -----------------------------------------------------------------
commit cbca7757387adb91e77a61c3bf673b3d0692d482
Author: Dieter Adriaenssens <ruleant(a)users.sourceforge.net>
Date: Wed Aug 17 00:09:17 2011 +0200
coding style and wrapping long lines
-----------------------------------------------------------------------
Summary of changes:
libraries/import.lib.php | 25 ++-
server_privileges.php | 32 ++--
server_synchronize.php | 384 +++++++++++++++++++++++++++++-----------------
3 files changed, 277 insertions(+), 164 deletions(-)
diff --git a/libraries/import.lib.php b/libraries/import.lib.php
index eda224f..0d0239c 100644
--- a/libraries/import.lib.php
+++ b/libraries/import.lib.php
@@ -97,16 +97,21 @@ function PMA_importRunQuery($sql = '', $full = '', $controluser = false)
$sql_query .= $import_run_buffer['full'];
}
if (!$cfg['AllowUserDropDatabase']
- && !$is_superuser
- && preg_match('@^[[:space:]]*DROP[[:space:]]+(IF EXISTS[[:space:]]+)?DATABASE @i', $import_run_buffer['sql'])) {
+ && !$is_superuser
+ && preg_match('@^[[:space:]]*DROP[[:space:]]+(IF EXISTS[[:space:]]+)?DATABASE @i', $import_run_buffer['sql'])
+ ) {
$GLOBALS['message'] = PMA_Message::error(__('"DROP DATABASE" statements are disabled.'));
$error = true;
} else {
$executed_queries++;
- if ($run_query && $GLOBALS['finished'] && empty($sql) && !$error && (
- (!empty($import_run_buffer['sql']) && preg_match('/^[\s]*(SELECT|SHOW|HANDLER)/i', $import_run_buffer['sql'])) ||
- ($executed_queries == 1)
- )) {
+ if ($run_query
+ && $GLOBALS['finished']
+ && empty($sql)
+ && !$error
+ && ((!empty($import_run_buffer['sql'])
+ && preg_match('/^[\s]*(SELECT|SHOW|HANDLER)/i', $import_run_buffer['sql']))
+ || ($executed_queries == 1))
+ ) {
$go_sql = true;
if (!$sql_query_disabled) {
$complete_query = $sql_query;
@@ -161,13 +166,15 @@ function PMA_importRunQuery($sql = '', $full = '', $controluser = false)
list($db, $reload) = PMA_lookForUse($import_run_buffer['sql'], $db, $reload);
}
- if ($result != false && preg_match('@^[\s]*(DROP|CREATE)[\s]+(IF EXISTS[[:space:]]+)?(TABLE|DATABASE)[[:space:]]+(.+)@im', $import_run_buffer['sql'])) {
+ if ($result != false
+ && preg_match('@^[\s]*(DROP|CREATE)[\s]+(IF EXISTS[[:space:]]+)?(TABLE|DATABASE)[[:space:]]+(.+)@im', $import_run_buffer['sql'])
+ ) {
$reload = true;
}
} // end run query
} // end if not DROP DATABASE
- } // end non empty query
- elseif (!empty($import_run_buffer['full'])) {
+ // end non empty query
+ } elseif (!empty($import_run_buffer['full'])) {
if ($go_sql) {
$complete_query .= $import_run_buffer['full'];
$display_query .= $import_run_buffer['full'];
diff --git a/server_privileges.php b/server_privileges.php
index f085889..78e4f06 100644
--- a/server_privileges.php
+++ b/server_privileges.php
@@ -325,14 +325,15 @@ function PMA_extractPrivInfo($row = '', $enableHTML = false)
$allPrivileges = true;
foreach ($grants as $current_grant) {
if ((!empty($row) && isset($row[$current_grant[0]]))
- || (empty($row) && isset($GLOBALS[$current_grant[0]]))) {
+ || (empty($row) && isset($GLOBALS[$current_grant[0]]))
+ ) {
if ((!empty($row) && $row[$current_grant[0]] == 'Y')
- || (empty($row)
- && ($GLOBALS[$current_grant[0]] == 'Y'
- || (is_array($GLOBALS[$current_grant[0]])
+ || (empty($row)
+ && ($GLOBALS[$current_grant[0]] == 'Y'
+ || (is_array($GLOBALS[$current_grant[0]])
&& count($GLOBALS[$current_grant[0]]) == $GLOBALS['column_count']
- && empty($GLOBALS[$current_grant[0] . '_none'])))))
- {
+ && empty($GLOBALS[$current_grant[0] . '_none']))))
+ ) {
if ($enableHTML) {
$privs[] = '<dfn title="' . $current_grant[2] . '">' . $current_grant[1] . '</dfn>';
} else {
@@ -678,8 +679,7 @@ function PMA_displayPrivTable($db = '*', $table = '*', $submit = true)
foreach ($privTable as $i => $table) {
echo ' <fieldset>' . "\n"
. ' <legend>' . __($privTable_names[$i]) . '</legend>' . "\n";
- foreach ($table as $priv)
- {
+ foreach ($table as $priv) {
echo ' <div class="item">' . "\n"
. ' <input type="checkbox"'
. ' name="' . $priv[0] . '_priv" id="checkbox_' . $priv[0] . '_priv"'
@@ -1218,10 +1218,10 @@ if (!empty($update_privs)) {
* @todo similar code appears twice in this script
*/
if ((isset($Grant_priv) && $Grant_priv == 'Y')
- || (! isset($dbname)
- && (isset($max_questions) || isset($max_connections)
- || isset($max_updates) || isset($max_user_connections))))
- {
+ || (! isset($dbname)
+ && (isset($max_questions) || isset($max_connections)
+ || isset($max_updates) || isset($max_user_connections)))
+ ) {
$sql_query2 .= 'WITH';
if (isset($Grant_priv) && $Grant_priv == 'Y') {
$sql_query2 .= ' GRANT OPTION';
@@ -1463,8 +1463,7 @@ if ($GLOBALS['is_ajax_request'] && ! isset($_REQUEST['export']) && (! isset($_RE
if (!empty($password) || isset($pma_pw)) {
$new_user_string .= __('Yes');
- }
- else {
+ } else {
$new_user_string .= '<span style="color: #FF0000">' . __('No') . '</span>';
};
@@ -1474,8 +1473,7 @@ if ($GLOBALS['is_ajax_request'] && ! isset($_REQUEST['export']) && (! isset($_RE
if ((isset($Grant_priv) && $Grant_priv == 'Y')) {
$new_user_string .= __('Yes');
- }
- else {
+ } else {
$new_user_string .= __('No');
}
@@ -2381,7 +2379,7 @@ if (empty($_REQUEST['adduser']) && (! isset($checkprivs) || ! strlen($checkprivs
$extra_data['user_form'] = $user_form;
$message = PMA_Message::success(__('User has been added.'));
PMA_ajaxResponse($message, $message->isSuccess(), $extra_data);
- }else{
+ } else {
// Offer to create a new user for the current database
$user_form .= '<fieldset id="fieldset_add_user">' . "\n"
. ' <a href="server_privileges.php?' . $GLOBALS['url_query'] . '&adduser=1&dbname=' . htmlspecialchars($checkprivs) .'" val="'.'checkprivs='.htmlspecialchars($checkprivs). '&'.$GLOBALS['url_query'] . '" class="'.$conditional_class.'" name="db_specific">' . "\n"
diff --git a/server_synchronize.php b/server_synchronize.php
index 28a7193..9ba41b7 100644
--- a/server_synchronize.php
+++ b/server_synchronize.php
@@ -73,15 +73,22 @@ if ((isset($_REQUEST['submit_connect']))) {
${"{$con}_server"}['socket'] = ${"{$con}_socket"};
} else {
${"{$con}_server"}['host'] = ${"{$con}_host"};
- if (isset(${"{$con}_port"}) && ! empty(${"{$con}_port"}) && ((int)${"{$con}_port"} * 1) > 0) {
+ if (isset(${"{$con}_port"})
+ && ! empty(${"{$con}_port"})
+ && ((int)${"{$con}_port"} * 1) > 0
+ ) {
${"{$con}_server"}['port'] = (int)${"{$con}_port"};
}
}
- ${"{$con}_connection"} = PMA_DBI_connect(${"{$con}_username"}, ${"{$con}_password"}, $is_controluser = false, ${"{$con}_server"}, $auxiliary_connection = true);
+ ${"{$con}_connection"} = PMA_DBI_connect(${"{$con}_username"},
+ ${"{$con}_password"}, $is_controluser = false,
+ ${"{$con}_server"}, $auxiliary_connection = true);
} // end foreach ($cons as $con)
- if ((! $src_connection && $src_type != 'cur') || (! $trg_connection && $trg_type != 'cur')) {
+ if ((! $src_connection && $src_type != 'cur')
+ || (! $trg_connection && $trg_type != 'cur')
+ ) {
/**
* Displays the connection error string if
* connections are not established
@@ -104,7 +111,8 @@ if ((isset($_REQUEST['submit_connect']))) {
*/
foreach ($cons as $con) {
if (${"{$con}_connection"} != null) {
- ${"{$con}_link"} = PMA_DBI_connect(${"{$con}_username"}, ${"{$con}_password"}, $is_controluser = false, ${"{$con}_server"});
+ ${"{$con}_link"} = PMA_DBI_connect(${"{$con}_username"},
+ ${"{$con}_password"}, $is_controluser = false, ${"{$con}_server"});
} else {
${"{$con}_link"} = null;
}
@@ -192,27 +200,36 @@ if ((isset($_REQUEST['submit_connect']))) {
for ($i = 0; $i < sizeof($matching_tables); $i++) {
/**
- * Finding out all the differences structure, data and index diff for all the matching tables only
+ * Finding out all the differences structure, data and index diff
+ * for all the matching tables only
*/
- 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);
-
- 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, $i);
-
- 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, $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);
+
+ 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, $i);
+
+ 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, $i);
}
for ($j = 0; $j < sizeof($source_tables_uncommon); $j++) {
/**
- * Finding out the number of rows to be added in tables that need to be added in target database
+ * Finding out the number of rows to be added in tables
+ * that need to be added in target database
*/
- PMA_dataDiffInUncommonTables($source_tables_uncommon, $src_db, $src_link, $j, $row_count);
+ PMA_dataDiffInUncommonTables($source_tables_uncommon, $src_db,
+ $src_link, $j, $row_count);
}
/**
- * Storing all arrays in session for use when page is reloaded for each button press
+ * Storing all arrays in session for use when page is reloaded
+ * for each button press
*/
$_SESSION['matching_tables'] = $matching_tables;
$_SESSION['update_array'] = $update_array;
@@ -250,7 +267,8 @@ if ((isset($_REQUEST['submit_connect']))) {
$_SESSION['target_indexes'] = $target_indexes;
/**
- * Displays the sub-heading and icons showing Structure Synchronization and Data Synchronization
+ * Displays the sub-heading and icons showing Structure Synchronization
+ * and Data Synchronization
*/
?>
<form name="synchronize_form" id="synchronize_form" method="post" action="server_synchronize.php">
@@ -269,7 +287,8 @@ if ((isset($_REQUEST['submit_connect']))) {
</table>
<?php
/**
- * Displays the tables containing the source tables names, their difference with the target tables and target tables names
+ * Displays the tables containing the source tables names,
+ * their difference with the target tables and target tables names.
*/
PMA_syncDisplayHeaderCompare($src_db, $trg_db);
$rows = array();
@@ -300,7 +319,8 @@ if ((isset($_REQUEST['submit_connect']))) {
}
/**
- * Calculating the number of alter columns, number of columns to be added, number of columns to be removed,
+ * Calculating the number of alter columns, number of columns to be
+ * added, number of columns to be removed,
* number of index to be added and removed.
*/
$num_alter_cols = 0;
@@ -333,19 +353,32 @@ if ((isset($_REQUEST['submit_connect']))) {
$btn_data_params = null;
/**
- * Display the red button of structure synchronization if there exists any structure difference or index difference.
+ * Display the red button of structure synchronization if there
+ * exists any structure difference or index difference.
*/
- if (($num_alter_cols > 0) || ($num_insert_cols > 0) || ($num_remove_cols > 0) || ($num_add_index > 0) || ($num_remove_index > 0)) {
+ if (($num_alter_cols > 0)
+ || ($num_insert_cols > 0)
+ || ($num_remove_cols > 0)
+ || ($num_add_index > 0)
+ || ($num_remove_index > 0)
+ ) {
$btn_structure_params = array($i, $num_alter_cols, $num_insert_cols,
$num_remove_cols, $num_add_index, $num_remove_index);
}
/**
- * Display the green button of data synchronization if there exists any data difference.
+ * Display the green button of data synchronization if there exists
+ * any data difference.
*/
- if ((isset($update_array[$i]) || isset($insert_array[$i])) && !empty($matching_tables_keys[$i])) {
- if (isset($update_array[$i][0][$matching_tables_keys[$i][0]]) || isset($insert_array[$i][0][$matching_tables_keys[$i][0]])) {
- $btn_data_params = array($i, $num_of_updates, $num_of_insertions, null, null, null);
+ if ((isset($update_array[$i])
+ || isset($insert_array[$i]))
+ && !empty($matching_tables_keys[$i])
+ ) {
+ if (isset($update_array[$i][0][$matching_tables_keys[$i][0]])
+ || isset($insert_array[$i][0][$matching_tables_keys[$i][0]])
+ ) {
+ $btn_data_params = array($i, $num_of_updates,
+ $num_of_insertions, null, null, null);
}
}
@@ -387,8 +420,10 @@ if ((isset($_REQUEST['submit_connect']))) {
</fieldset>';
/**
- * This "list" div will contain a table and each row will depict information about structure/data diffrence in tables.
- * Rows will be generated dynamically as soon as the colored buttons "D" or "S" are clicked.
+ * This "list" div will contain a table and each row will depict
+ * information about structure/data difference in tables.
+ * Rows will be generated dynamically as soon as the colored
+ * buttons "D" or "S" are clicked.
*/
echo '<fieldset style="padding:0"><div id="list" style="overflow:auto; height:140px; padding:1em">
@@ -419,12 +454,17 @@ if ((isset($_REQUEST['submit_connect']))) {
* This fieldset displays the checkbox to confirm deletion of previous rows from target tables
*/
echo '<fieldset>
- <p><input type= "checkbox" name="delete_rows" id ="delete_rows" /><label for="delete_rows">' . __('Would you like to delete all the previous rows from target tables?') . '</label> </p>
+ <p><input type= "checkbox" name="delete_rows" id ="delete_rows" /><label for="delete_rows">'
+ . __('Would you like to delete all the previous rows from target tables?')
+ . '</label> </p>
</fieldset>
<fieldset class="tblFooters">';
- echo '<input type="button" name="apply_changes" value="' . __('Apply Selected Changes')
- . '" onclick ="ApplySelectedChanges(' . "'" . htmlspecialchars($_SESSION['token']) . "'" . ')" />';
- echo '<input type="submit" name="synchronize_db" value="' . __('Synchronize Databases') . '" />' . '</fieldset>';
+ echo '<input type="button" name="apply_changes" value="'
+ . __('Apply Selected Changes')
+ . '" onclick ="ApplySelectedChanges('
+ . "'" . htmlspecialchars($_SESSION['token']) . "'" . ')" />';
+ echo '<input type="submit" name="synchronize_db" value="'
+ . __('Synchronize Databases') . '" />' . '</fieldset>';
echo '</form>';
}
}
@@ -437,7 +477,9 @@ if (isset($_REQUEST['Table_ids'])) {
/**
* Displays success message
*/
- echo '<div class="success">' . __('Selected target tables have been synchronized with source tables.') . '</div>';
+ echo '<div class="success">'
+ . __('Selected target tables have been synchronized with source tables.')
+ . '</div>';
$src_db = $_SESSION['src_db'];
$trg_db = $_SESSION['trg_db'];
@@ -480,7 +522,8 @@ if (isset($_REQUEST['Table_ids'])) {
*/
foreach ($cons as $con) {
if (${"{$con}_type"} != "cur") {
- ${"{$con}_link"} = PMA_DBI_connect(${"{$con}_username"}, ${"{$con}_password"}, $is_controluser = false, ${"{$con}_server"});
+ ${"{$con}_link"} = PMA_DBI_connect(${"{$con}_username"},
+ ${"{$con}_password"}, $is_controluser = false, ${"{$con}_server"});
} else {
${"{$con}_link"} = null;
// working on current server, so initialize this for tracking
@@ -521,42 +564,49 @@ if (isset($_REQUEST['Table_ids'])) {
/**
* Applying the structure difference on selected matching tables
*/
- for ($q = 0; $q < sizeof($matching_table_structure_diff); $q++)
- {
+ for ($q = 0; $q < sizeof($matching_table_structure_diff); $q++) {
if (isset($alter_str_array[$matching_table_structure_diff[$q]])) {
-
- PMA_alterTargetTableStructure($trg_db, $trg_link, $matching_tables, $source_columns, $alter_str_array, $matching_tables_fields,
- $criteria, $matching_tables_keys, $target_tables_keys, $matching_table_structure_diff[$q], false);
+ PMA_alterTargetTableStructure($trg_db, $trg_link, $matching_tables,
+ $source_columns, $alter_str_array, $matching_tables_fields,
+ $criteria, $matching_tables_keys, $target_tables_keys,
+ $matching_table_structure_diff[$q], false);
unset($alter_str_array[$matching_table_structure_diff[$q]]);
}
if (isset($add_column_array[$matching_table_structure_diff[$q]])) {
-
- PMA_findDeleteRowsFromTargetTables($delete_array, $matching_tables, $matching_table_structure_diff[$q], $target_tables_keys,
- $matching_tables_keys, $trg_db, $trg_link, $src_db, $src_link);
+ PMA_findDeleteRowsFromTargetTables($delete_array, $matching_tables,
+ $matching_table_structure_diff[$q], $target_tables_keys,
+ $matching_tables_keys, $trg_db, $trg_link, $src_db, $src_link);
if (isset($delete_array[$matching_table_structure_diff[$q]])) {
-
- PMA_deleteFromTargetTable($trg_db, $trg_link, $matching_tables, $matching_table_structure_diff[$q], $target_tables_keys, $delete_array, false);
+ PMA_deleteFromTargetTable($trg_db, $trg_link, $matching_tables,
+ $matching_table_structure_diff[$q], $target_tables_keys,
+ $delete_array, false);
unset($delete_array[$matching_table_structure_diff[$q]]);
}
- PMA_addColumnsInTargetTable($src_db, $trg_db,$src_link, $trg_link, $matching_tables, $source_columns, $add_column_array, $matching_tables_fields,
- $criteria, $matching_tables_keys, $target_tables_keys, $uncommon_tables,$uncommon_tables_fields, $matching_table_structure_diff[$q], $uncommon_cols, false);
+ PMA_addColumnsInTargetTable($src_db, $trg_db,$src_link, $trg_link,
+ $matching_tables, $source_columns, $add_column_array,
+ $matching_tables_fields, $criteria, $matching_tables_keys,
+ $target_tables_keys, $uncommon_tables,$uncommon_tables_fields,
+ $matching_table_structure_diff[$q], $uncommon_cols, false);
unset($add_column_array[$matching_table_structure_diff[$q]]);
}
if (isset($uncommon_columns[$matching_table_structure_diff[$q]])) {
-
- PMA_removeColumnsFromTargetTable($trg_db, $trg_link, $matching_tables, $uncommon_columns, $matching_table_structure_diff[$q], false);
+ PMA_removeColumnsFromTargetTable($trg_db, $trg_link, $matching_tables,
+ $uncommon_columns, $matching_table_structure_diff[$q], false);
unset($uncommon_columns[$matching_table_structure_diff[$q]]);
}
- if (isset($add_indexes_array[$matching_table_structure_diff[$q]]) || isset($remove_indexes_array[$matching_table_structure_diff[$q]])
- || isset($alter_indexes_array[$matching_table_structure_diff[$q]])) {
-
- PMA_applyIndexesDiff ($trg_db, $trg_link, $matching_tables, $source_indexes, $target_indexes, $add_indexes_array, $alter_indexes_array,
- $remove_indexes_array, $matching_table_structure_diff[$q], false);
+ if (isset($add_indexes_array[$matching_table_structure_diff[$q]])
+ || isset($remove_indexes_array[$matching_table_structure_diff[$q]])
+ || isset($alter_indexes_array[$matching_table_structure_diff[$q]])
+ ) {
+ PMA_applyIndexesDiff ($trg_db, $trg_link, $matching_tables,
+ $source_indexes, $target_indexes, $add_indexes_array,
+ $alter_indexes_array, $remove_indexes_array,
+ $matching_table_structure_diff[$q], false);
unset($add_indexes_array[$matching_table_structure_diff[$q]]);
unset($alter_indexes_array[$matching_table_structure_diff[$q]]);
@@ -567,55 +617,65 @@ if (isset($_REQUEST['Table_ids'])) {
* Applying the data difference. First checks if structure diff is applied or not.
* If not, then apply structure difference first then apply data difference.
*/
- for ($p = 0; $p < sizeof($matching_table_data_diff); $p++)
- {
+ for ($p = 0; $p < sizeof($matching_table_data_diff); $p++) {
if ($_REQUEST['checked'] == 'true') {
-
- PMA_findDeleteRowsFromTargetTables($delete_array, $matching_tables, $matching_table_data_diff[$p], $target_tables_keys,
- $matching_tables_keys, $trg_db, $trg_link, $src_db, $src_link);
+ PMA_findDeleteRowsFromTargetTables($delete_array, $matching_tables,
+ $matching_table_data_diff[$p], $target_tables_keys,
+ $matching_tables_keys, $trg_db, $trg_link, $src_db, $src_link);
if (isset($delete_array[$matching_table_data_diff[$p]])) {
-
- PMA_deleteFromTargetTable($trg_db, $trg_link, $matching_tables, $matching_table_data_diff[$p], $target_tables_keys, $delete_array, false);
+ PMA_deleteFromTargetTable($trg_db, $trg_link, $matching_tables,
+ $matching_table_data_diff[$p], $target_tables_keys,
+ $delete_array, false);
unset($delete_array[$matching_table_data_diff[$p]]);
}
}
if (isset($alter_str_array[$matching_table_data_diff[$p]])) {
-
- PMA_alterTargetTableStructure($trg_db, $trg_link, $matching_tables, $source_columns, $alter_str_array, $matching_tables_fields,
- $criteria, $matching_tables_keys, $target_tables_keys, $matching_table_data_diff[$p], false);
+ PMA_alterTargetTableStructure($trg_db, $trg_link, $matching_tables,
+ $source_columns, $alter_str_array, $matching_tables_fields,
+ $criteria, $matching_tables_keys, $target_tables_keys,
+ $matching_table_data_diff[$p], false);
unset($alter_str_array[$matching_table_data_diff[$p]]);
}
if (isset($add_column_array[$matching_table_data_diff[$p]])) {
-
- PMA_findDeleteRowsFromTargetTables($delete_array, $matching_tables, $matching_table_data_diff[$p], $target_tables_keys,
- $matching_tables_keys, $trg_db, $trg_link, $src_db, $src_link);
+ PMA_findDeleteRowsFromTargetTables($delete_array, $matching_tables,
+ $matching_table_data_diff[$p], $target_tables_keys,
+ $matching_tables_keys, $trg_db, $trg_link, $src_db, $src_link);
if (isset($delete_array[$matching_table_data_diff[$p]])) {
-
- PMA_deleteFromTargetTable($trg_db, $trg_link, $matching_tables, $matching_table_data_diff[$p], $target_tables_keys, $delete_array, false);
+ PMA_deleteFromTargetTable($trg_db, $trg_link, $matching_tables,
+ $matching_table_data_diff[$p], $target_tables_keys,
+ $delete_array, false);
unset($delete_array[$matching_table_data_diff[$p]]);
}
- PMA_addColumnsInTargetTable($src_db, $trg_db,$src_link, $trg_link, $matching_tables, $source_columns, $add_column_array, $matching_tables_fields,
- $criteria, $matching_tables_keys, $target_tables_keys, $uncommon_tables, $uncommon_tables_fields, $matching_table_data_diff[$p], $uncommon_cols, false);
+ PMA_addColumnsInTargetTable($src_db, $trg_db,$src_link, $trg_link,
+ $matching_tables, $source_columns, $add_column_array,
+ $matching_tables_fields, $criteria, $matching_tables_keys,
+ $target_tables_keys, $uncommon_tables, $uncommon_tables_fields,
+ $matching_table_data_diff[$p], $uncommon_cols, false);
unset($add_column_array[$matching_table_data_diff[$p]]);
}
if (isset($uncommon_columns[$matching_table_data_diff[$p]])) {
-
- PMA_removeColumnsFromTargetTable($trg_db, $trg_link, $matching_tables, $uncommon_columns, $matching_table_data_diff[$p], false);
+ PMA_removeColumnsFromTargetTable($trg_db, $trg_link, $matching_tables,
+ $uncommon_columns, $matching_table_data_diff[$p], false);
unset($uncommon_columns[$matching_table_data_diff[$p]]);
}
- if ((isset($matching_table_structure_diff[$q]) && isset($add_indexes_array[$matching_table_structure_diff[$q]]))
- || (isset($matching_table_structure_diff[$q]) && isset($remove_indexes_array[$matching_table_structure_diff[$q]]))
- || (isset($matching_table_structure_diff[$q]) && isset($alter_indexes_array[$matching_table_structure_diff[$q]]))) {
-
- PMA_applyIndexesDiff ($trg_db, $trg_link, $matching_tables, $source_indexes, $target_indexes, $add_indexes_array, $alter_indexes_array,
- $remove_indexes_array, $matching_table_structure_diff[$q], false);
+ if ((isset($matching_table_structure_diff[$q])
+ && isset($add_indexes_array[$matching_table_structure_diff[$q]]))
+ || (isset($matching_table_structure_diff[$q])
+ && isset($remove_indexes_array[$matching_table_structure_diff[$q]]))
+ || (isset($matching_table_structure_diff[$q])
+ && isset($alter_indexes_array[$matching_table_structure_diff[$q]]))
+ ) {
+ PMA_applyIndexesDiff ($trg_db, $trg_link, $matching_tables,
+ $source_indexes, $target_indexes, $add_indexes_array,
+ $alter_indexes_array, $remove_indexes_array,
+ $matching_table_structure_diff[$q], false);
unset($add_indexes_array[$matching_table_structure_diff[$q]]);
unset($alter_indexes_array[$matching_table_structure_diff[$q]]);
@@ -624,12 +684,16 @@ if (isset($_REQUEST['Table_ids'])) {
/**
* Applying the data difference.
*/
- PMA_updateTargetTables($matching_tables, $update_array, $src_db, $trg_db, $trg_link, $matching_table_data_diff[$p], $matching_tables_keys, false);
-
- PMA_insertIntoTargetTable($matching_tables, $src_db, $trg_db, $src_link, $trg_link , $matching_tables_fields, $insert_array,
- $matching_table_data_diff[$p], $matching_tables_keys, $source_columns, $add_column_array, $criteria, $target_tables_keys,
- $uncommon_tables, $uncommon_tables_fields, $uncommon_cols, $alter_str_array, $source_indexes, $target_indexes, $add_indexes_array,
- $alter_indexes_array, $delete_array, $update_array, false);
+ PMA_updateTargetTables($matching_tables, $update_array, $src_db, $trg_db,
+ $trg_link, $matching_table_data_diff[$p], $matching_tables_keys, false);
+
+ PMA_insertIntoTargetTable($matching_tables, $src_db, $trg_db, $src_link,
+ $trg_link, $matching_tables_fields, $insert_array,
+ $matching_table_data_diff[$p], $matching_tables_keys, $source_columns,
+ $add_column_array, $criteria, $target_tables_keys, $uncommon_tables,
+ $uncommon_tables_fields, $uncommon_cols, $alter_str_array,
+ $source_indexes, $target_indexes, $add_indexes_array,
+ $alter_indexes_array, $delete_array, $update_array, false);
}
/**
* Updating the session variables to the latest values of the arrays.
@@ -644,32 +708,35 @@ if (isset($_REQUEST['Table_ids'])) {
$_SESSION['update_array'] = $update_array;
/**
- * Applying structure difference to selected non-matching tables (present in Source but absent from Target).
+ * Applying structure difference to selected non-matching tables
+ * (present in Source but absent from Target).
*/
- for ($s = 0; $s < sizeof($uncommon_table_structure_diff); $s++)
- {
- PMA_createTargetTables($src_db, $trg_db, $src_link, $trg_link, $uncommon_tables, $uncommon_table_structure_diff[$s], $uncommon_tables_fields, false);
+ for ($s = 0; $s < sizeof($uncommon_table_structure_diff); $s++) {
+ PMA_createTargetTables($src_db, $trg_db, $src_link, $trg_link,
+ $uncommon_tables, $uncommon_table_structure_diff[$s],
+ $uncommon_tables_fields, false);
$_SESSION['uncommon_tables_fields'] = $uncommon_tables_fields;
unset($uncommon_tables[$uncommon_table_structure_diff[$s]]);
}
/**
- * Applying data difference to selected non-matching tables (present in Source but absent from Target).
+ * Applying data difference to selected non-matching tables
+ * (present in Source but absent from Target).
* Before data synchronization, structure synchronization is confirmed.
*/
- for ($r = 0; $r < sizeof($uncommon_table_data_diff); $r++)
- {
+ for ($r = 0; $r < sizeof($uncommon_table_data_diff); $r++) {
if (!(in_array($uncommon_table_data_diff[$r], $uncommon_table_structure_diff))) {
if (isset($uncommon_tables[$uncommon_table_data_diff[$r]])) {
-
- PMA_createTargetTables($src_db, $trg_db, $src_link, $trg_link, $uncommon_tables, $uncommon_table_data_diff[$r],
+ PMA_createTargetTables($src_db, $trg_db, $src_link, $trg_link,
+ $uncommon_tables, $uncommon_table_data_diff[$r],
$uncommon_tables_fields, false);
$_SESSION['uncommon_tables_fields'] = $uncommon_tables_fields;
unset($uncommon_tables[$uncommon_table_data_diff[$r]]);
}
}
- PMA_populateTargetTables($src_db, $trg_db, $src_link, $trg_link, $source_tables_uncommon, $uncommon_table_data_diff[$r],
+ PMA_populateTargetTables($src_db, $trg_db, $src_link, $trg_link,
+ $source_tables_uncommon, $uncommon_table_data_diff[$r],
$_SESSION['uncommon_tables_fields'], false);
unset($row_count[$uncommon_table_data_diff[$r]]);
@@ -709,13 +776,19 @@ if (isset($_REQUEST['Table_ids'])) {
$btn_structure_params = null;
$btn_data_params = null;
- if (($num_alter_cols > 0) || ($num_insert_cols > 0) || ($num_remove_cols > 0) || ($num_add_index > 0) || ($num_remove_index > 0)) {
+ if (($num_alter_cols > 0)
+ || ($num_insert_cols > 0)
+ || ($num_remove_cols > 0)
+ || ($num_add_index > 0)
+ || ($num_remove_index > 0)
+ ) {
$btn_structure_params = array($i, $num_alter_cols, $num_insert_cols,
$num_remove_cols, $num_add_index, $num_remove_index);
}
if (!(in_array($i, $matching_table_data_diff))) {
-
- if (isset($matching_tables_keys[$i][0]) && isset($update_array[$i][0][$matching_tables_keys[$i][0]])) {
+ if (isset($matching_tables_keys[$i][0])
+ && isset($update_array[$i][0][$matching_tables_keys[$i][0]])
+ ) {
if (isset($update_array[$i])) {
$num_of_updates = sizeof($update_array[$i]);
} else {
@@ -724,7 +797,9 @@ if (isset($_REQUEST['Table_ids'])) {
} else {
$num_of_updates = 0;
}
- if (isset($matching_tables_keys[$i][0]) && isset($insert_array[$i][0][$matching_tables_keys[$i][0]])) {
+ if (isset($matching_tables_keys[$i][0])
+ && isset($insert_array[$i][0][$matching_tables_keys[$i][0]])
+ ) {
if (isset($insert_array[$i])) {
$num_of_insertions = sizeof($insert_array[$i]);
} else {
@@ -734,8 +809,11 @@ if (isset($_REQUEST['Table_ids'])) {
$num_of_insertions = 0;
}
- if ((isset($matching_tables_keys[$i][0]) && isset($update_array[$i][0][$matching_tables_keys[$i][0]]))
- || (isset($matching_tables_keys[$i][0]) && isset($insert_array[$i][0][$matching_tables_keys[$i][0]]))) {
+ if ((isset($matching_tables_keys[$i][0])
+ && isset($update_array[$i][0][$matching_tables_keys[$i][0]]))
+ || (isset($matching_tables_keys[$i][0])
+ && isset($insert_array[$i][0][$matching_tables_keys[$i][0]]))
+ ) {
$btn_data_params = array($i, $num_of_updates, $num_of_insertions,
null, null, null);
}
@@ -815,8 +893,10 @@ if (isset($_REQUEST['Table_ids'])) {
</fieldset>';
/**
- * This "list" div will contain a table and each row will depict information about structure/data diffrence in tables.
- * Rows will be generated dynamically as soon as the colored buttons "D" or "S" are clicked.
+ * This "list" div will contain a table and each row will depict information about
+ * structure/data difference in tables.
+ * Rows will be generated dynamically as soon as the colored buttons "D" or "S"
+ * are clicked.
*/
echo '<fieldset style="padding:0"><div id="list" style = "overflow:auto; height:140px; padding:1em">';
@@ -847,14 +927,17 @@ if (isset($_REQUEST['Table_ids'])) {
* This fieldset displays the checkbox to confirm deletion of previous rows from target tables
*/
echo '<fieldset>
- <p><input type="checkbox" name="delete_rows" id ="delete_rows" /><label for="delete_rows">' . __('Would you like to delete all the previous rows from target tables?') . '</label> </p>
- </fieldset>';
+ <p><input type="checkbox" name="delete_rows" id ="delete_rows" /><label for="delete_rows">'
+ . __('Would you like to delete all the previous rows from target tables?') . '</label> </p>
+ </fieldset>';
echo '<fieldset class="tblFooters">';
- echo '<input type="button" name="apply_changes" value="' . __('Apply Selected Changes') . '"
- onclick ="ApplySelectedChanges(' . "'" . htmlspecialchars($_SESSION['token']) . "'" .')" />';
- echo '<input type="submit" name="synchronize_db" value="' . __('Synchronize Databases') . '" />'
- . '</fieldset>';
+ echo '<input type="button" name="apply_changes" value="'
+ . __('Apply Selected Changes') . '" onclick ="ApplySelectedChanges('
+ . "'" . htmlspecialchars($_SESSION['token']) . "'" .')" />';
+ echo '<input type="submit" name="synchronize_db" value="'
+ . __('Synchronize Databases') . '" />'
+ . '</fieldset>';
echo '</form>';
}
@@ -899,14 +982,16 @@ if (isset($_REQUEST['synchronize_db'])) {
/**
* Display success message.
*/
- echo '<div class="success">' . __('Target database has been synchronized with source database') . '</div>';
+ echo '<div class="success">'
+ . __('Target database has been synchronized with source database')
+ . '</div>';
/**
- * Displaying all the tables of source and target database and now no difference is there.
+ * Displaying all the tables of source and target database
+ * and now no difference is there.
*/
PMA_syncDisplayHeaderCompare($src_db, $trg_db);
$rows = array();
- for ($i = 0; $i < count($matching_tables); $i++)
- {
+ for ($i = 0; $i < count($matching_tables); $i++) {
$rows[] = array(
'src_table_name' => $matching_tables[$i],
'dst_table_name' => $matching_tables[$i]);
@@ -930,7 +1015,8 @@ if (isset($_REQUEST['synchronize_db'])) {
* connecting the source and target servers
*/
if ('cur' != $_SESSION['src_type']) {
- $src_link = PMA_DBI_connect($src_username, $src_password, $is_controluser = false, $_SESSION['src_server']);
+ $src_link = PMA_DBI_connect($src_username, $src_password,
+ $is_controluser = false, $_SESSION['src_server']);
} else {
$src_link = $GLOBALS['userlink'];
// working on current server, so initialize this for tracking
@@ -938,7 +1024,8 @@ if (isset($_REQUEST['synchronize_db'])) {
$GLOBALS['db'] = $_SESSION['src_db'];
}
if ('cur' != $_SESSION['trg_type']) {
- $trg_link = PMA_DBI_connect($trg_username, $trg_password, $is_controluser = false, $_SESSION['trg_server']);
+ $trg_link = PMA_DBI_connect($trg_username, $trg_password,
+ $is_controluser = false, $_SESSION['trg_server']);
} else {
$trg_link = $GLOBALS['userlink'];
// working on current server, so initialize this for tracking
@@ -958,65 +1045,83 @@ if (isset($_REQUEST['synchronize_db'])) {
* first find out rows to be deleted and then delete the rows.
*/
if (isset($_REQUEST['delete_rows'])) {
- PMA_findDeleteRowsFromTargetTables($delete_array, $matching_tables, $p, $target_tables_keys, $matching_tables_keys,
+ PMA_findDeleteRowsFromTargetTables($delete_array, $matching_tables, $p,
+ $target_tables_keys, $matching_tables_keys,
$trg_db, $trg_link, $src_db, $src_link);
if (isset($delete_array[$p])) {
- PMA_deleteFromTargetTable($trg_db, $trg_link, $matching_tables, $p, $target_tables_keys, $delete_array, true);
+ PMA_deleteFromTargetTable($trg_db, $trg_link, $matching_tables, $p,
+ $target_tables_keys, $delete_array, true);
unset($delete_array[$p]);
}
}
if (isset($alter_str_array[$p])) {
- PMA_alterTargetTableStructure($trg_db, $trg_link, $matching_tables, $source_columns, $alter_str_array, $matching_tables_fields,
- $criteria, $matching_tables_keys, $target_tables_keys, $p, true);
+ PMA_alterTargetTableStructure($trg_db, $trg_link, $matching_tables,
+ $source_columns, $alter_str_array, $matching_tables_fields,
+ $criteria, $matching_tables_keys, $target_tables_keys, $p, true);
unset($alter_str_array[$p]);
}
if (! empty($add_column_array[$p])) {
- PMA_findDeleteRowsFromTargetTables($delete_array, $matching_tables, $p, $target_tables_keys, $matching_tables_keys,
- $trg_db, $trg_link, $src_db, $src_link);
+ PMA_findDeleteRowsFromTargetTables($delete_array, $matching_tables, $p,
+ $target_tables_keys, $matching_tables_keys,
+ $trg_db, $trg_link, $src_db, $src_link);
if (isset($delete_array[$p])) {
- PMA_deleteFromTargetTable($trg_db, $trg_link, $matching_tables, $p, $target_tables_keys, $delete_array, true);
+ PMA_deleteFromTargetTable($trg_db, $trg_link, $matching_tables, $p,
+ $target_tables_keys, $delete_array, true);
unset($delete_array[$p]);
}
- PMA_addColumnsInTargetTable($src_db, $trg_db, $src_link, $trg_link, $matching_tables, $source_columns, $add_column_array,
- $matching_tables_fields, $criteria, $matching_tables_keys, $target_tables_keys, $uncommon_tables, $uncommon_tables_fields,
+ PMA_addColumnsInTargetTable($src_db, $trg_db, $src_link, $trg_link,
+ $matching_tables, $source_columns, $add_column_array,
+ $matching_tables_fields, $criteria, $matching_tables_keys,
+ $target_tables_keys, $uncommon_tables, $uncommon_tables_fields,
$p, $uncommon_cols, true);
unset($add_column_array[$p]);
}
if (isset($uncommon_columns[$p])) {
- PMA_removeColumnsFromTargetTable($trg_db, $trg_link, $matching_tables, $uncommon_columns, $p, true);
+ PMA_removeColumnsFromTargetTable($trg_db, $trg_link, $matching_tables,
+ $uncommon_columns, $p, true);
unset($uncommon_columns[$p]);
}
- if (isset($matching_table_structure_diff) &&
- (isset($add_indexes_array[$matching_table_structure_diff[$p]])
+ if (isset($matching_table_structure_diff)
+ && (isset($add_indexes_array[$matching_table_structure_diff[$p]])
|| isset($remove_indexes_array[$matching_table_structure_diff[$p]])
- || isset($alter_indexes_array[$matching_table_structure_diff[$p]]))) {
- PMA_applyIndexesDiff ($trg_db, $trg_link, $matching_tables, $source_indexes, $target_indexes, $add_indexes_array, $alter_indexes_array,
- $remove_indexes_array, $matching_table_structure_diff[$p], true);
+ || isset($alter_indexes_array[$matching_table_structure_diff[$p]]))
+ ) {
+ PMA_applyIndexesDiff ($trg_db, $trg_link, $matching_tables,
+ $source_indexes, $target_indexes, $add_indexes_array,
+ $alter_indexes_array, $remove_indexes_array,
+ $matching_table_structure_diff[$p], true);
unset($add_indexes_array[$matching_table_structure_diff[$p]]);
unset($alter_indexes_array[$matching_table_structure_diff[$p]]);
unset($remove_indexes_array[$matching_table_structure_diff[$p]]);
}
- PMA_updateTargetTables($matching_tables, $update_array, $src_db, $trg_db, $trg_link, $p, $matching_tables_keys, true);
+ PMA_updateTargetTables($matching_tables, $update_array, $src_db, $trg_db,
+ $trg_link, $p, $matching_tables_keys, true);
- PMA_insertIntoTargetTable($matching_tables, $src_db, $trg_db, $src_link, $trg_link , $matching_tables_fields, $insert_array, $p,
- $matching_tables_keys, $matching_tables_keys, $source_columns, $add_column_array, $criteria, $target_tables_keys, $uncommon_tables,
- $uncommon_tables_fields,$uncommon_cols, $alter_str_array,$source_indexes, $target_indexes, $add_indexes_array,
+ PMA_insertIntoTargetTable($matching_tables, $src_db, $trg_db, $src_link,
+ $trg_link , $matching_tables_fields, $insert_array, $p,
+ $matching_tables_keys, $matching_tables_keys, $source_columns,
+ $add_column_array, $criteria, $target_tables_keys, $uncommon_tables,
+ $uncommon_tables_fields,$uncommon_cols, $alter_str_array,$source_indexes,
+ $target_indexes, $add_indexes_array,
$alter_indexes_array, $delete_array, $update_array, true);
}
/**
- * Creating and populating tables present in source but absent from target database.
+ * Creating and populating tables present in source but absent
+ * from target database.
*/
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, true);
+ PMA_createTargetTables($src_db, $trg_db, $src_link, $trg_link,
+ $source_tables_uncommon, $q, $uncommon_tables_fields, true);
}
if (isset($row_count[$q])) {
- PMA_populateTargetTables($src_db, $trg_db, $src_link, $trg_link, $source_tables_uncommon, $q, $uncommon_tables_fields, true);
+ PMA_populateTargetTables($src_db, $trg_db, $src_link, $trg_link,
+ $source_tables_uncommon, $q, $uncommon_tables_fields, true);
}
}
echo "</fieldset>";
@@ -1026,8 +1131,10 @@ if (isset($_REQUEST['synchronize_db'])) {
* Displays the main page when none of the following buttons is pressed
*/
- if (! isset($_REQUEST['submit_connect']) && ! isset($_REQUEST['synchronize_db']) && ! isset($_REQUEST['Table_ids']) )
-{
+if (! isset($_REQUEST['submit_connect'])
+ && ! isset($_REQUEST['synchronize_db'])
+ && ! isset($_REQUEST['Table_ids'])
+) {
/**
* Displays the sub-page heading
*/
@@ -1063,7 +1170,8 @@ if (isset($_REQUEST['synchronize_db'])) {
$database_header = __('Target database');
}
- $database_header .= PMA_showHint(PMA_sanitize(sprintf('%sAllowArbitraryServer%s', '[a@./Documentation.html#AllowArbitraryServer@_blank]', '[/a]')));
+ $database_header .= PMA_showHint(PMA_sanitize(sprintf('%sAllowArbitraryServer%s',
+ '[a@./Documentation.html#AllowArbitraryServer@_blank]', '[/a]')));
?>
<table id="serverconnection_<?php echo $type; ?>_remote" class="data noclick">
<caption class="tblHeaders"><?php echo $database_header; ?></caption>
hooks/post-receive
--
phpMyAdmin
