Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

sqldb

package module

Go to main page

Versions in this module

v1

v1.0.2

Apr 26, 2024

v1.0.1

Apr 11, 2024

Changes in this version

+ const DefaultMaxRetryDelay

+ func ExecuteSQLTransactionWithRetry(ctx context.Context, makeTx MakeTx, rollbackTx RollbackTx, txBody TxBody, ...) error

+ type MakeTx func() (Tx, error)

+ type OnBackoff func(retry int, delay time.Duration)

+ type RollbackTx func(tx Tx) error

+ type TxBody func(tx Tx) error

v1.0.0

Apr 10, 2024

Changes in this version

+ const DefaultNumTxRetries

+ const DefaultRetryDelay

+ const PostgresTag — darwin/amd64, linux/amd64, windows/amd64

+ const Subsystem

+ var DefaultPostgresFixtureLifetime = 10 * time.Minute

+ var DefaultStoreTimeout = time.Second * 10

+ var ErrRetriesExceeded = errors.New("db tx retries exceeded")

+ func DisableLog()

+ func IsSerializationError(err error) bool

+ func MapSQLError(err error) error

+ func SQLInt32[T constraints.Integer](num T) sql.NullInt32

+ func SQLInt64[T constraints.Integer](num T) sql.NullInt64

+ func SQLStr(s string) sql.NullString

+ func SQLTime(t time.Time) sql.NullTime

+ func UseLogger(logger btclog.Logger)

+ type BaseDB struct

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

+ type BatchedQuerier interface

+ BeginTx func(ctx context.Context, options TxOptions) (*sql.Tx, error)

+ type BatchedTx interface

+ ExecTx func(ctx context.Context, txOptions TxOptions, txBody func(Q) error) error

+ type ErrSQLUniqueConstraintViolation struct

+ DBError error

+ func (e ErrSQLUniqueConstraintViolation) Error() string

+ type ErrSerializationError struct

+ DBError error

+ func (e ErrSerializationError) Error() string

+ func (e ErrSerializationError) Unwrap() error

+ type PostgresConfig struct

+ Dsn string

+ MaxConnections int

+ SkipMigrations bool

+ Timeout time.Duration

+ func (p *PostgresConfig) Validate() error

+ type PostgresStore struct

+ func NewPostgresStore(cfg *PostgresConfig) (*PostgresStore, error)

+ func NewTestPostgresDB(t *testing.T, fixture *TestPgFixture) *PostgresStore

+ type QueryCreator func(*sql.Tx) Q

+ type SqliteConfig struct

+ BusyTimeout time.Duration

+ MaxConnections int

+ PragmaOptions []string

+ SkipMigrations bool

+ Timeout time.Duration

+ type SqliteStore struct

+ func NewSqliteStore(cfg *SqliteConfig, dbPath string) (*SqliteStore, error)

+ func NewTestSqliteDB(t *testing.T) *SqliteStore

+ type TestPgFixture struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewTestPgFixture(t *testing.T, expiry time.Duration) *TestPgFixture

+ func (f *TestPgFixture) GetConfig(dbName string) *PostgresConfig

+ func (f *TestPgFixture) TearDown(t *testing.T)

+ type TransactionExecutor struct

+ func NewTransactionExecutor[Querier any](db BatchedQuerier, createQuery QueryCreator[Querier], opts ...TxExecutorOption) *TransactionExecutor[Querier]

+ func (t *TransactionExecutor[Q]) ExecTx(ctx context.Context, txOptions TxOptions, txBody func(Q) error) error

+ type Tx interface

+ Commit func() error

+ Rollback func() error

+ type TxExecutorOption func(*txExecutorOptions)

+ func WithTxRetries(numRetries int) TxExecutorOption

+ func WithTxRetryDelay(delay time.Duration) TxExecutorOption

+ type TxOptions interface

+ ReadOnly func() bool

Other modules containing this package

github.com/lightningnetwork/lnd