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

change to non-closure iterator

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-25 16:06:09 -07:00
parent 598f63c651
commit 7bb11c0e0b
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
2 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
datastore/backend.nim
View File

@ -32,6 +32,7 @@ type
DbQueryHandle*[T] = object
query*: DbQuery
cancel*: bool
closed*: bool
env*: T
DbQueryResponse* = tuple[key: Option[KeyId], data: DataBuffer]

12
datastore/sql/sqliteds.nim
View File

@ -163,12 +163,13 @@ proc query*(
success DbQueryHandle[RawStmtPtr](query: query, env: s)
proc close*(handle: DbQueryHandle[RawStmtPtr]) =
proc close*(handle: var DbQueryHandle[RawStmtPtr]) =
if not handle.closed:
handle.closed = true
echo "sqlite backend: query: finally close"
discard sqlite3_reset(handle.env)
discard sqlite3_clear_bindings(handle.env)
handle.env.dispose()
return
iterator iter*(handle: var DbQueryHandle[RawStmtPtr]): ?!DbQueryResponse =
while not handle.cancel:
@ -211,15 +212,16 @@ iterator iter*(handle: var DbQueryHandle[RawStmtPtr]): ?!DbQueryResponse =
echo "SQLITE ROW: yield"
yield success (key.some, data)
of SQLITE_DONE:
echo "SQLITE DONE: return"
echo "SQLITE DONE: yield"
handle.close()
break
else:
echo "SQLITE ERROR: return"
echo "SQLITE ERROR: yield"
handle.cancel = true
yield DbQueryResponse.failure newException(DatastoreError, $sqlite3_errstr(v))
break
handle.close()
proc contains*(self: SQLiteBackend, key: DbKey): bool =