sql

package

v0.1.10 Latest Latest Go to latest Published: Jan 15, 2021 License: MIT Imports: 4 Imported by: 0

Details

Package sql provides basic functionality for accessing a PostgreSQL database.

This section is empty.

This section is empty.

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

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

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

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

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.

type Rows = sql.Rows

type Storage struct {
	*sql.DB
}

type Storage provides database access. Implements interface b.ContextState

func (st *Storage) GetSessionMailbox(sid string) chan b.Message

method GetSessionMailbox for interface b.ContextState.