executor

Documentation

Index

• Variables
• type Engine
  • func NewEngine() (e *Engine, err error)
  • func (e *Engine) Begin() (*Tx, error)
  • func (e *Engine) Stop()
• type NamedValue
• type Tx
  • func NewTx(ctx context.Context, e *Engine, opts sql.TxOptions) (*Tx, error)
  • func (t *Tx) Commit() error
  • func (t *Tx) ExecContext(ctx context.Context, query string, args []NamedValue) (int64, int64, error)
  • func (t *Tx) QueryContext(ctx context.Context, query string, args []NamedValue) ([]string, []*agnostic.Tuple, error)
  • func (t *Tx) Rollback() error

Variables

var (
	NotImplemented = errors.New("not implemented")
	ParsingError   = errors.New("parsing error")
)

Types

type Engine

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

Engine is the root struct of RamSQL server

func NewEngine

func NewEngine() (e *Engine, err error)

New initialize a new RamSQL server

func (*Engine) Begin

func (e *Engine) Begin() (*Tx, error)

func (*Engine) Stop

func (e *Engine) Stop()

type NamedValue

type NamedValue struct {
	Name    string
	Ordinal int
	Value   any
}

type Tx

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

func NewTx

func NewTx(ctx context.Context, e *Engine, opts sql.TxOptions) (*Tx, error)

func (*Tx) Commit

func (t *Tx) Commit() error

Commit the transaction on server

func (*Tx) ExecContext

func (t *Tx) ExecContext(ctx context.Context, query string, args []NamedValue) (int64, int64, error)

func (*Tx) QueryContext

func (t *Tx) QueryContext(ctx context.Context, query string, args []NamedValue) ([]string, []*agnostic.Tuple, error)

func (*Tx) Rollback

func (t *Tx) Rollback() error

Rollback all changes