logos-storage/nim-datastore
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-datastore.git synced 2026-01-04 22:53:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

enable sqllite threading tests

Browse Source
This commit is contained in:
Dmitriy Ryajov 2023-09-14 17:56:20 -06:00
parent f0038127c8
commit af310306ad
No known key found for this signature in database
GPG Key ID: DA8C680CE7C657A4
2 changed files with 59 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

81
tests/datastore/querycommontests.nim
View File

@ -41,8 +41,8 @@ template queryTests*(ds: Datastore, extended = true) {.dirty.} =
res: seq[QueryResponse]
cnt = 0
while not iter.finished:
let (key, val) = (await iter.next()).tryGet
for pair in iter:
let (key, val) = (await pair).tryGet
if key.isNone:
break
@ -75,13 +75,17 @@ template queryTests*(ds: Datastore, extended = true) {.dirty.} =
let
iter = (await ds.query(q)).tryGet
res = block:
var res: seq[QueryResponse]
while not iter.finished:
let (key, val) = (await iter.next()).tryGet
var
res: seq[QueryResponse]
cnt = 0
for pair in iter:
let (key, val) = (await pair).tryGet
if key.isNone:
break
res.add((key, val))
cnt.inc
res
@ -109,13 +113,17 @@ template queryTests*(ds: Datastore, extended = true) {.dirty.} =
let
iter = (await ds.query(q)).tryGet
res = block:
var res: seq[QueryResponse]
while not iter.finished:
let (key, val) = (await iter.next()).tryGet
var
res: seq[QueryResponse]
cnt = 0
for pair in iter:
let (key, val) = (await pair).tryGet
if key.isNone:
break
res.add((key, val))
cnt.inc
res
@ -143,13 +151,17 @@ template queryTests*(ds: Datastore, extended = true) {.dirty.} =
var
res = block:
var res: seq[QueryResponse]
while not iter.finished:
let (key, val) = (await iter.next()).tryGet
var
res: seq[QueryResponse]
cnt = 0
for pair in iter:
let (key, val) = (await pair).tryGet
if key.isNone:
break
res.add((key, val))
cnt.inc
res
@ -184,9 +196,20 @@ template queryTests*(ds: Datastore, extended = true) {.dirty.} =
let
iter = (await ds.query(q)).tryGet
res = (await allFinished(toSeq(iter)))
.mapIt( it.read.tryGet )
.filterIt( it.key.isSome )
res = block:
var
res: seq[QueryResponse]
cnt = 0
for pair in iter:
let (key, val) = (await pair).tryGet
if key.isNone:
break
res.add((key, val))
cnt.inc
res
check:
res.len == 10
@ -208,13 +231,17 @@ template queryTests*(ds: Datastore, extended = true) {.dirty.} =
let
iter = (await ds.query(q)).tryGet
res = block:
var res: seq[QueryResponse]
while not iter.finished:
let (key, val) = (await iter.next()).tryGet
var
res: seq[QueryResponse]
cnt = 0
for pair in iter:
let (key, val) = (await pair).tryGet
if key.isNone:
break
res.add((key, val))
cnt.inc
res
@ -238,13 +265,17 @@ template queryTests*(ds: Datastore, extended = true) {.dirty.} =
let
iter = (await ds.query(q)).tryGet
res = block:
var res: seq[QueryResponse]
while not iter.finished:
let (key, val) = (await iter.next()).tryGet
var
res: seq[QueryResponse]
cnt = 0
for pair in iter:
let (key, val) = (await pair).tryGet
if key.isNone:
break
res.add((key, val))
cnt.inc
res
@ -284,13 +315,17 @@ template queryTests*(ds: Datastore, extended = true) {.dirty.} =
let
iter = (await ds.query(q)).tryGet
res = block:
var res: seq[QueryResponse]
while not iter.finished:
let (key, val) = (await iter.next()).tryGet
var
res: seq[QueryResponse]
cnt = 0
for pair in iter:
let (key, val) = (await pair).tryGet
if key.isNone:
break
res.add((key, val))
cnt.inc
res

2
tests/datastore/testthreadproxyds.nim
View File

@ -52,4 +52,4 @@ suite "Test Query ThreadDatastore":
(await ds.close()).tryGet()
taskPool.shutdown()
queryTests(ds, false)
queryTests(ds, true)