connection arguments: fix KeyError

This commit is contained in:
Felix Hamme 2023-05-16 17:31:39 +02:00
commit 5256d97e25

View file

@ -145,14 +145,14 @@ def mysql_connect(module, login_user=None, login_password=None, config_file='',
# In case of PyMySQL driver: # In case of PyMySQL driver:
if mysql_driver.version_info[0] < 1: if mysql_driver.version_info[0] < 1:
# for PyMySQL < 1.0.0, use 'db' instead of 'database' # for PyMySQL < 1.0.0, use 'db' instead of 'database'
config['db'] = config['database'] config['db'] = config.get('database')
del config['database'] del config['database']
db_connection = mysql_driver.connect(autocommit=autocommit, **config) db_connection = mysql_driver.connect(autocommit=autocommit, **config)
else: else:
# In case of MySQLdb driver # In case of MySQLdb driver
if mysql_driver.version_info[0] < 2 or mysql_driver.version_info[1] < 1: if mysql_driver.version_info[0] < 2 or mysql_driver.version_info[1] < 1:
# for MySQLdb < 2.1.0, use 'db' instead of 'database' # for MySQLdb < 2.1.0, use 'db' instead of 'database'
config['db'] = config['database'] config['db'] = config.get('database')
del config['database'] del config['database']
db_connection = mysql_driver.connect(**config) db_connection = mysql_driver.connect(**config)
if autocommit: if autocommit: