Spaces:
Running
Running
Update modules/database/mongo_db.py
Browse files- modules/database/mongo_db.py +25 -4
modules/database/mongo_db.py
CHANGED
|
@@ -18,16 +18,37 @@ def get_collection(collection_name):
|
|
| 18 |
logger.error(f"Error al obtener colecci贸n {collection_name}: {str(e)}")
|
| 19 |
return None
|
| 20 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 21 |
def insert_document(collection_name, document):
|
| 22 |
-
collection = get_collection(collection_name)
|
| 23 |
try:
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 24 |
result = collection.insert_one(document)
|
| 25 |
-
logger.
|
| 26 |
return result.inserted_id
|
|
|
|
| 27 |
except Exception as e:
|
| 28 |
logger.error(f"Error al insertar documento en {collection_name}: {str(e)}")
|
| 29 |
-
return None
|
| 30 |
-
|
|
|
|
| 31 |
def find_documents(collection_name, query, sort=None, limit=None):
|
| 32 |
collection = get_collection(collection_name)
|
| 33 |
try:
|
|
|
|
| 18 |
logger.error(f"Error al obtener colecci贸n {collection_name}: {str(e)}")
|
| 19 |
return None
|
| 20 |
|
| 21 |
+
|
| 22 |
+
|
| 23 |
+
|
| 24 |
+
########################################################
|
| 25 |
+
#def insert_document(collection_name, document):
|
| 26 |
+
# collection = get_collection(collection_name)
|
| 27 |
+
# try:
|
| 28 |
+
# result = collection.insert_one(document)
|
| 29 |
+
# logger.info(f"Documento insertado en {collection_name} con ID: {result.inserted_id}")
|
| 30 |
+
# return result.inserted_id
|
| 31 |
+
# except Exception as e:
|
| 32 |
+
# logger.error(f"Error al insertar documento en {collection_name}: {str(e)}")
|
| 33 |
+
# return None
|
| 34 |
+
##################################################
|
| 35 |
def insert_document(collection_name, document):
|
|
|
|
| 36 |
try:
|
| 37 |
+
collection = get_collection(collection_name)
|
| 38 |
+
if collection is None:
|
| 39 |
+
logger.error(f"No se pudo obtener la colecci贸n {collection_name}")
|
| 40 |
+
return None
|
| 41 |
+
|
| 42 |
+
# Insertar documento
|
| 43 |
result = collection.insert_one(document)
|
| 44 |
+
logger.debug(f"Resultado de inserci贸n: {result.inserted_id}")
|
| 45 |
return result.inserted_id
|
| 46 |
+
|
| 47 |
except Exception as e:
|
| 48 |
logger.error(f"Error al insertar documento en {collection_name}: {str(e)}")
|
| 49 |
+
return None
|
| 50 |
+
|
| 51 |
+
#######################################################
|
| 52 |
def find_documents(collection_name, query, sort=None, limit=None):
|
| 53 |
collection = get_collection(collection_name)
|
| 54 |
try:
|