Loading transfer_service/db_connector.py +1 −17 Original line number Diff line number Diff line Loading @@ -22,7 +22,7 @@ class DbConnector(object): def createConnectionPool(self): self.connPool = ThreadedConnectionPool( 5, 8, 32, user = self.user, password = self.password, Loading @@ -32,17 +32,6 @@ class DbConnector(object): connect_timeout = 2 ) #def connect(self): # try: # self.conn = psycopg2.connect(user = self.user, # password = self.password, # host = self.host, # port = self.port, # database = self.dbname) # except(Exception, psycopg2.Error) as error : # sys.exit(f"Error while connecting to PostgreSQL: {error}") # self.cursor = self.conn.cursor(cursor_factory = RealDictCursor) @contextmanager def getConnection(self): conn = self.connPool.getconn() Loading @@ -52,11 +41,6 @@ class DbConnector(object): finally: self.connPool.putconn(conn, close = False) #def disconnect(self): # if self.conn: # self.cursor.close() # self.conn.close() """ Getters """ Loading Loading
transfer_service/db_connector.py +1 −17 Original line number Diff line number Diff line Loading @@ -22,7 +22,7 @@ class DbConnector(object): def createConnectionPool(self): self.connPool = ThreadedConnectionPool( 5, 8, 32, user = self.user, password = self.password, Loading @@ -32,17 +32,6 @@ class DbConnector(object): connect_timeout = 2 ) #def connect(self): # try: # self.conn = psycopg2.connect(user = self.user, # password = self.password, # host = self.host, # port = self.port, # database = self.dbname) # except(Exception, psycopg2.Error) as error : # sys.exit(f"Error while connecting to PostgreSQL: {error}") # self.cursor = self.conn.cursor(cursor_factory = RealDictCursor) @contextmanager def getConnection(self): conn = self.connPool.getconn() Loading @@ -52,11 +41,6 @@ class DbConnector(object): finally: self.connPool.putconn(conn, close = False) #def disconnect(self): # if self.conn: # self.cursor.close() # self.conn.close() """ Getters """ Loading