|
|
@@ -450,18 +450,18 @@ class MongodbHandler:
|
|
|
query = {attribute: {comparison_operator: attribute_value}}
|
|
|
data = self._database[collection_name].find(query, {'_id': return_id}).sort(sort_label, direction).limit(limit)
|
|
|
|
|
|
- print('THIS IS THE DATA', list(data))
|
|
|
- if data.collection.count_documents(query) == 0:
|
|
|
- self._log.warning('No data was found for the query')
|
|
|
- return None
|
|
|
-
|
|
|
except Exception as error:
|
|
|
self._log.log_and_raise_error(('An error occured trying to query data from {}, \nError:{}').format(collection_name, error))
|
|
|
|
|
|
- if return_as_dataframe:
|
|
|
- return self.convert_mongo_data_into_dataframe(data, index, collection_name)
|
|
|
+ if data.collection.count_documents(query) != 0:
|
|
|
+ if return_as_dataframe:
|
|
|
+ return self.convert_mongo_data_into_dataframe(data, index, collection_name)
|
|
|
+ else:
|
|
|
+ print('THIS IS THE DATA', list(data))
|
|
|
+ return data
|
|
|
else:
|
|
|
- return data
|
|
|
+ self._log.warning('No data was found for the query')
|
|
|
+ return None
|
|
|
|
|
|
def update_data_in_collection(self, update_label:str, update_value: str, collection_name:str, query_label: str = None, query_value: str = None, create_if_not_exist: bool = True, find_query: dict = None, update_many: bool = False):
|
|
|
|
