|
from .database_init import get_mongodb |
|
import logging |
|
|
|
logger = logging.getLogger(__name__) |
|
|
|
def get_collection(collection_name): |
|
try: |
|
db = get_mongodb() |
|
if db is None: |
|
logger.error(f"No se pudo obtener la base de datos para {collection_name}") |
|
return None |
|
|
|
collection = db[collection_name] |
|
logger.info(f"Colecci贸n {collection_name} obtenida exitosamente") |
|
return collection |
|
|
|
except Exception as e: |
|
logger.error(f"Error al obtener colecci贸n {collection_name}: {str(e)}") |
|
return None |
|
|
|
def insert_document(collection_name, document): |
|
collection = get_collection(collection_name) |
|
try: |
|
result = collection.insert_one(document) |
|
logger.info(f"Documento insertado en {collection_name} con ID: {result.inserted_id}") |
|
return result.inserted_id |
|
except Exception as e: |
|
logger.error(f"Error al insertar documento en {collection_name}: {str(e)}") |
|
return None |
|
|
|
def find_documents(collection_name, query, sort=None, limit=None): |
|
collection = get_collection(collection_name) |
|
try: |
|
cursor = collection.find(query) |
|
if sort: |
|
cursor = cursor.sort(sort) |
|
if limit: |
|
cursor = cursor.limit(limit) |
|
return list(cursor) |
|
except Exception as e: |
|
logger.error(f"Error al buscar documentos en {collection_name}: {str(e)}") |
|
return [] |
|
|
|
def update_document(collection_name, query, update): |
|
collection = get_collection(collection_name) |
|
try: |
|
result = collection.update_one(query, update) |
|
logger.info(f"Documento actualizado en {collection_name}: {result.modified_count} modificado(s)") |
|
return result.modified_count |
|
except Exception as e: |
|
logger.error(f"Error al actualizar documento en {collection_name}: {str(e)}") |
|
return 0 |
|
|
|
def delete_document(collection_name, query): |
|
collection = get_collection(collection_name) |
|
try: |
|
result = collection.delete_one(query) |
|
logger.info(f"Documento eliminado de {collection_name}: {result.deleted_count} eliminado(s)") |
|
return result.deleted_count |
|
except Exception as e: |
|
logger.error(f"Error al eliminar documento de {collection_name}: {str(e)}") |
|
return 0 |