exec

Documentation

Index

• type Executor
  • func NewExecutor(db *sql.DB, logger logger.GpaLogger) *Executor
  • func (e *Executor) Exec(sql string, args ...interface{}) (sql.Result, error)
  • func (e *Executor) ExecContext(ctx context.Context, sql string, args ...interface{}) (sql.Result, error)
  • func (e *Executor) QueryContextRow(ctx context.Context, sql string, args ...interface{}) *sql.Row
  • func (e *Executor) QueryContextRows(ctx context.Context, sql string, args ...interface{}) (*sql.Rows, error)
  • func (e *Executor) QueryRow(sql string, args ...interface{}) *sql.Row
  • func (e *Executor) QueryRows(sql string, args ...interface{}) (*sql.Rows, error)
• type SQLExecutor
• type TXExecutor
  • func NewTXExecutor(ctx context.Context, db *sql.DB, logger logger.GpaLogger) (*TXExecutor, error)
  • func (tx *TXExecutor) Commit() error
  • func (tx *TXExecutor) Exec(sql string, args ...interface{}) (sql.Result, error)
  • func (tx *TXExecutor) ExecContext(ctx context.Context, sql string, args ...interface{}) (sql.Result, error)
  • func (tx *TXExecutor) QueryContextRow(ctx context.Context, sql string, args ...interface{}) *sql.Row
  • func (tx *TXExecutor) QueryContextRows(ctx context.Context, sql string, args ...interface{}) (*sql.Rows, error)
  • func (tx *TXExecutor) QueryRow(sql string, args ...interface{}) *sql.Row
  • func (tx *TXExecutor) QueryRows(sql string, args ...interface{}) (*sql.Rows, error)
  • func (tx *TXExecutor) Rollback() error

Types

type Executor

type Executor struct {
	// contains filtered or unexported fields
}

func NewExecutor

func NewExecutor(db *sql.DB, logger logger.GpaLogger) *Executor

func (*Executor) Exec

func (e *Executor) Exec(sql string, args ...interface{}) (sql.Result, error)

func (*Executor) ExecContext

func (e *Executor) ExecContext(ctx context.Context, sql string, args ...interface{}) (sql.Result, error)

func (*Executor) QueryContextRow

func (e *Executor) QueryContextRow(ctx context.Context, sql string, args ...interface{}) *sql.Row

func (*Executor) QueryContextRows

func (e *Executor) QueryContextRows(ctx context.Context, sql string, args ...interface{}) (*sql.Rows, error)

func (*Executor) QueryRow

func (e *Executor) QueryRow(sql string, args ...interface{}) *sql.Row

func (*Executor) QueryRows

func (e *Executor) QueryRows(sql string, args ...interface{}) (*sql.Rows, error)

type SQLExecutor

type SQLExecutor interface {
	QueryRow(sql string, args ...interface{}) *sql.Row
	QueryRows(sql string, args ...interface{}) (*sql.Rows, error)
	QueryContextRow(ctx context.Context, sql string, args ...interface{}) *sql.Row
	QueryContextRows(ctx context.Context, sql string, args ...interface{}) (*sql.Rows, error)

	Exec(query string, args ...interface{}) (sql.Result, error)
	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
}

type TXExecutor

type TXExecutor struct {
	// contains filtered or unexported fields
}

func NewTXExecutor

func NewTXExecutor(ctx context.Context, db *sql.DB, logger logger.GpaLogger) (*TXExecutor, error)

func (*TXExecutor) Commit

func (tx *TXExecutor) Commit() error

func (*TXExecutor) Exec

func (tx *TXExecutor) Exec(sql string, args ...interface{}) (sql.Result, error)

func (*TXExecutor) ExecContext

func (tx *TXExecutor) ExecContext(ctx context.Context, sql string, args ...interface{}) (sql.Result, error)

func (*TXExecutor) QueryContextRow

func (tx *TXExecutor) QueryContextRow(ctx context.Context, sql string, args ...interface{}) *sql.Row

func (*TXExecutor) QueryContextRows

func (tx *TXExecutor) QueryContextRows(ctx context.Context, sql string, args ...interface{}) (*sql.Rows, error)

func (*TXExecutor) QueryRow

func (tx *TXExecutor) QueryRow(sql string, args ...interface{}) *sql.Row

func (*TXExecutor) QueryRows

func (tx *TXExecutor) QueryRows(sql string, args ...interface{}) (*sql.Rows, error)

func (*TXExecutor) Rollback

func (tx *TXExecutor) Rollback() error