X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_common%2Fdbmongo.py;h=9e34920f9f707dbe87ff95a6db444d7cef1ed239;hb=acbbdf2e24f53353f18b60fbb67b33f616bb3aae;hp=582773a9ff1dda6b052d7b860bd0cdbee431d58e;hpb=5c012612f1292b012dc12b337c611c6f3c083b18;p=osm%2Fcommon.git diff --git a/osm_common/dbmongo.py b/osm_common/dbmongo.py index 582773a..9e34920 100644 --- a/osm_common/dbmongo.py +++ b/osm_common/dbmongo.py @@ -1,7 +1,7 @@ import logging from pymongo import MongoClient, errors -from dbbase import DbException, DbBase +from osm_common.dbbase import DbException, DbBase from http import HTTPStatus from time import time, sleep @@ -167,12 +167,12 @@ class DbMongo(DbBase): try: collection = self.db[table] rows = collection.update_one(self._format_filter(filter), {"$set": update_dict}) - if rows.updated_count == 0: + if rows.matched_count == 0: if fail_on_empty: raise DbException("Not found any {} with filter='{}'".format(table[:-1], filter), HTTPStatus.NOT_FOUND) return None - return {"deleted": rows.deleted_count} + return {"modified": rows.modified_count} except Exception as e: # TODO refine raise DbException(str(e)) @@ -186,6 +186,6 @@ class DbMongo(DbBase): raise DbException("Not found any {} with filter='{}'".format(table[:-1], _filter), HTTPStatus.NOT_FOUND) return None - return {"replace": rows.modified_count} + return {"replaced": rows.modified_count} except Exception as e: # TODO refine raise DbException(str(e))