sql

package

v0.2.0 Latest Latest Go to latest Published: Mar 6, 2025 License: MIT Imports: 16 Imported by: 0

Details

This section is empty.

View Source

var ErrNoRows = sql.ErrNoRows

This section is empty.

type Helper struct {
	DB    *sqlx.DB
	JobsQ *goqite.Queue
	// contains filtered or unexported fields
}

func NewHelper(opts NewHelperOptions) *Helper

NewHelper with the given options. If no logger is provided, logs are discarded.

func (h *Helper) Connect() error

func (h *Helper) Exec(ctx context.Context, query string, args ...any) error

func (h *Helper) Get(ctx context.Context, dest any, query string, args ...any) error

func (h *Helper) InTransaction(ctx context.Context, callback func(tx *Tx) error) (err error)

InTransaction runs callback in a transaction, and makes sure to handle rollbacks, commits etc.

func (h *Helper) MigrateDown(ctx context.Context) error

func (h *Helper) MigrateUp(ctx context.Context) error

func (h *Helper) Ping(ctx context.Context) error

func (h *Helper) Select(ctx context.Context, dest any, query string, args ...any) error

type NewHelperOptions struct {
	Log  *slog.Logger
	Path string
}

type Tx struct {
	Tx *sqlx.Tx
}

func (t *Tx) Exec(ctx context.Context, query string, args ...any) error

func (t *Tx) Get(ctx context.Context, dest any, query string, args ...any) error

func (t *Tx) Select(ctx context.Context, dest any, query string, args ...any) error