From 53fd8b52e32a4f709034e6e674053c31f676ef96 Mon Sep 17 00:00:00 2001
From: Julian Keck <julian.keck9@kit.edu>
Date: Fri, 2 Aug 2024 14:37:55 +0200
Subject: [PATCH] UPD remove set_connection_parameters
---
api/__init__.py | 29 -----------------------------
1 file changed, 29 deletions(-)
diff --git a/api/__init__.py b/api/__init__.py
index de85627..ba71db4 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
--
GitLab