ansible-collections/community.mysql
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.mysql.git synced 2025-04-06 10:40:36 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Using show all slaves status whe using MariaDB to be consistent

Browse source 
with the MySQL behaviour.
This commit is contained in:
William Welter 2024-01-04 13:38:38 +00:00
parent 81ab18d56c
commit a7de8f89c4
1 changed files with 26 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
plugins/modules/mysql_info.py
View file

@ -5,6 +5,7 @@
# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt) # GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
from __future__ import absolute_import, division, print_function from __future__ import absolute_import, division, print_function
__metaclass__ = type __metaclass__ = type
DOCUMENTATION = r''' DOCUMENTATION = r'''
@ -325,9 +326,10 @@ class MySQL_Info(object):
5. add info about the new subset with an example to RETURN block 5. add info about the new subset with an example to RETURN block
""" """
def __init__(self, module, cursor): def __init__(self, module, cursor, server_implementation):
self.module = module self.module = module
self.cursor = cursor self.cursor = cursor
self.server_implementation = server_implementation
self.info = { self.info = {
'version': {}, 'version': {},
'databases': {}, 'databases': {},
@ -387,6 +389,18 @@ class MySQL_Info(object):
self.__collect(exclude_fields, return_empty_dbs, set(self.info)) self.__collect(exclude_fields, return_empty_dbs, set(self.info))
return self.info return self.info
def is_mariadb(self):
if self.server_implementation == "mariadb":
return True
else:
return False
def is_mysql(self):
if self.server_implementation == "mysql":
return True
else:
return False
def __collect(self, exclude_fields, return_empty_dbs, wanted): def __collect(self, exclude_fields, return_empty_dbs, wanted):
"""Collect all possible subsets.""" """Collect all possible subsets."""
if 'version' in wanted or 'settings' in wanted: if 'version' in wanted or 'settings' in wanted:
@ -497,7 +511,10 @@ class MySQL_Info(object):
def __get_slave_status(self): def __get_slave_status(self):
"""Get slave status if the instance is a slave.""" """Get slave status if the instance is a slave."""
res = self.__exec_sql('SHOW SLAVE STATUS') if(self.is_mariadb()):
res = self.__exec_sql('SHOW ALL SLAVES STATUS')
else:
res = self.__exec_sql('SHOW SLAVE STATUS')
if res: if res:
for line in res: for line in res:
host = line['Master_Host'] host = line['Master_Host']
@ -738,10 +755,16 @@ def main():
'Exception message: %s' % (connector_name, connector_version, config_file, to_native(e))) 'Exception message: %s' % (connector_name, connector_version, config_file, to_native(e)))
module.fail_json(msg) module.fail_json(msg)
cursor.execute("SELECT VERSION()")
if 'mariadb' in cursor.fetchone()[0].lower():
server_implementation="mariadb"
else:
server_implementation="mysql"
############################### ###############################
# Create object and do main job # Create object and do main job
mysql = MySQL_Info(module, cursor) mysql = MySQL_Info(module, cursor, server_implementation)
module.exit_json(changed=False, module.exit_json(changed=False,
connector_name=connector_name, connector_name=connector_name,