db

Documentation

Index

• Variables
• func Drop(_ string) error
• func DumpSchema(_ string) error
• func Migrate(_ string) error
• func MustConnectOnce()
• func Rollback(_ string) error
• func WalCleanup(_ string) error
• type DbWrapper
  • func (db DbWrapper) Close() error
  • func (db DbWrapper) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
  • func (db DbWrapper) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
  • func (db DbWrapper) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
  • func (db DbWrapper) QueryRowxContext(ctx context.Context, query string, args ...any) *sqlx.Row
  • func (db DbWrapper) SelectContext(ctx context.Context, dest any, query string, args ...any) error
  • func (db DbWrapper) Transaction(ctx context.Context, fn func(tx *sqlx.Tx) error) error

Variables

var ErrDropFailed = errors.New("failed to run database rollback")

var ErrMigrationFailed = errors.New("failed to run database migration")

var ErrRollbackFailed = errors.New("failed to run database rollback")

Functions

func Drop

func Drop(_ string) error

func DumpSchema

func DumpSchema(_ string) error

func Migrate

func Migrate(_ string) error

func MustConnectOnce

func MustConnectOnce()

func Rollback

func Rollback(_ string) error

func WalCleanup

func WalCleanup(_ string) error

Types

type DbWrapper

type DbWrapper struct {
	// contains filtered or unexported fields
}

var Db DbWrapper

func (DbWrapper) Close

func (db DbWrapper) Close() error

func (DbWrapper) ExecContext

func (db DbWrapper) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)

func (DbWrapper) QueryContext

func (db DbWrapper) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)

func (DbWrapper) QueryRowContext

func (db DbWrapper) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row

func (DbWrapper) QueryRowxContext

func (db DbWrapper) QueryRowxContext(ctx context.Context, query string, args ...any) *sqlx.Row

func (DbWrapper) SelectContext

func (db DbWrapper) SelectContext(ctx context.Context, dest any, query string, args ...any) error

func (DbWrapper) Transaction

func (db DbWrapper) Transaction(ctx context.Context, fn func(tx *sqlx.Tx) error) error