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>
96 lines
2.0 KiB
Go
96 lines
2.0 KiB
Go
package gormlite
|
|
|
|
import (
|
|
"fmt"
|
|
"testing"
|
|
|
|
"gorm.io/gorm"
|
|
|
|
"github.com/hanzoai/sqlite3"
|
|
"github.com/hanzoai/sqlite3/driver"
|
|
"github.com/hanzoai/sqlite3/vfs/memdb"
|
|
)
|
|
|
|
func TestDialector(t *testing.T) {
|
|
dsn := memdb.TestDB(t)
|
|
|
|
// Custom connection with a custom function called "my_custom_function".
|
|
db, err := driver.Open(dsn, func(conn *sqlite3.Conn) error {
|
|
return conn.CreateFunction("my_custom_function", 0, sqlite3.DETERMINISTIC,
|
|
func(ctx sqlite3.Context, arg ...sqlite3.Value) {
|
|
ctx.ResultText("my-result")
|
|
})
|
|
})
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
rows := []struct {
|
|
description string
|
|
dialector gorm.Dialector
|
|
openSuccess bool
|
|
query string
|
|
querySuccess bool
|
|
}{
|
|
{
|
|
description: "Default driver",
|
|
dialector: Open(dsn),
|
|
openSuccess: true,
|
|
query: "SELECT 1",
|
|
querySuccess: true,
|
|
},
|
|
{
|
|
description: "Custom function",
|
|
dialector: Open(dsn),
|
|
openSuccess: true,
|
|
query: "SELECT my_custom_function()",
|
|
querySuccess: false,
|
|
},
|
|
{
|
|
description: "Custom connection",
|
|
dialector: OpenDB(db),
|
|
openSuccess: true,
|
|
query: "SELECT 1",
|
|
querySuccess: true,
|
|
},
|
|
{
|
|
description: "Custom connection, custom function",
|
|
dialector: OpenDB(db),
|
|
openSuccess: true,
|
|
query: "SELECT my_custom_function()",
|
|
querySuccess: true,
|
|
},
|
|
}
|
|
for rowIndex, row := range rows {
|
|
t.Run(fmt.Sprintf("%d/%s", rowIndex, row.description), func(t *testing.T) {
|
|
db, err := gorm.Open(row.dialector, &gorm.Config{})
|
|
if !row.openSuccess {
|
|
if err == nil {
|
|
t.Errorf("Expected Open to fail.")
|
|
}
|
|
return
|
|
}
|
|
|
|
if err != nil {
|
|
t.Errorf("Expected Open to succeed; got error: %v", err)
|
|
}
|
|
if db == nil {
|
|
t.Errorf("Expected db to be non-nil.")
|
|
}
|
|
if row.query != "" {
|
|
err = db.Exec(row.query).Error
|
|
if !row.querySuccess {
|
|
if err == nil {
|
|
t.Errorf("Expected query to fail.")
|
|
}
|
|
return
|
|
}
|
|
|
|
if err != nil {
|
|
t.Errorf("Expected query to succeed; got error: %v", err)
|
|
}
|
|
}
|
|
})
|
|
}
|
|
}
|