query

Documentation

Index

• type BeginStmt
  • func (stmt BeginStmt) IsReadOnly() bool
  • func (stmt BeginStmt) Prepare(*statement.Context) (statement.Statement, error)
  • func (stmt BeginStmt) Run(ctx *statement.Context) (statement.Result, error)
• type CommitStmt
  • func (stmt CommitStmt) IsReadOnly() bool
  • func (stmt CommitStmt) Prepare(*statement.Context) (statement.Statement, error)
  • func (stmt CommitStmt) Run(ctx *statement.Context) (statement.Result, error)
• type Context
  • func (c *Context) GetTx() *database.Transaction
• type Query
  • func New(statements ...statement.Statement) Query
  • func (q *Query) Prepare(context *Context) error
  • func (q Query) Run(context *Context) (*statement.Result, error)
• type RollbackStmt
  • func (stmt RollbackStmt) IsReadOnly() bool
  • func (stmt RollbackStmt) Prepare(*statement.Context) (statement.Statement, error)
  • func (stmt RollbackStmt) Run(ctx *statement.Context) (statement.Result, error)

Types

type BeginStmt

type BeginStmt struct {
	Writable bool
}

BeginStmt is a statement that creates a new transaction.

func (BeginStmt) IsReadOnly

func (stmt BeginStmt) IsReadOnly() bool

func (BeginStmt) Prepare

func (stmt BeginStmt) Prepare(*statement.Context) (statement.Statement, error)

Prepare implements the Preparer interface.

func (BeginStmt) Run

func (stmt BeginStmt) Run(ctx *statement.Context) (statement.Result, error)

type CommitStmt

type CommitStmt struct{}

CommitStmt is a statement that commits the current active transaction.

func (CommitStmt) IsReadOnly

func (stmt CommitStmt) IsReadOnly() bool

func (CommitStmt) Prepare

func (stmt CommitStmt) Prepare(*statement.Context) (statement.Statement, error)

Prepare implements the Preparer interface.

func (CommitStmt) Run

func (stmt CommitStmt) Run(ctx *statement.Context) (statement.Result, error)

type Context

type Context struct {
	Ctx    context.Context
	DB     *database.Database
	Tx     *database.Transaction
	Params []environment.Param
}

func (*Context) GetTx

func (c *Context) GetTx() *database.Transaction

type Query

type Query struct {
	Statements []statement.Statement
	// contains filtered or unexported fields
}

A Query can execute statements against the database. It can read or write data from any table, or even alter the structure of the database. Results are returned as streams.

func New

func New(statements ...statement.Statement) Query

New creates a new query with the given statements.

func (*Query) Prepare

func (q *Query) Prepare(context *Context) error

Prepare the statements by calling their Prepare methods. It stops at the first statement that doesn't implement the statement.Preparer interface.

func (Query) Run

func (q Query) Run(context *Context) (*statement.Result, error)

Run executes all the statements in their own transaction and returns the last result.

type RollbackStmt

type RollbackStmt struct{}

RollbackStmt is a statement that rollbacks the current active transaction.

func (RollbackStmt) IsReadOnly

func (stmt RollbackStmt) IsReadOnly() bool

func (RollbackStmt) Prepare

func (stmt RollbackStmt) Prepare(*statement.Context) (statement.Statement, error)

Prepare implements the Preparer interface.

func (RollbackStmt) Run

func (stmt RollbackStmt) Run(ctx *statement.Context) (statement.Result, error)