database

Documentation

Index

• type DB
  • func Open(path string) (*DB, error)
  • func (db *DB) Close() error
  • func (db *DB) Exec(query string, args ...any) (sql.Result, error)
  • func (db *DB) Migrate() error
  • func (db *DB) Query(query string, args ...any) (*sql.Rows, error)
  • func (db *DB) QueryRow(query string, args ...any) *sql.Row
  • func (db *DB) RunInTx(fn func() error) error
• type DBTX

Types

type DB

type DB struct {
	Conn *sql.DB
	// contains filtered or unexported fields
}

func Open

func Open(path string) (*DB, error)

func (*DB) Close

func (db *DB) Close() error

func (*DB) Exec

func (db *DB) Exec(query string, args ...any) (sql.Result, error)

Exec delegates to the active transaction if present, otherwise to Conn.

func (*DB) Migrate

func (db *DB) Migrate() error

func (*DB) Query

func (db *DB) Query(query string, args ...any) (*sql.Rows, error)

Query delegates to the active transaction if present, otherwise to Conn.

func (*DB) QueryRow

func (db *DB) QueryRow(query string, args ...any) *sql.Row

QueryRow delegates to the active transaction if present, otherwise to Conn.

func (*DB) RunInTx

func (db *DB) RunInTx(fn func() error) error

RunInTx executes fn within a database transaction. If a transaction is already active (nested call), fn is called directly without creating a new transaction. On error or panic, the transaction is rolled back.

type DBTX

type DBTX interface {
	Exec(query string, args ...any) (sql.Result, error)
	Query(query string, args ...any) (*sql.Rows, error)
	QueryRow(query string, args ...any) *sql.Row
}

DBTX is the common interface between *sql.DB and *sql.Tx.