sql

Documentation

Overview

Package sql provides basic functionality for accessing a PostgreSQL database.

Index

• Variables
• func BuildWhere(cols []string) string
• func Exec(ctx *b.Context, qu string, args ...interface{}) error
• func ExecDB(ctx *b.Context, db *Storage, qu string, args ...interface{}) error
• func ExecDBN(ctx *b.Context, db *Storage, qu string, args ...interface{}) (int64, error)
• func ExecN(ctx *b.Context, qu string, args ...interface{}) (int64, error)
• func Query(ctx *b.Context, process func(*Rows) error, qu string, args ...interface{}) error
• func QueryDB(ctx *b.Context, db *Storage, process func(*Rows) error, qu string, ...) error
• func QueryNumber(ctx *b.Context, qu string, args ...interface{}) (uint64, error)
• func QueryNumberDB(ctx *b.Context, db *Storage, qu string, args ...interface{}) (uint64, error)
• func QueryRow(ctx *b.Context, process func(*Row) error, qu string, args ...interface{}) error
• func QueryRowDB(ctx *b.Context, db *Storage, process func(*Row) error, qu string, ...) error
• func QueryRows(ctx *b.Context, qu string, args ...interface{}) (*sql.Rows, error)
• func QueryRowsDB(ctx *b.Context, db *Storage, qu string, args ...interface{}) (*sql.Rows, error)
• func QueryString(ctx *b.Context, qu string, args ...interface{}) (string, error)
• func QueryStringDB(ctx *b.Context, db *Storage, qu string, args ...interface{}) (string, error)
• func Start(ctx *b.Context)
• func StartDB(ctx *b.Context) *sql.DB
• type NullBool
• type NullInt64
• type NullString
• type Row
• type Rows
• type Storage

Variables

var NoData = sql.ErrNoRows

Functions

func BuildWhere

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 ExecDB

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

func ExecDBN

func ExecDBN(ctx *b.Context, db *Storage, qu string,
	args ...interface{}) (int64, error)

func ExecN

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

ExecN executes a SQL update, insert, or delete statement, returning the number of affected rows together with the error returned by the execution.

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 QueryDB

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

func QueryNumber

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 QueryNumberDB

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

func QueryRow

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 QueryRowDB

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

func QueryRows

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 QueryRowsDB

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

func QueryString

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 QueryStringDB

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

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.

func StartDB

func StartDB(ctx *b.Context) *sql.DB

Types

type NullBool

type NullBool = sql.NullBool

type NullInt64

type NullInt64 = sql.NullInt64

type NullString

type NullString = sql.NullString

type Row

type Row = sql.Row

type Rows

type Rows = sql.Rows

type Storage

type Storage struct {
	*sql.DB
	b.DefaultState
}

type Storage provides database access. Implements interface b.ContextState.