psql

Documentation

Overview

Package psql augments database/sql

Index

• Variables
• func DelFromContext(ctx context.Context, key string) (ok bool)
• func DiscardDB(ctx context.Context)
• func ExecValues(execResult sql.Result, e error) (ID, rows int64, err error)
• func GetDB(ctx context.Context) (db *sql.DB)
• func NewExecResult(execResult sql.Result, e error) (result parl.ExecResult, err error)
• func QueryString(label string, ctx context.Context, dataSource parl.DataSource, query string, ...) (value string, err error)
• func ScanToInt(sqlRow *sql.Row, e error) (value int, err error)
• func ScanToString(sqlRow *sql.Row, e error) (value string, err error)
• func SqlExec(label string, ctx context.Context, dataSource parl.DataSource, query string, ...) (err error)
• func StoreDB(ctx context.Context, db *sql.DB)
• func StoreInContext(ctx context.Context, key string, value interface{}) (ok bool)
• type Context
  • func NewContext(ctx ...context.Context) (c *Context)
  • func (c *Context) Delete(key string)
  • func (c *Context) Store(key string, value interface{})
  • func (c *Context) Value(key interface{}) (result interface{})
  • func (c *Context) Value2(key interface{}) (result interface{}, ok bool)
• type DBCache
  • func NewDBCache(dataSource parl.DataSource) (dc *DBCache)
  • func (dc *DBCache) Close() (err error)
  • func (dc *DBCache) Stmt(query string, ctx context.Context) (stmt *sql.Stmt, err error)
  • func (dc *DBCache) WrapStmt(stmt *sql.Stmt) (stm Stmt)
• type DBMap
  • func NewDBMap(dsnr parl.DataSourceNamer, ...) (dbMap *DBMap)
  • func (dm *DBMap) Close() (err error)
  • func (dm *DBMap) Exec(partition parl.DBPartition, query string, ctx context.Context, args ...any) (execResult parl.ExecResult, err error)
  • func (dm *DBMap) Query(partition parl.DBPartition, query string, ctx context.Context, args ...any) (sqlRows *sql.Rows, err error)
  • func (dm *DBMap) QueryInt(partition parl.DBPartition, query string, ctx context.Context, args ...any) (value int, err error)
  • func (dm *DBMap) QueryRow(partition parl.DBPartition, query string, ctx context.Context, args ...any) (sqlRow *sql.Row, err error)
  • func (dm *DBMap) QueryString(partition parl.DBPartition, query string, ctx context.Context, args ...any) (value string, err error)
• type ExecResult
  • func (r *ExecResult) Get() (ID int64, rows int64)
  • func (r ExecResult) String() (s string)
• type Stmt
• type StmtWrapper

Variables

var DBFactory = &dbFactory{}

Functions

func DelFromContext

func DelFromContext(ctx context.Context, key string) (ok bool)

DelFromContext removes a value from context. Thread-safe

func DiscardDB

func DiscardDB(ctx context.Context)

DiscardDB removes db handle from context

func ExecValues

func ExecValues(execResult sql.Result, e error) (ID, rows int64, err error)

ExecValues parses the result from an Exec* method into its values. if LastInsertId or RowsAffected fails, the error is added to err.

func GetDB

func GetDB(ctx context.Context) (db *sql.DB)

GetDB obtains db handle from context

func NewExecResult

func NewExecResult(execResult sql.Result, e error) (result parl.ExecResult, err error)

func QueryString

func QueryString(label string, ctx context.Context, dataSource parl.DataSource,
	query string, args ...any) (value string, err error)

func ScanToInt

func ScanToInt(sqlRow *sql.Row, e error) (value int, err error)

func ScanToString

func ScanToString(sqlRow *sql.Row, e error) (value string, err error)

func SqlExec

func SqlExec(label string, ctx context.Context, dataSource parl.DataSource,
	query string, args ...any) (err error)

