projects
/
osm
/
common.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Change package.deb generation to include postinstall for aiokafka pip installation
[osm/common.git]
/
osm_common
/
dbmemory.py
diff --git
a/osm_common/dbmemory.py
b/osm_common/dbmemory.py
index
cdb0482
..
6f7e4c4
100644
(file)
--- a/
osm_common/dbmemory.py
+++ b/
osm_common/dbmemory.py
@@
-1,5
+1,5
@@
import logging
import logging
-from dbbase import DbException, DbBase
+from
osm_common.
dbbase import DbException, DbBase
from http import HTTPStatus
from uuid import uuid4
from copy import deepcopy
from http import HTTPStatus
from uuid import uuid4
from copy import deepcopy
@@
-64,7
+64,7
@@
class DbMemory(DbBase):
for i, _ in self._find(table, self._format_filter(filter)):
id_list.append(i)
deleted = len(id_list)
for i, _ in self._find(table, self._format_filter(filter)):
id_list.append(i)
deleted = len(id_list)
- for i in
id_list
:
+ for i in
reversed(id_list)
:
del self.db[table][i]
return {"deleted": deleted}
except DbException:
del self.db[table][i]
return {"deleted": deleted}
except DbException:
@@
-94,7
+94,7
@@
class DbMemory(DbBase):
raise DbException("Not found entry with filter='{}'".format(filter), HTTPStatus.NOT_FOUND)
return None
self.db[table][i] = deepcopy(indata)
raise DbException("Not found entry with filter='{}'".format(filter), HTTPStatus.NOT_FOUND)
return None
self.db[table][i] = deepcopy(indata)
- return {"up
ad
ted": 1}
+ return {"up
da
ted": 1}
except Exception as e: # TODO refine
raise DbException(str(e))
except Exception as e: # TODO refine
raise DbException(str(e))
@@
-114,7
+114,7
@@
class DbMemory(DbBase):
if __name__ == '__main__':
# some test code
if __name__ == '__main__':
# some test code
- db =
dbm
emory()
+ db =
DbM
emory()
db.create("test", {"_id": 1, "data": 1})
db.create("test", {"_id": 2, "data": 2})
db.create("test", {"_id": 3, "data": 3})
db.create("test", {"_id": 1, "data": 1})
db.create("test", {"_id": 2, "data": 2})
db.create("test", {"_id": 3, "data": 3})