storage

Documentation

Index

• Variables
• type BaseStorage
  • func NewBaseStorage(store *connection.Store) *BaseStorage
  • func (r *BaseStorage) SetTxToContext(ctx context.Context, tx *sqlx.Tx) context.Context
  • func (r *BaseStorage) WithTransaction(ctx context.Context, fn TransactionFunc) error
• type SQLExec
• type SQLQuery
• type SQLQueryExec
• type TransactionFunc

Variables

var (
	ErrSQLTransactionNoTrx        = errors.New("error on getting transaction context. no transaction available")
	ErrSQLTransactionFailedTrx    = errors.New("error on performing transactional request")
	ErrSQLTransactionFailedCommit = errors.New("failed to commit transaction")
)

transactional SQL error

Types

type BaseStorage

type BaseStorage struct {
	Storage *connection.Store
}

func NewBaseStorage

func NewBaseStorage(store *connection.Store) *BaseStorage

func (*BaseStorage) SetTxToContext

func (r *BaseStorage) SetTxToContext(ctx context.Context, tx *sqlx.Tx) context.Context

set transaction to context

func (*BaseStorage) WithTransaction

func (r *BaseStorage) WithTransaction(ctx context.Context, fn TransactionFunc) error

wrapper function to handle transaction process

type SQLExec

type SQLExec interface {
	sqlx.Execer
	sqlx.ExecerContext
	NamedExec(query string, arg interface{}) (sql.Result, error)
	NamedExecContext(ctx context.Context, query string, arg interface{}) (sql.Result, error)
}

type SQLQuery

type SQLQuery interface {
	sqlx.Queryer
	GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
	SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
	PrepareNamedContext(ctx context.Context, query string) (*sqlx.NamedStmt, error)
}

type SQLQueryExec

type SQLQueryExec interface {
	SQLExec
	SQLQuery
	Rebind(query string) string
}

type TransactionFunc

type TransactionFunc func(ctx context.Context) error