mirror of
https://github.com/logos-storage/nim-datastore.git
synced 2026-01-07 08:03:13 +00:00
test query
This commit is contained in:
Jaremy Creechley
parent
690b3d4453
commit
8aa3618805
@ -101,9 +101,9 @@ template executeTask[T](ctx: TaskCtx[T], blk: untyped) =
|
||||
except CatchableError as exc:
|
||||
trace "Unexpected exception thrown in async task", exc = exc.msg
|
||||
ctx[].res.err exc.toThreadErr()
|
||||
except Exception as exc:
|
||||
trace "Unexpected defect thrown in async task", exc = exc.msg
|
||||
ctx[].res.err exc.toThreadErr()
|
||||
# except Exception as exc:
|
||||
# trace "Unexpected defect thrown in async task", exc = exc.msg
|
||||
# ctx[].res.err exc.toThreadErr()
|
||||
finally:
|
||||
ctx.setDone()
|
||||
# echo "\t\texecuteTask:fireSync!"
|
||||
|
||||
@ -64,277 +64,277 @@ template queryTests*(ds: Datastore, extended = true) {.dirty.} =
|
||||
|
||||
(await iter.dispose()).tryGet
|
||||
|
||||
test "Key should query all keys without values":
|
||||
let
|
||||
q = Query.init(key1, value = false)
|
||||
# test "Key should query all keys without values":
|
||||
# let
|
||||
# q = Query.init(key1, value = false)
|
||||
|
||||
(await ds.put(key1, val1)).tryGet
|
||||
(await ds.put(key2, val2)).tryGet
|
||||
(await ds.put(key3, val3)).tryGet
|
||||
# (await ds.put(key1, val1)).tryGet
|
||||
# (await ds.put(key2, val2)).tryGet
|
||||
# (await ds.put(key3, val3)).tryGet
|
||||
|
||||
let
|
||||
iter = (await ds.query(q)).tryGet
|
||||
res = block:
|
||||
var
|
||||
res: seq[QueryResponse]
|
||||
cnt = 0
|
||||
# let
|
||||
# iter = (await ds.query(q)).tryGet
|
||||
# res = block:
|
||||
# var
|
||||
# res: seq[QueryResponse]
|
||||
# cnt = 0
|
||||
|
||||
for pair in iter:
|
||||
let (key, val) = (await pair).tryGet
|
||||
if key.isNone:
|
||||
break
|
||||
# for pair in iter:
|
||||
# let (key, val) = (await pair).tryGet
|
||||
# if key.isNone:
|
||||
# break
|
||||
|
||||
res.add((key, val))
|
||||
cnt.inc
|
||||
# res.add((key, val))
|
||||
# cnt.inc
|
||||
|
||||
res
|
||||
# res
|
||||
|
||||
check:
|
||||
res.len == 3
|
||||
res[0].key.get == key1
|
||||
res[0].data.len == 0
|
||||
# check:
|
||||
# res.len == 3
|
||||
# res[0].key.get == key1
|
||||
# res[0].data.len == 0
|
||||
|
||||
res[1].key.get == key2
|
||||
res[1].data.len == 0
|
||||
# res[1].key.get == key2
|
||||
# res[1].data.len == 0
|
||||
|
||||
res[2].key.get == key3
|
||||
res[2].data.len == 0
|
||||
# res[2].key.get == key3
|
||||
# res[2].data.len == 0
|
||||
|
||||
(await iter.dispose()).tryGet
|
||||
# (await iter.dispose()).tryGet
|
||||
|
||||
test "Key should not query parent":
|
||||
let
|
||||
q = Query.init(key2)
|
||||
# test "Key should not query parent":
|
||||
# let
|
||||
# q = Query.init(key2)
|
||||
|
||||
(await ds.put(key1, val1)).tryGet
|
||||
(await ds.put(key2, val2)).tryGet
|
||||
(await ds.put(key3, val3)).tryGet
|
||||
# (await ds.put(key1, val1)).tryGet
|
||||
# (await ds.put(key2, val2)).tryGet
|
||||
# (await ds.put(key3, val3)).tryGet
|
||||
|
||||
let
|
||||
iter = (await ds.query(q)).tryGet
|
||||
res = block:
|
||||
var
|
||||
res: seq[QueryResponse]
|
||||
cnt = 0
|
||||
# let
|
||||
# iter = (await ds.query(q)).tryGet
|
||||
# res = block:
|
||||
# var
|
||||
# res: seq[QueryResponse]
|
||||
# cnt = 0
|
||||
|
||||
for pair in iter:
|
||||
let (key, val) = (await pair).tryGet
|
||||
if key.isNone:
|
||||
break
|
||||
# for pair in iter:
|
||||
# let (key, val) = (await pair).tryGet
|
||||
# if key.isNone:
|
||||
# break
|
||||
|
||||
res.add((key, val))
|
||||
cnt.inc
|
||||
# res.add((key, val))
|
||||
# cnt.inc
|
||||
|
||||
res
|
||||
# res
|
||||
|
||||
check:
|
||||
res.len == 2
|
||||
res[0].key.get == key2
|
||||
res[0].data == val2
|
||||
# check:
|
||||
# res.len == 2
|
||||
# res[0].key.get == key2
|
||||
# res[0].data == val2
|
||||
|
||||
res[1].key.get == key3
|
||||
res[1].data == val3
|
||||
# res[1].key.get == key3
|
||||
# res[1].data == val3
|
||||
|
||||
(await iter.dispose()).tryGet
|
||||
# (await iter.dispose()).tryGet
|
||||
|
||||
test "Key should all list all keys at the same level":
|
||||
let
|
||||
queryKey = Key.init("/a").tryGet
|
||||
q = Query.init(queryKey)
|
||||
# test "Key should all list all keys at the same level":
|
||||
# let
|
||||
# queryKey = Key.init("/a").tryGet
|
||||
# q = Query.init(queryKey)
|
||||
|
||||
(await ds.put(key1, val1)).tryGet
|
||||
(await ds.put(key2, val2)).tryGet
|
||||
(await ds.put(key3, val3)).tryGet
|
||||
# (await ds.put(key1, val1)).tryGet
|
||||
# (await ds.put(key2, val2)).tryGet
|
||||
# (await ds.put(key3, val3)).tryGet
|
||||
|
||||
let
|
||||
iter = (await ds.query(q)).tryGet
|
||||
# let
|
||||
# iter = (await ds.query(q)).tryGet
|
||||
|
||||
var
|
||||
res = block:
|
||||
var
|
||||
res: seq[QueryResponse]
|
||||
cnt = 0
|
||||
# var
|
||||
# res = block:
|
||||
# var
|
||||
# res: seq[QueryResponse]
|
||||
# cnt = 0
|
||||
|
||||
for pair in iter:
|
||||
let (key, val) = (await pair).tryGet
|
||||
if key.isNone:
|
||||
break
|
||||
# for pair in iter:
|
||||
# let (key, val) = (await pair).tryGet
|
||||
# if key.isNone:
|
||||
# break
|
||||
|
||||
res.add((key, val))
|
||||
cnt.inc
|
||||
# res.add((key, val))
|
||||
# cnt.inc
|
||||
|
||||
res
|
||||
# res
|
||||
|
||||
res.sort do (a, b: QueryResponse) -> int:
|
||||
cmp(a.key.get.id, b.key.get.id)
|
||||
# res.sort do (a, b: QueryResponse) -> int:
|
||||
# cmp(a.key.get.id, b.key.get.id)
|
||||
|
||||
check:
|
||||
res.len == 3
|
||||
res[0].key.get == key1
|
||||
res[0].data == val1
|
||||
# check:
|
||||
# res.len == 3
|
||||
# res[0].key.get == key1
|
||||
# res[0].data == val1
|
||||
|
||||
res[1].key.get == key2
|
||||
res[1].data == val2
|
||||
# res[1].key.get == key2
|
||||
# res[1].data == val2
|
||||
|
||||
res[2].key.get == key3
|
||||
res[2].data == val3
|
||||
# res[2].key.get == key3
|
||||
# res[2].data == val3
|
||||
|
||||
(await iter.dispose()).tryGet
|
||||
# (await iter.dispose()).tryGet
|
||||
|
||||
if extended:
|
||||
test "Should apply limit":
|
||||
let
|
||||
key = Key.init("/a").tryGet
|
||||
q = Query.init(key, limit = 10)
|
||||
# if extended:
|
||||
# test "Should apply limit":
|
||||
# let
|
||||
# key = Key.init("/a").tryGet
|
||||
# q = Query.init(key, limit = 10)
|
||||
|
||||
for i in 0..<100:
|
||||
let
|
||||
key = Key.init(key, Key.init("/" & $i).tryGet).tryGet
|
||||
val = ("val " & $i).toBytes
|
||||
# for i in 0..<100:
|
||||
# let
|
||||
# key = Key.init(key, Key.init("/" & $i).tryGet).tryGet
|
||||
# val = ("val " & $i).toBytes
|
||||
|
||||
(await ds.put(key, val)).tryGet
|
||||
# (await ds.put(key, val)).tryGet
|
||||
|
||||
let
|
||||
iter = (await ds.query(q)).tryGet
|
||||
res = block:
|
||||
var
|
||||
res: seq[QueryResponse]
|
||||
cnt = 0
|
||||
# let
|
||||
# iter = (await ds.query(q)).tryGet
|
||||
# res = block:
|
||||
# var
|
||||
# res: seq[QueryResponse]
|
||||
# cnt = 0
|
||||
|
||||
for pair in iter:
|
||||
let (key, val) = (await pair).tryGet
|
||||
if key.isNone:
|
||||
break
|
||||
# for pair in iter:
|
||||
# let (key, val) = (await pair).tryGet
|
||||
# if key.isNone:
|
||||
# break
|
||||
|
||||
res.add((key, val))
|
||||
cnt.inc
|
||||
# res.add((key, val))
|
||||
# cnt.inc
|
||||
|
||||
res
|
||||
# res
|
||||
|
||||
check:
|
||||
res.len == 10
|
||||
# check:
|
||||
# res.len == 10
|
||||
|
||||
(await iter.dispose()).tryGet
|
||||
# (await iter.dispose()).tryGet
|
||||
|
||||
test "Should not apply offset":
|
||||
let
|
||||
key = Key.init("/a").tryGet
|
||||
q = Query.init(key, offset = 90)
|
||||
# test "Should not apply offset":
|
||||
# let
|
||||
# key = Key.init("/a").tryGet
|
||||
# q = Query.init(key, offset = 90)
|
||||
|
||||
for i in 0..<100:
|
||||
let
|
||||
key = Key.init(key, Key.init("/" & $i).tryGet).tryGet
|
||||
val = ("val " & $i).toBytes
|
||||
# for i in 0..<100:
|
||||
# let
|
||||
# key = Key.init(key, Key.init("/" & $i).tryGet).tryGet
|
||||
# val = ("val " & $i).toBytes
|
||||
|
||||
(await ds.put(key, val)).tryGet
|
||||
# (await ds.put(key, val)).tryGet
|
||||
|
||||
let
|
||||
iter = (await ds.query(q)).tryGet
|
||||
res = block:
|
||||
var
|
||||
res: seq[QueryResponse]
|
||||
cnt = 0
|
||||
# let
|
||||
# iter = (await ds.query(q)).tryGet
|
||||
# res = block:
|
||||
# var
|
||||
# res: seq[QueryResponse]
|
||||
# cnt = 0
|
||||
|
||||
for pair in iter:
|
||||
let (key, val) = (await pair).tryGet
|
||||
if key.isNone:
|
||||
break
|
||||
# for pair in iter:
|
||||
# let (key, val) = (await pair).tryGet
|
||||
# if key.isNone:
|
||||
# break
|
||||
|
||||
res.add((key, val))
|
||||
cnt.inc
|
||||
# res.add((key, val))
|
||||
# cnt.inc
|
||||
|
||||
res
|
||||
# res
|
||||
|
||||
check:
|
||||
res.len == 10
|
||||
# check:
|
||||
# res.len == 10
|
||||
|
||||
(await iter.dispose()).tryGet
|
||||
# (await iter.dispose()).tryGet
|
||||
|
||||
test "Should not apply offset and limit":
|
||||
let
|
||||
key = Key.init("/a").tryGet
|
||||
q = Query.init(key, offset = 95, limit = 5)
|
||||
# test "Should not apply offset and limit":
|
||||
# let
|
||||
# key = Key.init("/a").tryGet
|
||||
# q = Query.init(key, offset = 95, limit = 5)
|
||||
|
||||
for i in 0..<100:
|
||||
let
|
||||
key = Key.init(key, Key.init("/" & $i).tryGet).tryGet
|
||||
val = ("val " & $i).toBytes
|
||||
# for i in 0..<100:
|
||||
# let
|
||||
# key = Key.init(key, Key.init("/" & $i).tryGet).tryGet
|
||||
# val = ("val " & $i).toBytes
|
||||
|
||||
(await ds.put(key, val)).tryGet
|
||||
# (await ds.put(key, val)).tryGet
|
||||
|
||||
let
|
||||
iter = (await ds.query(q)).tryGet
|
||||
res = block:
|
||||
var
|
||||
res: seq[QueryResponse]
|
||||
cnt = 0
|
||||
# let
|
||||
# iter = (await ds.query(q)).tryGet
|
||||
# res = block:
|
||||
# var
|
||||
# res: seq[QueryResponse]
|
||||
# cnt = 0
|
||||
|
||||
for pair in iter:
|
||||
let (key, val) = (await pair).tryGet
|
||||
if key.isNone:
|
||||
break
|
||||
# for pair in iter:
|
||||
# let (key, val) = (await pair).tryGet
|
||||
# if key.isNone:
|
||||
# break
|
||||
|
||||
res.add((key, val))
|
||||
cnt.inc
|
||||
# res.add((key, val))
|
||||
# cnt.inc
|
||||
|
||||
res
|
||||
# res
|
||||
|
||||
check:
|
||||
res.len == 5
|
||||
# check:
|
||||
# res.len == 5
|
||||
|
||||
for i in 0..<res.high:
|
||||
let
|
||||
val = ("val " & $(i + 95)).toBytes
|
||||
key = Key.init(key, Key.init("/" & $(i + 95)).tryGet).tryGet
|
||||
# for i in 0..<res.high:
|
||||
# let
|
||||
# val = ("val " & $(i + 95)).toBytes
|
||||
# key = Key.init(key, Key.init("/" & $(i + 95)).tryGet).tryGet
|
||||
|
||||
check:
|
||||
res[i].key.get == key
|
||||
res[i].data == val
|
||||
# check:
|
||||
# res[i].key.get == key
|
||||
# res[i].data == val
|
||||
|
||||
(await iter.dispose()).tryGet
|
||||
# (await iter.dispose()).tryGet
|
||||
|
||||
test "Should apply sort order - descending":
|
||||
let
|
||||
key = Key.init("/a").tryGet
|
||||
q = Query.init(key, sort = SortOrder.Descending)
|
||||
# test "Should apply sort order - descending":
|
||||
# let
|
||||
# key = Key.init("/a").tryGet
|
||||
# q = Query.init(key, sort = SortOrder.Descending)
|
||||
|
||||
var kvs: seq[QueryResponse]
|
||||
for i in 0..<100:
|
||||
let
|
||||
k = Key.init(key, Key.init("/" & $i).tryGet).tryGet
|
||||
val = ("val " & $i).toBytes
|
||||
# var kvs: seq[QueryResponse]
|
||||
# for i in 0..<100:
|
||||
# let
|
||||
# k = Key.init(key, Key.init("/" & $i).tryGet).tryGet
|
||||
# val = ("val " & $i).toBytes
|
||||
|
||||
kvs.add((k.some, val))
|
||||
(await ds.put(k, val)).tryGet
|
||||
# kvs.add((k.some, val))
|
||||
# (await ds.put(k, val)).tryGet
|
||||
|
||||
# lexicographic sort, as it comes from the backend
|
||||
kvs.sort do (a, b: QueryResponse) -> int:
|
||||
cmp(a.key.get.id, b.key.get.id)
|
||||
# # lexicographic sort, as it comes from the backend
|
||||
# kvs.sort do (a, b: QueryResponse) -> int:
|
||||
# cmp(a.key.get.id, b.key.get.id)
|
||||
|
||||
kvs = kvs.reversed
|
||||
let
|
||||
iter = (await ds.query(q)).tryGet
|
||||
res = block:
|
||||
var
|
||||
res: seq[QueryResponse]
|
||||
cnt = 0
|
||||
# kvs = kvs.reversed
|
||||
# let
|
||||
# iter = (await ds.query(q)).tryGet
|
||||
# res = block:
|
||||
# var
|
||||
# res: seq[QueryResponse]
|
||||
# cnt = 0
|
||||
|
||||
for pair in iter:
|
||||
let (key, val) = (await pair).tryGet
|
||||
if key.isNone:
|
||||
break
|
||||
# for pair in iter:
|
||||
# let (key, val) = (await pair).tryGet
|
||||
# if key.isNone:
|
||||
# break
|
||||
|
||||
res.add((key, val))
|
||||
cnt.inc
|
||||
# res.add((key, val))
|
||||
# cnt.inc
|
||||
|
||||
res
|
||||
# res
|
||||
|
||||
check:
|
||||
res.len == 100
|
||||
# check:
|
||||
# res.len == 100
|
||||
|
||||
for i, r in res[1..^1]:
|
||||
check:
|
||||
res[i].key.get == kvs[i].key.get
|
||||
res[i].data == kvs[i].data
|
||||
# for i, r in res[1..^1]:
|
||||
# check:
|
||||
# res[i].key.get == kvs[i].key.get
|
||||
# res[i].data == kvs[i].data
|
||||
|
||||
(await iter.dispose()).tryGet
|
||||
# (await iter.dispose()).tryGet
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user