SqlExec is used when parl.DB is not available, for example to implement the schema function provided to DBFactory.NewDB(). query is an sql statement that does not return any rows. label is used in error messages. SqlExec uses parl.DataSource obtained from DataSourceNamer.DataSource(). Because the cached prepared statements and the partitioning of parl.DB are not available, SqlExec uses any sql.DB method.

func StoreDB

func StoreDB(ctx context.Context, db *sql.DB)

StoreDB saves db handle in context

func StoreInContext

func StoreInContext(ctx context.Context, key string, value interface{}) (ok bool)

StoreInContext stores a value in context. Thread-safe

Types

type Context

type Context struct {
	context.Context
	Map sync.Map
}

Context is a context.Context with a Value() implementation

func NewContext

func NewContext(ctx ...context.Context) (c *Context)

NewContext provides a context.Context with a Value() implementation

func (*Context) Delete

func (c *Context) Delete(key string)

StoreInContext stores a value in context. Thread-safe

func (*Context) Store

func (c *Context) Store(key string, value interface{})

StoreInContext stores a value in context. Thread-safe

func (*Context) Value

func (c *Context) Value(key interface{}) (result interface{})

Value retrieves data from context. Thread-safe

func (*Context) Value2

func (c *Context) Value2(key interface{}) (result interface{}, ok bool)

Value2 retrieves data and was–present indicator from context. Thread-safe

type DBCache

type DBCache struct {
	// contains filtered or unexported fields
}

func NewDBCache

func NewDBCache(dataSource parl.DataSource) (dc *DBCache)

func (*DBCache) Close

func (dc *DBCache) Close() (err error)

func (*DBCache) Stmt

func (dc *DBCache) Stmt(query string, ctx context.Context) (stmt *sql.Stmt, err error)

func (*DBCache) WrapStmt

func (dc *DBCache) WrapStmt(stmt *sql.Stmt) (stm Stmt)

type DBMap

type DBMap struct {
	// contains filtered or unexported fields
}

func NewDBMap

func NewDBMap(dsnr parl.DataSourceNamer,
	schema func(dataSource parl.DataSource, ctx context.Context) (err error)) (dbMap *DBMap)

func (*DBMap) Close

func (dm *DBMap) Close() (err error)

func (*DBMap) Exec

func (dm *DBMap) Exec(
	partition parl.DBPartition, query string, ctx context.Context,
	args ...any) (execResult parl.ExecResult, err error)

func (*DBMap) Query

func (dm *DBMap) Query(
	partition parl.DBPartition, query string, ctx context.Context,
	args ...any) (sqlRows *sql.Rows, err error)

func (*DBMap) QueryInt

func (dm *DBMap) QueryInt(
	partition parl.DBPartition, query string, ctx context.Context,
	args ...any) (value int, err error)

func (*DBMap) QueryRow

func (dm *DBMap) QueryRow(
	partition parl.DBPartition, query string, ctx context.Context,
	args ...any) (sqlRow *sql.Row, err error)

func (*DBMap) QueryString

func (dm *DBMap) QueryString(
	partition parl.DBPartition, query string, ctx context.Context,
	args ...any) (value string, err error)

type ExecResult

type ExecResult struct {
	ID int64
	// contains filtered or unexported fields
}

ExecResult makes sql.Result printable. sql.Result are obtained by invoking Exec* methods of sql.DB sql.Stmt sql.Conn sql.Tx. sql.Result is an interface with methods LastInsertId and RowsAffected. each driver provides an sql.Result implementation.

func (*ExecResult) Get

func (r *ExecResult) Get() (ID int64, rows int64)

Get obtains last id and number of affected rows with errors separately

func (ExecResult) String

func (r ExecResult) String() (s string)

type Stmt

type Stmt interface {
	ExecContext(ctx context.Context, args ...any) (sqlResult sql.Result, err error)
	QueryContext(ctx context.Context, args ...any) (sqlRows *sql.Rows, err error)
	QueryRowContext(ctx context.Context, args ...any) (sqlRow *sql.Row)
}

type StmtWrapper

type StmtWrapper interface {
	WrapStmt(stmt *sql.Stmt) (stm Stmt)
}