logos-storage/nim-datastore
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-datastore.git synced 2026-01-05 07:03:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed thing

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-27 21:13:06 -07:00
parent d2d051d51f
commit 3822a97593
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
2 changed files with 13 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
datastore/sql.nim
View File

@ -60,10 +60,9 @@ method put*(self: SQLiteDatastore,
method close*(self: SQLiteDatastore): Future[?!void] {.async.} =
self.db.close()
method queryIter*(
self: SQLiteDatastore,
query: Query
): ?!(iterator(): ?!QueryResponse) =
method queryIter*(self: SQLiteDatastore,
query: Query
): ?!(iterator(): ?!QueryResponse) =
let dbquery = dbQuery(
key= KeyId.new query.key.id(),
@ -75,7 +74,7 @@ method queryIter*(
var qhandle = ? self.db.query(dbquery)
let iter = iterator(): ?!QueryResponse =
for resp in qhandle.iter():
for resp in qhandle.queryIter():
without qres =? resp, err:
yield QueryResponse.failure err
let k = qres.key.map() do(k: KeyId) -> Key:

18
tests/datastore/backendCommonTests.nim
View File

@ -81,7 +81,7 @@ template queryTests*(
var
handle = ds.query(q).tryGet
res = handle.iter().toSeq().mapIt(it.tryGet())
res = handle.queryIter().toSeq().mapIt(it.tryGet())
check:
res.len == 3
@ -107,7 +107,7 @@ template queryTests*(
var res: seq[DbQueryResponse[KeyId, DataBuffer]]
var cnt = 0
for item in handle.iter():
for item in handle.queryIter():
cnt.inc
res.insert(item.tryGet(), 0)
if cnt > 1:
@ -135,7 +135,7 @@ template queryTests*(
var
handle = ds.query(q).tryGet
let
res = handle.iter().toSeq().mapIt(it.tryGet())
res = handle.queryIter().toSeq().mapIt(it.tryGet())
check:
res.len == 3
@ -160,7 +160,7 @@ template queryTests*(
var
handle = ds.query(q).tryGet
let
res = handle.iter().toSeq().mapIt(it.tryGet())
res = handle.queryIter().toSeq().mapIt(it.tryGet())
# ).filterIt(it.isOk).mapIt(it.tryGet())
check:
@ -182,7 +182,7 @@ template queryTests*(
var
handle = ds.query(q).tryGet
res = handle.iter().toSeq().mapIt(it.tryGet())
res = handle.queryIter().toSeq().mapIt(it.tryGet())
res.sort do (a, b: DbQueryResponse[KeyId, DataBuffer]) -> int:
cmp($a.key.get, $b.key.get)
@ -214,7 +214,7 @@ template queryTests*(
var
handle = ds.query(q).tryGet
let
res = handle.iter().toSeq().mapIt(it.tryGet())
res = handle.queryIter().toSeq().mapIt(it.tryGet())
check:
res.len == 10
@ -239,7 +239,7 @@ template queryTests*(
var
handle = ds.query(q).tryGet
let
res = handle.iter().toSeq().mapIt(it.tryGet())
res = handle.queryIter().toSeq().mapIt(it.tryGet())
# echo "RES: ", res.mapIt(it.key)
check:
@ -260,7 +260,7 @@ template queryTests*(
var
handle = ds.query(q).tryGet
res = handle.iter().toSeq().mapIt(it.tryGet())
res = handle.queryIter().toSeq().mapIt(it.tryGet())
check:
res.len == 5
@ -296,7 +296,7 @@ template queryTests*(
kvs = kvs.reversed
var
handle = ds.query(q).tryGet
res = handle.iter().toSeq().mapIt(it.tryGet())
res = handle.queryIter().toSeq().mapIt(it.tryGet())
check:
res.len == 100