sql

README

gosql

Documentation

Index

• func AtP(index int) string
• func Colon(index int) string
• func Configure(f func(Config) Config)
• func Dollar(index int) string
• func PanicOnLogicalError(err error)
• func PrintLogicalError(err error)
• func Question(index int) string
• type Config
• type DB
  • func Open(driverName string, dataSource string) (db *DB, err error)
  • func (d *DB) Begin(ctx context.Context, options *TxOptions) (txCtx context.Context, err error)
  • func (d *DB) Commit(ctx context.Context) (err error)
  • func (d *DB) End(ctx context.Context, txErr error) (commitErr error, rollbackErr error)
  • func (d *DB) Exec(query string, arg ...any) (result Result, err error)
  • func (d *DB) ExecContext(ctx context.Context, query string, arg ...any) (result Result, err error)
  • func (d *DB) Executor(ctx context.Context) (executor Executor)
  • func (d *DB) NamedExec(query string, args map[string]any) (result Result, err error)
  • func (d *DB) NamedExecContext(ctx context.Context, query string, args map[string]any) (result Result, err error)
  • func (d *DB) NamedQuery(query string, args map[string]any) (rows *Rows, err error)
  • func (d *DB) NamedQueryContext(ctx context.Context, query string, args map[string]any) (rows *Rows, err error)
  • func (d *DB) Query(query string, args ...any) (rows *Rows, err error)
  • func (d *DB) QueryContext(ctx context.Context, query string, args ...any) (rows *Rows, err error)
  • func (d *DB) Rollback(ctx context.Context) (err error)
  • func (d *DB) Transactional(ctx context.Context, f func(ctx context.Context) error, options *TxOptions) (beginErr error, err error, commitErr error, rollbackErr error)
• type Executor
• type Frame
  • func (f Frame) File() string
  • func (f Frame) Func() string
  • func (f Frame) Line() int
• type Placeholder
• type Result
• type Rows
• type StackTrace
• type Tx
  • func (t *Tx) Commit() (err error)
  • func (t *Tx) Exec(query string, arg ...any) (result Result, err error)
  • func (t *Tx) ExecContext(ctx context.Context, query string, arg ...any) (result Result, err error)
  • func (t *Tx) NamedExec(query string, args map[string]any) (result Result, err error)
  • func (t *Tx) NamedExecContext(ctx context.Context, query string, args map[string]any) (result Result, err error)
  • func (t *Tx) NamedQuery(query string, args map[string]any) (rows *Rows, err error)
  • func (t *Tx) NamedQueryContext(ctx context.Context, query string, args map[string]any) (rows *Rows, err error)
  • func (t *Tx) Query(query string, args ...any) (rows *Rows, err error)
  • func (t *Tx) QueryContext(ctx context.Context, query string, args ...any) (rows *Rows, err error)
  • func (t *Tx) Rollback() (err error)
• type TxController
• type TxOptions

Functions

func AtP

func AtP(index int) string

func Colon

func Colon(index int) string

func Configure

func Configure(f func(Config) Config)

func Dollar

func Dollar(index int) string

func PanicOnLogicalError

func PanicOnLogicalError(err error)

func PrintLogicalError

func PrintLogicalError(err error)

func Question

func Question(index int) string

Types

type Config

type Config struct {
	Placeholder         Placeholder
	LogicalErrorHandler func(err error)
}

type DB

type DB sql.DB

func Open

func Open(driverName string, dataSource string) (db *DB, err error)

func (*DB) Begin

func (d *DB) Begin(ctx context.Context, options *TxOptions) (txCtx context.Context, err error)

func (*DB) Commit

func (d *DB) Commit(ctx context.Context) (err error)

func (*DB) End

func (d *DB) End(ctx context.Context, txErr error) (commitErr error, rollbackErr error)

func (*DB) Exec

func (d *DB) Exec(query string, arg ...any) (result Result, err error)

func (*DB) ExecContext

func (d *DB) ExecContext(ctx context.Context, query string, arg ...any) (result Result, err error)

