Spaces:
Sleeping
Sleeping
File size: 1,463 Bytes
d63d035 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 |
from library.librerias import sqlite3, Queue, threading
DB_PATH = "database/anhelados.db"
class DatabaseConnection:
"""
Clase para gestionar las conexiones a la base de datos con un pool.
"""
_instance = None
_lock = threading.Lock()
_connection_pool = Queue(maxsize=5)
def __new__(cls):
"""
Crea una nueva instancia de la clase si no existe.
"""
with cls._lock:
if cls._instance is None:
cls._instance = super().__new__(cls)
cls._instance.conn = cls._instance._create_connection()
return cls._instance
def _create_connection(self):
"""
Crea una conexi贸n a la base de datos.
"""
if not self._connection_pool.empty():
return self._connection_pool.get()
else:
connection = sqlite3.connect(DB_PATH)
connection.row_factory = sqlite3.Row
return connection
def get_connection(self):
"""
Obtener el objeto de conexi贸n de la base de datos.
"""
return self._instance._create_connection()
def release_connection(self):
"""
Liberar la conexi贸n de nuevo al pool.
"""
if self._instance is not None:
self._connection_pool.put(self._instance.conn)
self._instance.conn = None # Marcar la instancia como sin conexi贸n
|