Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

sqlite

package module

Go to main page

Versions in this module

v0

v0.0.5

May 4, 2026

v0.0.4

Apr 14, 2026

Changes in this version

+ type Action int

+ const ActionBegin

+ const ActionCommit

+ const ActionExec

+ const ActionQuery

+ const ActionRollback

type BufferWriter

+ func (bw *BufferWriter) Begin() (*Tx, error)

type DB

+ func (db *DB) BeginTx(ctx context.Context, opts *sql.TxOptions) (*Tx, error)

type Task

+ func (t *Task) Action() Action

type TaskFunc

+ func BeginTx() TaskFunc

+ func Rollback() TaskFunc

+ Action func() Action

type TaskResult

+ Buffered bool

v0.0.3

Apr 12, 2026

Changes in this version

type BufferConfig

+ func DefaultBufferConfig() BufferConfig

v0.0.2

Apr 12, 2026

Changes in this version

+ type BufferWriter struct

+ func (w *BufferWriter) BeginTx(ctx context.Context, opts *sql.TxOptions) (*Tx, error)

+ func (w *BufferWriter) Close() error

+ func (w *BufferWriter) Exec(query string, args ...any) (sql.Result, error)

+ func (w *BufferWriter) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)

+ func (w *BufferWriter) Flush() error

type DB

+ func (db *DB) Flush() error

v0.0.1

Apr 12, 2026

Changes in this version

+ var ErrClosed = errors.New("sqlite: writer is closed")

+ var ErrTxNotready = errors.New("sqlite: transaction not ready")

+ type BufferConfig struct

+ FlushInterval time.Duration

+ Size int

+ func (c *BufferConfig) Validate()

+ type DB struct

+ Reader *sql.DB

+ Writer *Writer

+ func New(ctx context.Context, dsn string) (*DB, error)

+ func Open(ctx context.Context, dsn string) (*DB, error)

+ func (db *DB) Close() error

+ func (db *DB) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (db *DB) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (db *DB) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (db *DB) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (db *DB) QueryRow(query string, args ...interface{}) *sql.Row

+ func (db *DB) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

+ type Savepoint struct

+ func NewSavepoint(tx *sql.Tx) (*Savepoint, error)

+ func (s *Savepoint) Name() string

+ func (s *Savepoint) Release()

+ func (s *Savepoint) Rollback()

+ type Task struct

+ func (t *Task) Exec(tx *sql.Tx) TaskResult

+ func (t *Task) Flush() bool

+ func (t *Task) Notify() chan TaskResult

+ type TaskArgs struct

+ type TaskFunc interface

+ Exec func(w *sql.Tx) TaskResult

+ Flush func() bool

+ Notify func() chan TaskResult

+ func Commit(tasks []TaskArgs) TaskFunc

+ func Exec(query string, args ...any) TaskFunc

+ func Query(query string, args ...any) TaskFunc

+ func QueryRow(query string, args ...any) TaskFunc

+ type TaskResult struct

+ Error error

+ Result any

+ type Tx struct

+ func (btx *Tx) Commit() error

+ func (btx *Tx) Exec(query string, args ...any) (sql.Result, error)

+ func (btx *Tx) Rollback() error

+ type Writer struct

+ func NewWriter(db *sql.DB, cfg BufferConfig) *Writer

+ func (w *Writer) BeginTx(ctx context.Context, opts *sql.TxOptions) (*Tx, error)

+ func (w *Writer) Close() error

+ func (w *Writer) Commit() error

+ func (w *Writer) Exec(query string, args ...any) (sql.Result, error)

+ func (w *Writer) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)