hanzo-devandClaude Opus 4.8
764539773a
Fork of ncruces/go-sqlite3 (MIT, retained). Renames module to github.com/hanzoai/sqlite3 (wasm blob stays upstream ncruces/go-sqlite3-wasm) and adds the hanzovfs package: a pure-Go, no-FUSE SQLite VFS that seals pages with ChaCha20-Poly1305 (per-tenant DEK, HIP-0302) for per-tenant SQLite ⇒ hanzoai/vfs ⇒ S3. Deprecates modernc.org/sqlite (no custom-VFS hook) and direct ncruces use. Benchmarked 3.6x faster writes / ~92x faster point-reads than FUSE; encryption ~free. Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
80 lines
1.5 KiB
Go
80 lines
1.5 KiB
Go
package tests
|
|
|
|
import (
|
|
"encoding/json"
|
|
"math"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/hanzoai/sqlite3"
|
|
"github.com/hanzoai/sqlite3/driver"
|
|
"github.com/hanzoai/sqlite3/internal/testcfg"
|
|
"github.com/hanzoai/sqlite3/vfs/memdb"
|
|
"github.com/ncruces/julianday"
|
|
)
|
|
|
|
func TestJSON(t *testing.T) {
|
|
t.Parallel()
|
|
dsn := memdb.TestDB(t)
|
|
|
|
ctx := testcfg.Context(t)
|
|
db, err := driver.Open(dsn)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
defer db.Close()
|
|
|
|
conn, err := db.Conn(ctx)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
defer conn.Close()
|
|
|
|
_, err = conn.ExecContext(ctx, `CREATE TABLE test (col)`)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
reference := time.Date(2013, 10, 7, 4, 23, 19, 120_000_000, time.FixedZone("", -4*3600))
|
|
|
|
_, err = conn.ExecContext(ctx,
|
|
`INSERT INTO test (col) VALUES (?), (?), (?), (?)`,
|
|
nil, 1, math.Pi, reference,
|
|
)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
_, err = conn.ExecContext(ctx,
|
|
`INSERT INTO test (col) VALUES (?), (?), (?), (?)`,
|
|
sqlite3.JSON(math.Pi), sqlite3.JSON(false),
|
|
julianday.Format(reference), sqlite3.JSON([]string{}))
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
rows, err := conn.QueryContext(ctx, "SELECT * FROM test")
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
defer rows.Close()
|
|
|
|
want := []string{
|
|
"null", "1", "3.141592653589793",
|
|
`"2013-10-07T04:23:19.12-04:00"`,
|
|
"3.141592653589793", "false",
|
|
"2456572.849526851851852", "[]",
|
|
}
|
|
for rows.Next() {
|
|
var got json.RawMessage
|
|
err = rows.Scan(sqlite3.JSON(&got))
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if string(got) != want[0] {
|
|
t.Errorf("got %q, want %q", got, want[0])
|
|
}
|
|
want = want[1:]
|
|
}
|
|
}
|