Added exception handling to database creation and deletion. Fixes #8075.

reviewable/pr18780/r1
Graham Mainwaring 11 years ago
parent 3d2b201cf9
commit 6e237bed7a

@ -319,7 +319,10 @@ def main():
changed = False
if db_exists(cursor, db):
if state == "absent":
changed = db_delete(cursor, db)
try:
changed = db_delete(cursor, db)
except Exception, e:
module.fail_json(msg="error deleting database: " + str(e))
elif state == "dump":
rc, stdout, stderr = db_dump(module, login_host, login_user,
login_password, db, target,
@ -340,7 +343,10 @@ def main():
module.exit_json(changed=True, db=db, msg=stdout)
else:
if state == "present":
changed = db_create(cursor, db, encoding, collation)
try:
changed = db_create(cursor, db, encoding, collation)
except Exception, e:
module.fail_json(msg="error creating database: " + str(e))
module.exit_json(changed=changed, db=db)

Loading…
Cancel
Save