datasource

package
v0.0.0-...-543a005 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 4, 2023 License: MIT, MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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 {
	BeginTx(ctx context.Context, opts *sql.TxOptions) (tx *sql.Tx, err error)
	PingContext(ctx context.Context) (err error)
	io.Closer
	ConnTx
}

type ConnTx 

type ConnTx interface {
	ExecContext(ctx context.Context, query string, args ...interface{}) (res sql.Result, err error)
	PrepareContext(ctx context.Context, query string) (stmt *sql.Stmt, err error)
	QueryContext(ctx context.Context, query string, args ...interface{}) (rows *sql.Rows, err error)
	QueryRowContext(ctx context.Context, query string, args ...interface{}) (row *sql.Row)
}

type DataSource 

type DataSource struct{}

func (DataSource) EndTx 

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

func (DataSource) ExecSQL 

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

func (DataSource) QuerySQL 

func (DataSource) QuerySQL(sqlRows *sql.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)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.