X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=osm_common%2Fdbmemory.py;h=196d5d96283a47dde1a9f986a05c10b02fdae349;hb=2c9794c5dc468baabe99b2f934e4bdb32e98ce54;hp=c57f932f29e6e335af34c8b4171cf209777e56d3;hpb=bf6c5729597476199627c6750e8db3a92ce47c9c;p=osm%2Fcommon.git diff --git a/osm_common/dbmemory.py b/osm_common/dbmemory.py index c57f932..196d5d9 100644 --- a/osm_common/dbmemory.py +++ b/osm_common/dbmemory.py @@ -372,15 +372,17 @@ class DbMemory(DbBase): raise DbException("Not found entry with _id='{}'".format(q_filter), HTTPStatus.NOT_FOUND) return None - def set_list(self, table, q_filter, update_dict, fail_on_empty=True, unset=None, pull=None, push=None): + def set_list(self, table, q_filter, update_dict, unset=None, pull=None, push=None): with self.lock: updated = 0 - for i, db_item in self._find(table, self._format_filter(q_filter)): + found = 0 + for _, db_item in self._find(table, self._format_filter(q_filter)): + found += 1 if self._update(db_item, update_dict, unset=unset, pull=pull, push=push): updated += 1 - if i == 0 and fail_on_empty: - raise DbException("Not found entry with _id='{}'".format(q_filter), HTTPStatus.NOT_FOUND) - return {"updated": updated} if i else None + # if not found and fail_on_empty: + # raise DbException("Not found entry with '{}'".format(q_filter), HTTPStatus.NOT_FOUND) + return {"updated": updated} if found else None def replace(self, table, _id, indata, fail_on_empty=True): """ @@ -412,7 +414,7 @@ class DbMemory(DbBase): Add a new entry at database :param table: collection or table :param indata: content to be added - :return: database id of the inserted element. Raises a DbException on error + :return: database '_id' of the inserted element. Raises a DbException on error """ try: id = indata.get("_id") @@ -432,7 +434,7 @@ class DbMemory(DbBase): Add a new entry at database :param table: collection or table :param indata_list: list content to be added - :return: database ids of the inserted element. Raises a DbException on error + :return: list of inserted 'id's. Raises a DbException on error """ try: _ids = []