X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_common%2Fdbmongo.py;h=e5e12c67b1868735cc4def86907aa67accba6680;hb=refs%2Ftags%2Fv14.0.0rc1;hp=f5c4d3055d9e95c70194b7e2eac10b52b01df184;hpb=76394efe9fbee088dddd1dc9d4da6f043c3959a5;p=osm%2Fcommon.git diff --git a/osm_common/dbmongo.py b/osm_common/dbmongo.py index f5c4d30..e5e12c6 100644 --- a/osm_common/dbmongo.py +++ b/osm_common/dbmongo.py @@ -284,7 +284,7 @@ class DbMongo(DbBase): with self.lock: collection = self.db[table] db_filter = self._format_filter(q_filter) - count = collection.count(db_filter) + count = collection.count_documents(db_filter) return count except DbException: raise @@ -308,8 +308,8 @@ class DbMongo(DbBase): collection = self.db[table] if not (fail_on_empty and fail_on_more): return collection.find_one(db_filter) - rows = collection.find(db_filter) - if rows.count() == 0: + rows = list(collection.find(db_filter)) + if len(rows) == 0: if fail_on_empty: raise DbException( "Not found any {} with filter='{}'".format( @@ -317,8 +317,9 @@ class DbMongo(DbBase): ), HTTPStatus.NOT_FOUND, ) + return None - elif rows.count() > 1: + elif len(rows) > 1: if fail_on_more: raise DbException( "Found more than one {} with filter='{}'".format(