|
|
@ -159,7 +159,8 @@ def main():
|
|
|
|
.ISOLATION_LEVEL_AUTOCOMMIT)
|
|
|
|
.ISOLATION_LEVEL_AUTOCOMMIT)
|
|
|
|
cursor = db_connection.cursor(
|
|
|
|
cursor = db_connection.cursor(
|
|
|
|
cursor_factory=psycopg2.extras.DictCursor)
|
|
|
|
cursor_factory=psycopg2.extras.DictCursor)
|
|
|
|
except Exception, e:
|
|
|
|
except Exception:
|
|
|
|
|
|
|
|
e = get_exception()
|
|
|
|
module.fail_json(msg="unable to connect to database: %s" % e)
|
|
|
|
module.fail_json(msg="unable to connect to database: %s" % e)
|
|
|
|
|
|
|
|
|
|
|
|
try:
|
|
|
|
try:
|
|
|
@ -174,14 +175,17 @@ def main():
|
|
|
|
|
|
|
|
|
|
|
|
elif state == "present":
|
|
|
|
elif state == "present":
|
|
|
|
changed = ext_create(cursor, ext)
|
|
|
|
changed = ext_create(cursor, ext)
|
|
|
|
except NotSupportedError, e:
|
|
|
|
except NotSupportedError:
|
|
|
|
|
|
|
|
e = get_exception()
|
|
|
|
module.fail_json(msg=str(e))
|
|
|
|
module.fail_json(msg=str(e))
|
|
|
|
except Exception, e:
|
|
|
|
except Exception:
|
|
|
|
|
|
|
|
e = get_exception()
|
|
|
|
module.fail_json(msg="Database query failed: %s" % e)
|
|
|
|
module.fail_json(msg="Database query failed: %s" % e)
|
|
|
|
|
|
|
|
|
|
|
|
module.exit_json(changed=changed, db=db, ext=ext)
|
|
|
|
module.exit_json(changed=changed, db=db, ext=ext)
|
|
|
|
|
|
|
|
|
|
|
|
# import module snippets
|
|
|
|
# import module snippets
|
|
|
|
from ansible.module_utils.basic import *
|
|
|
|
from ansible.module_utils.basic import *
|
|
|
|
|
|
|
|
from ansible.module_utils.pycompat24 import get_exception
|
|
|
|
main()
|
|
|
|
main()
|
|
|
|
|
|
|
|
|
|
|
|