query

type BeginStmt ¶

type BeginStmt struct {
	Writable bool
}

BeginStmt is a statement that creates a new transaction.

func (stmt BeginStmt) NeedsTransaction() bool

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 (stmt CommitStmt) IsReadOnly() bool

func (stmt CommitStmt) NeedsTransaction() bool

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

type Context ¶

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

type PreparedStatement ¶ added in v0.18.0

type PreparedStatement struct {
	statement.Statement
}

type Query ¶

type Query struct {
	Statements []statement.Statement
}

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(statements ...statement.Statement) *Query

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

type RollbackStmt ¶

type RollbackStmt struct{}

RollbackStmt is a statement that rollbacks the current active transaction.

func (stmt RollbackStmt) NeedsTransaction() bool

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