diff --git a/api/__init__.py b/api/__init__.py index de856278b1baa43349c990bfc54b4c60a3cf4880..ba71db447ebd4be1334454b4428c9d32007ca3d0 100644 --- a/api/__init__.py +++ b/api/__init__.py @@ -17,34 +17,6 @@ def get_db(request: Request): return database -def set_connection_parameters(db_conn): - # client-connection-defaults setzen, falls fuer unseren hostnamen definiert: - get_stmt_bindings = dict({'bnd_fqdn': settings.api_client_name.rstrip('.') + '.'}) - get_stmt = """ - select pg_set.name, ccp.cfg_param_value - from netadmin.dns_ntree n - JOIN netadmin.cntl_clnt_conn_params ccp ON ccp.dns_ntree_key_nr = n.key_nr - JOIN pg_catalog.pg_settings pg_set ON pg_set.name = ccp.cfg_param_name - where n.fqdn = %(bnd_fqdn)s - """ - set_stmt = """select pg_catalog.set_config(%(bnd_k)s, %(bnd_v)s, %(bnd_is_local)s)""" - # apply param setting transaction-local (only for current TA)? - set_ta_local = False - - # - # eigener transaction block - # ta-context: implizites commit nach block-exit, implizites cursor-schliessen - with db_conn.transaction(): - with db_conn.cursor() as csr: - csr.execute(get_stmt, get_stmt_bindings) - ccp_rows = csr.fetchall() - for ccp_row in ccp_rows: - (p_name, p_value) = ccp_row - set_stmt_bindings = dict({'bnd_k': p_name, 'bnd_v': p_value, 'bnd_is_local': set_ta_local}) - csr.execute(set_stmt, set_stmt_bindings) - return - - def get_conn(request: Request): if hasattr(request.state, 'db_conn'): return request.state.db_conn @@ -53,7 +25,6 @@ def get_conn(request: Request): query = "SET search_path TO netadmin, public;" db.execute(db_connection, query) db_connection.commit() - set_connection_parameters(db_connection) request.state.db_conn = db_connection # Register callbacks to ensure transactions are properly committed after request is over