2024-05-30 11:55:58 +00:00
|
|
|
from contextvars import ContextVar
|
2024-06-16 22:25:48 +00:00
|
|
|
from peewee import *
|
2024-06-17 23:44:20 +00:00
|
|
|
from peewee import PostgresqlDatabase, InterfaceError as PeeWeeInterfaceError
|
|
|
|
|
2024-06-17 17:34:19 +00:00
|
|
|
import logging
|
2024-06-17 23:44:20 +00:00
|
|
|
from playhouse.db_url import connect, parse
|
2024-06-17 17:34:19 +00:00
|
|
|
|
|
|
|
from config import SRC_LOG_LEVELS
|
|
|
|
|
|
|
|
log = logging.getLogger(__name__)
|
|
|
|
log.setLevel(SRC_LOG_LEVELS["DB"])
|
2024-05-30 11:55:58 +00:00
|
|
|
|
|
|
|
db_state_default = {"closed": None, "conn": None, "ctx": None, "transactions": None}
|
|
|
|
db_state = ContextVar("db_state", default=db_state_default.copy())
|
|
|
|
|
2024-06-16 22:25:48 +00:00
|
|
|
class PeeweeConnectionState(object):
|
2024-05-30 11:55:58 +00:00
|
|
|
def __init__(self, **kwargs):
|
|
|
|
super().__setattr__("_state", db_state)
|
|
|
|
super().__init__(**kwargs)
|
|
|
|
|
|
|
|
def __setattr__(self, name, value):
|
|
|
|
self._state.get()[name] = value
|
|
|
|
|
|
|
|
def __getattr__(self, name):
|
2024-06-16 22:25:48 +00:00
|
|
|
value = self._state.get()[name]
|
|
|
|
return value
|
2024-05-30 11:55:58 +00:00
|
|
|
|
2024-06-17 23:44:20 +00:00
|
|
|
class CustomReconnectMixin(ReconnectMixin):
|
|
|
|
reconnect_errors = (
|
|
|
|
# psycopg2
|
|
|
|
(OperationalError, 'termin'),
|
|
|
|
(InterfaceError, 'closed'),
|
|
|
|
# peewee
|
|
|
|
(PeeWeeInterfaceError, 'closed'),
|
|
|
|
)
|
|
|
|
|
|
|
|
class ReconnectingPostgresqlDatabase(CustomReconnectMixin, PostgresqlDatabase):
|
|
|
|
pass
|
|
|
|
|
2024-06-16 22:25:48 +00:00
|
|
|
def register_connection(db_url):
|
|
|
|
db = connect(db_url)
|
|
|
|
if isinstance(db, PostgresqlDatabase):
|
2024-06-17 17:34:19 +00:00
|
|
|
# Enable autoconnect for SQLite databases, managed by Peewee
|
2024-06-17 16:56:31 +00:00
|
|
|
db.autoconnect = True
|
2024-06-17 23:44:20 +00:00
|
|
|
db.reuse_if_open = True
|
2024-06-17 17:34:19 +00:00
|
|
|
log.info("Connected to PostgreSQL database")
|
2024-06-17 23:44:20 +00:00
|
|
|
connection = parse(db_url)
|
|
|
|
db = ReconnectingPostgresqlDatabase(connection['database'], user=connection['user'], password=connection['password'],host=connection['host'], port=connection['port'])
|
|
|
|
db.connect(reuse_if_open=True)
|
2024-06-16 22:25:48 +00:00
|
|
|
elif isinstance(db, SqliteDatabase):
|
2024-06-17 17:34:19 +00:00
|
|
|
# Enable autoconnect for SQLite databases, managed by Peewee
|
2024-06-17 16:56:31 +00:00
|
|
|
db.autoconnect = True
|
2024-06-17 23:44:20 +00:00
|
|
|
db.reuse_if_open = True
|
2024-06-17 17:34:19 +00:00
|
|
|
log.info("Connected to SQLite database")
|
2024-06-16 22:25:48 +00:00
|
|
|
else:
|
|
|
|
raise ValueError('Unsupported database connection')
|
2024-06-17 14:50:47 +00:00
|
|
|
return db
|