func (*DB) Executor

func (d *DB) Executor(ctx context.Context) (executor Executor)

func (*DB) NamedExec

func (d *DB) NamedExec(query string, args map[string]any) (result Result, err error)

func (*DB) NamedExecContext

func (d *DB) NamedExecContext(ctx context.Context, query string, args map[string]any) (result Result, err error)

func (*DB) NamedQuery

func (d *DB) NamedQuery(query string, args map[string]any) (rows *Rows, err error)

func (*DB) NamedQueryContext

func (d *DB) NamedQueryContext(ctx context.Context, query string, args map[string]any) (rows *Rows, err error)

func (*DB) Query

func (d *DB) Query(query string, args ...any) (rows *Rows, err error)

func (*DB) QueryContext

func (d *DB) QueryContext(ctx context.Context, query string, args ...any) (rows *Rows, err error)

func (*DB) Rollback

func (d *DB) Rollback(ctx context.Context) (err error)

func (*DB) Transactional

func (d *DB) Transactional(
	ctx context.Context,
	f func(ctx context.Context) error,
	options *TxOptions,
) (beginErr error, err error, commitErr error, rollbackErr error)

type Executor

type Executor interface {
	Exec(query string, args ...any) (result Result, err error)
	NamedExec(query string, args map[string]any) (result Result, err error)

	ExecContext(ctx context.Context, query string, args ...any) (result Result, err error)
	NamedExecContext(ctx context.Context, query string, args map[string]any) (result Result, err error)

	Query(query string, args ...any) (rows *Rows, err error)
	NamedQuery(query string, args map[string]any) (rows *Rows, err error)

	QueryContext(ctx context.Context, query string, args ...any) (rows *Rows, err error)
	NamedQueryContext(ctx context.Context, query string, args map[string]any) (rows *Rows, err error)
}

type Frame

type Frame uintptr

func (Frame) File

func (f Frame) File() string

func (Frame) Func

func (f Frame) Func() string

func (Frame) Line

func (f Frame) Line() int

type Placeholder

type Placeholder = func(index int) string

type Result

type Result = sql.Result

type Rows

type Rows = sql.Rows

type StackTrace

type StackTrace []Frame

type Tx

type Tx sql.Tx

func (*Tx) Commit

func (t *Tx) Commit() (err error)

func (*Tx) Exec

func (t *Tx) Exec(query string, arg ...any) (result Result, err error)

func (*Tx) ExecContext

func (t *Tx) ExecContext(ctx context.Context, query string, arg ...any) (result Result, err error)

func (*Tx) NamedExec

func (t *Tx) NamedExec(query string, args map[string]any) (result Result, err error)

func (*Tx) NamedExecContext

func (t *Tx) NamedExecContext(ctx context.Context, query string, args map[string]any) (result Result, err error)

func (*Tx) NamedQuery

func (t *Tx) NamedQuery(query string, args map[string]any) (rows *Rows, err error)

func (*Tx) NamedQueryContext

func (t *Tx) NamedQueryContext(ctx context.Context, query string, args map[string]any) (rows *Rows, err error)

func (*Tx) Query

func (t *Tx) Query(query string, args ...any) (rows *Rows, err error)

func (*Tx) QueryContext

func (t *Tx) QueryContext(ctx context.Context, query string, args ...any) (rows *Rows, err error)

func (*Tx) Rollback

func (t *Tx) Rollback() (err error)

type TxController

type TxController interface {
	Transactional(
		ctx context.Context,
		f func(ctx context.Context) error,
		options *TxOptions,
	) (beginErr error, err error, commitErr error, rollbackErr error)
	Begin(ctx context.Context, options *TxOptions) (txCtx context.Context, err error)
	End(ctx context.Context, txErr error) (rollbackErr error, commitErr error)
	Commit(ctx context.Context) (err error)
	Rollback(ctx context.Context) (err error)
}

type TxOptions

type TxOptions = sql.TxOptions