diff options
| author | Jonathan Mainguy <jon@soh.re> | 2014-09-29 19:49:42 -0400 |
|---|---|---|
| committer | Jonathan Mainguy <jon@soh.re> | 2014-12-12 16:10:14 -0500 |
| commit | d611f86e5b3644421b2f24eb1b5af2c6eb7be61d (patch) | |
| tree | 14de30000efa5a81fe1eb4c4070253dc8a5d7744 /database/mysql | |
| parent | b54920ea8f4678c9a086686b778e5a3570687791 (diff) | |
| download | ansible-modules-extras-d611f86e5b3644421b2f24eb1b5af2c6eb7be61d.tar.gz | |
Addes login_port feature, similiar to how mysql_db.py works
Diffstat (limited to 'database/mysql')
| -rw-r--r-- | database/mysql/mysql_replication.py | 17 |
1 files changed, 15 insertions, 2 deletions
diff --git a/database/mysql/mysql_replication.py b/database/mysql/mysql_replication.py index 1d61436a..c5f2cc3a 100644 --- a/database/mysql/mysql_replication.py +++ b/database/mysql/mysql_replication.py @@ -54,6 +54,12 @@ options: description: - mysql host to connect required: False + login_port: + description: + - Port of the MySQL server. Requires login_host be defined as other then localhost if login_port is used + required: False + default: 3306 + version_added: "1.9" login_unix_socket: description: - unix socket to connect mysql server @@ -115,6 +121,9 @@ EXAMPLES = ''' # Change master to master server 192.168.1.1 and use binary log 'mysql-bin.000009' with position 4578 - mysql_replication: mode=changemaster master_host=192.168.1.1 master_log_file=mysql-bin.000009 master_log_pos=4578 + +# Check slave status using port 3308 +- mysql_replication: mode=getslave login_host=ansible.example.com login_port=3308 ''' import ConfigParser @@ -229,6 +238,7 @@ def main(): login_user=dict(default=None), login_password=dict(default=None), login_host=dict(default="localhost"), + login_port=dict(default="3306"), login_unix_socket=dict(default=None), mode=dict(default="getslave", choices=["getmaster", "getslave", "changemaster", "stopslave", "startslave"]), master_host=dict(default=None), @@ -251,6 +261,7 @@ def main(): user = module.params["login_user"] password = module.params["login_password"] host = module.params["login_host"] + port = module.params["login_port"] mode = module.params["mode"] master_host = module.params["master_host"] master_user = module.params["master_user"] @@ -292,8 +303,10 @@ def main(): try: if module.params["login_unix_socket"]: db_connection = MySQLdb.connect(host=module.params["login_host"], unix_socket=module.params["login_unix_socket"], user=login_user, passwd=login_password) + elif module.params["login_port"] != "3306" and module.params["login_host"] == "localhost": + module.fail_json(msg="login_host is required when login_port is defined, login_host cannot be localhost when login_port is defined") else: - db_connection = MySQLdb.connect(host=module.params["login_host"], user=login_user, passwd=login_password) + db_connection = MySQLdb.connect(host=module.params["login_host"], port=int(module.params["login_port"]), user=login_user, passwd=login_password) except Exception, e: module.fail_json(msg="unable to connect to database, check login_user and login_password are correct or ~/.my.cnf has the credentials") try: @@ -366,4 +379,4 @@ def main(): # import module snippets from ansible.module_utils.basic import * main() -warnings.simplefilter("ignore")
\ No newline at end of file +warnings.simplefilter("ignore") |