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

add a get_server_type module_utils method to detect MySQL vs MariaDB

Browse source
This commit is contained in:
Laurent Indermuehle 2023-09-14 15:41:42 +02:00
parent 1e24343375
commit 089e1c3fb1
No known key found for this signature in database
GPG key ID: 93FA944C9F34DD09
3 changed files with 16 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
plugins/module_utils/mysql.py
View file

@ -194,6 +194,16 @@ def mysql_common_argument_spec():
)
def get_server_type(cursor):
""" Return MySQL or MariaDB after quering the server
using SELECT VERSION()"""
srv_ver = get_server_version(cursor)
if 'mariadb' in srv_ver.lower():
return "mariadb"
else:
return "mysql"
def get_server_version(cursor):
"""Returns a string representation of the server version."""
cursor.execute("SELECT VERSION() AS version")

5
plugins/module_utils/user.py
View file

@ -16,6 +16,7 @@ from ansible.module_utils.six import iteritems
from ansible_collections.community.mysql.plugins.module_utils.mysql import (
mysql_driver,
get_server_type,
)
@ -883,8 +884,8 @@ def limit_resources(module, cursor, user, host, resource_limits, check_mode):
def get_impl(cursor):
global impl
cursor.execute("SELECT VERSION()")
if 'mariadb' in cursor.fetchone()[0].lower():
if get_server_type(cursor) == 'mariadb':
from ansible_collections.community.mysql.plugins.module_utils.implementations.mariadb import user as mariauser
impl = mariauser
else:

7
plugins/modules/mysql_role.py
View file

@ -305,7 +305,8 @@ from ansible_collections.community.mysql.plugins.module_utils.mysql import (
mysql_connect,
mysql_driver,
mysql_driver_fail_msg,
mysql_common_argument_spec
mysql_common_argument_spec,
get_server_type
)
from ansible_collections.community.mysql.plugins.module_utils.user import (
convert_priv_dict_to_str,
@ -407,9 +408,7 @@ class DbServer():
Returns:
library: Depending on a server type (MySQL or MariaDB).
"""
self.cursor.execute("SELECT VERSION()")
if 'mariadb' in self.cursor.fetchone()[0].lower():
if get_server_type(cursor) == 'mariadb':
import ansible_collections.community.mysql.plugins.module_utils.implementations.mariadb.role as role_impl
else:
import ansible_collections.community.mysql.plugins.module_utils.implementations.mysql.role as role_impl