summaryrefslogtreecommitdiff
path: root/database/mysql
diff options
context:
space:
mode:
Diffstat (limited to 'database/mysql')
-rw-r--r--database/mysql/mysql_replication.py9
1 files changed, 4 insertions, 5 deletions
diff --git a/database/mysql/mysql_replication.py b/database/mysql/mysql_replication.py
index f75d6a05..70e226a6 100644
--- a/database/mysql/mysql_replication.py
+++ b/database/mysql/mysql_replication.py
@@ -317,7 +317,6 @@ def main():
module.fail_json(msg="Server is not configured as mysql slave")
elif mode in "changemaster":
- print "Change master"
chm=[]
chm_params = {}
if master_host:
@@ -329,22 +328,22 @@ def main():
if master_password:
chm.append("MASTER_PASSWORD=%(master_password)s")
chm_params['master_password'] = master_password
- if master_port:
+ if master_port is not None:
chm.append("MASTER_PORT=%(master_port)s")
chm_params['master_port'] = master_port
- if master_connect_retry:
+ if master_connect_retry is not None:
chm.append("MASTER_CONNECT_RETRY=%(master_connect_retry)s")
chm_params['master_connect_retry'] = master_connect_retry
if master_log_file:
chm.append("MASTER_LOG_FILE=%(master_log_file)s")
chm_params['master_log_file'] = master_log_file
- if master_log_pos:
+ if master_log_pos is not None:
chm.append("MASTER_LOG_POS=%(master_log_pos)s")
chm_params['master_log_pos'] = master_log_pos
if relay_log_file:
chm.append("RELAY_LOG_FILE=%(relay_log_file)s")
chm_params['relay_log_file'] = relay_log_file
- if relay_log_pos:
+ if relay_log_pos is not None:
chm.append("RELAY_LOG_POS=%(relay_log_pos)s")
chm_params['relay_log_pos'] = relay_log_pos
if master_ssl: