sql

func BuildWhere ¶ added in v0.1.11

func BuildWhere(cols []string) string

func Exec ¶

func Exec(ctx *b.Context, qu string, args ...interface{}) error

Exec executes a SQL update, insert, or delete statement.

func Query ¶

func Query(ctx *b.Context, process func(*Rows) error, qu string,
	args ...interface{}) error

Function Query executes a SQL query and calls the process closure using the Rows object returned by the query.

func QueryNumber ¶ added in v0.1.11

func QueryNumber(ctx *b.Context, qu string, args ...interface{}) (uint64, error)

Function QueryNumber executes the SQL query given and returns a scalar numeric value.

func QueryRow ¶ added in v0.1.11

func QueryRow(ctx *b.Context, process func(*Row) error, qu string,
	args ...interface{}) error

Function QueryRow excecutes a SQL query that returns exactly one Row and calls the process closure using the Row object returned by the query.

func QueryRows ¶ added in v0.1.11

func QueryRows(ctx *b.Context, qu string, args ...interface{}) (*sql.Rows, error)

Funtion QueryRows executes a SQL query and returns the sql.Rows object. It is the responsibility of the caller to iterate over the Rows object returned and scan the individual rows.

func QueryString ¶ added in v0.1.11

func QueryString(ctx *b.Context, qu string, args ...interface{}) (string, error)

Function QueryString executes the SQL query given and returns a scalar string value.

func Start ¶

func Start(ctx *b.Context)

Start is a generic actor startup handler that connects to a database and stores the db connection via a Storage object in the context.