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

query fixes

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-25 20:58:26 -07:00
parent 0c72ad8478
commit 73ec70fa95
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
datastore/sql.nim
View File

@ -51,9 +51,9 @@ method put*(self: SQLiteDatastore,
method put*(self: SQLiteDatastore,
batch: seq[BatchEntry]): Future[?!void] {.async.} =
var dbatch: seq[tuple[key: string, data: seq[byte]]]
var dbatch: seq[tuple[key: KeyId, data: DataBuffer]]
for entry in batch:
dbatch.add((entry.key.id(), entry.data))
dbatch.add((KeyId.new entry.key.id(), DataBuffer.new entry.data))
self.db.put(dbatch)
method close*(self: SQLiteDatastore): Future[?!void] {.async.} =
@ -65,12 +65,12 @@ method query*(
): Future[?!QueryIter] {.async.} =
var iter = QueryIter()
let dbquery = DbQuery(
key: KeyId.new query.key.id(),
value: query.value,
limit: query.limit,
offset: query.offset,
sort: query.sort,
let dbquery = dbQuery(
key= KeyId.new query.key.id(),
value= query.value,
limit= query.limit,
offset= query.offset,
sort= query.sort,
)
var queries = ? self.db.query(dbquery)