(dbPath string)
| 21 | } |
| 22 | |
| 23 | func New(dbPath string) (*DB, error) { |
| 24 | db, err := sql.Open("sqlite3", dbPath) |
| 25 | if err != nil { |
| 26 | return nil, fmt.Errorf("failed to open SQLite database: %w", err) |
| 27 | } |
| 28 | |
| 29 | return &DB{ |
| 30 | q: sqlitedb.New(db), |
| 31 | }, nil |
| 32 | } |
| 33 | |
| 34 | func (d *DB) IncrementTx(ctx context.Context, id db.GraphID) (db.Tx, error) { |
| 35 | res, err := d.q.IncrementTx(ctx, string(id)) |