Something went wrong. Try again.
forked from tangled.org/core
Something went wrong. Try again.
1.1 kB · 52 lines
Go
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253package db
import ( "database/sql"
_ "github.com/mattn/go-sqlite3")
type DB struct { db *sql.DB}
func Setup(dbPath string) (*DB, error) { db, err := sql.Open("sqlite3", dbPath) if err != nil { return nil, err }
_, err = db.Exec(` pragma journal_mode = WAL; pragma synchronous = normal; pragma foreign_keys = on; pragma temp_store = memory; pragma mmap_size = 30000000000; pragma page_size = 32768; pragma auto_vacuum = incremental; pragma busy_timeout = 5000;
create table if not exists known_dids ( did text primary key );
create table if not exists public_keys ( id integer primary key autoincrement, did text not null, key text not null, created text not null default (strftime('%Y-%m-%dT%H:%M:%SZ', 'now')), unique(did, key), foreign key (did) references known_dids(did) on delete cascade );
create table if not exists _jetstream ( id integer primary key autoincrement, last_time_us integer not null ); `) if err != nil { return nil, err }
return &DB{db: db}, nil}