datasource

Documentation

Index

• Variables
• func NewDatabase(cfg config.DatabaseConfig) (*sqlx.DB, error)
• type Conn
• type ConnTx
• type DataSource
  • func (DataSource) EndTx(tx *sqlx.Tx, err error) error
  • func (DataSource) ExecSQL(sqlResult sql.Result, err error) exec
  • func (DataSource) QuerySQL(sqlRows *sqlx.Rows, err error) Query
• type Exec
• type Query

Variables

var (
	ErrNoColumnReturned   = errors.New("no columns returned")
	ErrDataNotFound       = errors.New("data not found")
	ErrInvalidArguments   = errors.New("invalid arguments for scan")
	ErrInvalidTransaction = errors.New("invalid transaction")
)

datasource errors

Functions

func NewDatabase

func NewDatabase(cfg config.DatabaseConfig) (*sqlx.DB, error)

Types

type Conn

type Conn interface {
	BeginTxx(ctx context.Context, opts *sql.TxOptions) (*sqlx.Tx, error)
	PingContext(ctx context.Context) (err error)
	io.Closer
	ConnTx
}

type ConnTx

type ConnTx interface {
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
	PreparexContext(ctx context.Context, query string) (*sqlx.Stmt, error)
	QueryxContext(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)
	QueryRowxContext(ctx context.Context, query string, args ...interface{}) *sqlx.Row
}

type DataSource

type DataSource struct{}

func (DataSource) EndTx

func (DataSource) EndTx(tx *sqlx.Tx, err error) error

func (DataSource) ExecSQL

func (DataSource) ExecSQL(sqlResult sql.Result, err error) exec

func (DataSource) QuerySQL

func (DataSource) QuerySQL(sqlRows *sqlx.Rows, err error) Query

type Exec

type Exec interface {
	Scan(rowsAffected, lastInsertID *int64) (err error)
}

type Query

type Query interface {
	Scan(row func(i int) utils.Array) (err error)
}