0421e2a4bb
* feat(db): added new foreign-key indexes * feat(db): added new foreign-key indexes * feat(api): pg_client fixed exception handler * feat(api): changed change password response * feat(api): insights retention
62 lines
1.7 KiB
Python
62 lines
1.7 KiB
Python
import psycopg2
|
|
import psycopg2.extras
|
|
from chalicelib.utils.helper import environ
|
|
|
|
PG_CONFIG = {"host": environ["pg_host"],
|
|
"database": environ["pg_dbname"],
|
|
"user": environ["pg_user"],
|
|
"password": environ["pg_password"],
|
|
"port": int(environ["pg_port"])}
|
|
|
|
from psycopg2 import pool
|
|
from threading import Semaphore
|
|
|
|
|
|
class ORThreadedConnectionPool(psycopg2.pool.ThreadedConnectionPool):
|
|
def __init__(self, minconn, maxconn, *args, **kwargs):
|
|
self._semaphore = Semaphore(maxconn)
|
|
super().__init__(minconn, maxconn, *args, **kwargs)
|
|
|
|
def getconn(self, *args, **kwargs):
|
|
self._semaphore.acquire()
|
|
return super().getconn(*args, **kwargs)
|
|
|
|
def putconn(self, *args, **kwargs):
|
|
super().putconn(*args, **kwargs)
|
|
self._semaphore.release()
|
|
|
|
|
|
try:
|
|
postgreSQL_pool = ORThreadedConnectionPool(50, 100, **PG_CONFIG)
|
|
if (postgreSQL_pool):
|
|
print("Connection pool created successfully")
|
|
except (Exception, psycopg2.DatabaseError) as error:
|
|
print("Error while connecting to PostgreSQL", error)
|
|
raise error
|
|
|
|
|
|
class PostgresClient:
|
|
connection = None
|
|
cursor = None
|
|
|
|
def __init__(self):
|
|
self.connection = postgreSQL_pool.getconn()
|
|
|
|
def __enter__(self):
|
|
if self.cursor is None:
|
|
self.cursor = self.connection.cursor(cursor_factory=psycopg2.extras.RealDictCursor)
|
|
return self.cursor
|
|
|
|
def __exit__(self, *args):
|
|
try:
|
|
self.connection.commit()
|
|
self.cursor.close()
|
|
except Exception as error:
|
|
print("Error while committing/closing PG-connection", error)
|
|
raise error
|
|
finally:
|
|
postgreSQL_pool.putconn(self.connection)
|
|
|
|
|
|
def close():
|
|
pass
|