UPD remove set_connection_parameters

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