sqlite-vec/examples/simple-go-ncruces/demo.go

102 lines
1.7 KiB
Go
Raw Normal View History

2024-07-11 22:36:18 -07:00
package main
import (
_ "embed"
"log"
2024-07-16 23:11:26 -07:00
sqlite_vec "github.com/asg017/sqlite-vec-go-bindings/ncruces"
2024-07-11 22:36:18 -07:00
"github.com/ncruces/go-sqlite3"
)
func main() {
2024-07-12 16:59:55 -07:00
db, err := sqlite3.Open(":memory:")
2024-07-11 22:36:18 -07:00
if err != nil {
log.Fatal(err)
}
stmt, _, err := db.Prepare(`SELECT sqlite_version(), vec_version()`)
if err != nil {
log.Fatal(err)
}
2024-07-12 16:59:55 -07:00
stmt.Step()
2024-07-16 22:28:15 -07:00
log.Printf("sqlite_version=%s, vec_version=%s\n", stmt.ColumnText(0), stmt.ColumnText(1))
2024-07-23 14:16:34 -07:00
stmt.Close()
2024-07-12 16:59:55 -07:00
2024-07-11 22:36:18 -07:00
err = db.Exec("CREATE VIRTUAL TABLE vec_items USING vec0(embedding float[4])")
if err != nil {
log.Fatal(err)
}
items := map[int][]float32{
1: {0.1, 0.1, 0.1, 0.1},
2: {0.2, 0.2, 0.2, 0.2},
3: {0.3, 0.3, 0.3, 0.3},
4: {0.4, 0.4, 0.4, 0.4},
5: {0.5, 0.5, 0.5, 0.5},
}
q := []float32{0.3, 0.3, 0.3, 0.3}
stmt, _, err = db.Prepare("INSERT INTO vec_items(rowid, embedding) VALUES (?, ?)")
if err != nil {
log.Fatal(err)
}
for id, values := range items {
2024-07-16 23:11:26 -07:00
v, err := sqlite_vec.SerializeFloat32(values)
2024-07-11 22:36:18 -07:00
if err != nil {
log.Fatal(err)
}
stmt.BindInt(1, id)
stmt.BindBlob(2, v)
err = stmt.Exec()
if err != nil {
log.Fatal(err)
}
stmt.Reset()
}
stmt.Close()
stmt, _, err = db.Prepare(`
SELECT
rowid,
distance
FROM vec_items
WHERE embedding MATCH ?
ORDER BY distance
LIMIT 3
`);
if err != nil {
log.Fatal(err)
}
2024-07-16 23:11:26 -07:00
query, err := sqlite_vec.SerializeFloat32(q)
2024-07-11 22:36:18 -07:00
if err != nil {
log.Fatal(err)
}
stmt.BindBlob(1, query)
for stmt.Step() {
rowid := stmt.ColumnInt64(0)
distance := stmt.ColumnFloat(1)
2024-07-16 22:28:15 -07:00
log.Printf("rowid=%d, distance=%f\n", rowid, distance)
2024-07-11 22:36:18 -07:00
}
if err := stmt.Err(); err != nil {
log.Fatal(err)
}
err = stmt.Close()
if err != nil {
log.Fatal(err)
}
err = db.Close()
if err != nil {
log.Fatal(err)
}
}