ehmry
/
sqlite_actor
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Adjust to Syndicate API

This commit is contained in:
Emery Hemingway 2023-10-10 09:26:46 +01:00
parent 4b55b2774e
commit e03df9a2e8
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
sqlite_actor.nimble
View File

@ -1,4 +1,4 @@
version = "20230527" version = "20231010"
author = "Emery Hemingway" author = "Emery Hemingway"
description = "Syndicate Actor for accessing SQLite databases" description = "Syndicate Actor for accessing SQLite databases"
license = "Unlicense" license = "Unlicense"

8
src/sqlite_actor.nim
View File

@ -51,7 +51,7 @@ proc finalize(stmt: Stmt): cint {.importSqlite3.}
doAssert libversion_number() == SQLITE_VERSION_NUMBER doAssert libversion_number() == SQLITE_VERSION_NUMBER
import preserves, syndicate import preserves, syndicate, syndicate/relays
import ./sql import ./sql
proc logError(db: Sqlite3; context: string) = proc logError(db: Sqlite3; context: string) =
@ -61,7 +61,7 @@ type
Value = Preserve[void] Value = Preserve[void]
Args {.preservesDictionary.} = object Args {.preservesDictionary.} = object
database: string database: string
dataspace: Ref dataspace: Cap
proc extractValue(stmt: Stmt; col: cint): Value = proc extractValue(stmt: Stmt; col: cint): Value =
case column_type(stmt, col) case column_type(stmt, col)
@ -84,9 +84,9 @@ proc extractRecord(stmt: Stmt; label: Value, arity: cint): Value =
result = initRecord(label, arity) result = initRecord(label, arity)
for col in 0..<arity: result.record[col] = extractValue(stmt, col) for col in 0..<arity: result.record[col] = extractValue(stmt, col)
runActor("main") do (root: Ref; turn: var Turn): runActor("main") do (root: Cap; turn: var Turn):
connectStdio(root, turn) connectStdio(root, turn)
during(turn, root, ?Args) do (path: string, ds: Ref): during(turn, root, ?Args) do (path: string, ds: Cap):
var db: Sqlite3 var db: Sqlite3
if open_v2(path, addr db, SQLITE_OPEN_READONLY, nil) != SQLITE_OK: if open_v2(path, addr db, SQLITE_OPEN_READONLY, nil) != SQLITE_OK:
logError(db, path) logError(db, path)