From 64d0559e9f36532bcedcc6beb6890447efbc84f3 Mon Sep 17 00:00:00 2001 From: Andrey Klychkov Date: Wed, 19 Jun 2019 16:49:19 +0300 Subject: Postgres module_utils: add get_connect_params + unit tests (#58067) * add get_conn_params * add get_conn_params: add to the modules --- lib/ansible/modules/database/postgresql/postgresql_ext.py | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) (limited to 'lib/ansible/modules/database/postgresql/postgresql_ext.py') diff --git a/lib/ansible/modules/database/postgresql/postgresql_ext.py b/lib/ansible/modules/database/postgresql/postgresql_ext.py index 649d894b37..f37672a2d1 100644 --- a/lib/ansible/modules/database/postgresql/postgresql_ext.py +++ b/lib/ansible/modules/database/postgresql/postgresql_ext.py @@ -143,7 +143,11 @@ except ImportError: pass from ansible.module_utils.basic import AnsibleModule -from ansible.module_utils.postgres import connect_to_db, postgres_common_argument_spec +from ansible.module_utils.postgres import ( + connect_to_db, + get_conn_params, + postgres_common_argument_spec, +) from ansible.module_utils._text import to_native from ansible.module_utils.database import pg_quote_identifier @@ -216,7 +220,8 @@ def main(): cascade = module.params["cascade"] changed = False - db_connection = connect_to_db(module, autocommit=True) + conn_params = get_conn_params(module, module.params) + db_connection = connect_to_db(module, conn_params, autocommit=True) cursor = db_connection.cursor(cursor_factory=DictCursor) try: -- cgit v1.2.1