db

Apr 2, 2024

Changes in this version

type Query

+ Columns []*sql.ColumnType

+ InArgs []any

+ OutArgs []any

+ type Queryable interface

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

+ PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error)

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

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

+ type Runner func(many []Runnable, ctx context.Context, able Queryable) error

+ func NewPooledRunner(poolSize int) Runner

Dec 1, 2022

Changes in this version

+ func RunConcurrently(many []Runnable, ctx context.Context, conn *sql.Conn) error

+ func RunPooled(many []Runnable, ctx context.Context, conn *sql.Conn, poolSize int) error

+ func RunSequential(many []Runnable, ctx context.Context, conn *sql.Conn) error

+ type Query struct

+ Create func() R

+ In map[string]any

+ LastID int64

+ Out map[string]any

+ Prepared bool

+ Query string

+ Result *R

+ Results QueryResult[R]

+ RowsAffected int64

+ func (q *Query[R]) GetArgs() []any

+ func (q *Query[R]) NewRow() *R

+ func (q *Query[R]) Run(ctx context.Context, conn *sql.Conn) error

+ func (q *Query[R]) SetColumns(columns []string)

+ func (q Query[R]) GetValues(row *R) []any

+ type QueryResult interface

+ Add func(result R) bool

+ type QuerySlice struct

+ Max int

+ Slice *[]R

+ func (st *QuerySlice[R]) Add(result R) bool

+ type Runnable interface

+ Run func(ctx context.Context, conn *sql.Conn) error