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

Merge branch 'main' into lie_tests_using_containers

Browse source
This commit is contained in:
Laurent Indermuehle 2023-01-25 09:50:50 +01:00
commit f1749db40a
No known key found for this signature in database
GPG key ID: 93FA944C9F34DD09
5 changed files with 37 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

12
plugins/module_utils/mysql.py
View file

@ -35,6 +35,8 @@ mysql_driver_fail_msg = ('A MySQL module is required: for Python 2.7 either PyMy
'Consider setting ansible_python_interpreter to use '
'the intended Python version.')
from ansible_collections.community.mysql.plugins.module_utils.database import mysql_quote_identifier
def get_driver_name(mysql_driver):
""" (class) -> str
@ -192,3 +194,13 @@ def get_server_version(cursor):
version_str = result[0]
return version_str
def set_session_vars(module, cursor, session_vars):
"""Set session vars."""
for var, value in session_vars.items():
query = "SET SESSION %s = " % mysql_quote_identifier(var, 'vars')
try:
cursor.execute(query + "%s", (value,))
except Exception as e:
module.fail_json(msg='Failed to execute %s%s: %s' % (query, value, e))