pgc

Documentation

Index

• Constants
• Variables
• func CheckError(err error) error
• type Client
  • func NewClient(logger log.Logger, dbc *db.Client) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) Commit(ctx context.Context) error
  • func (c *Client) ExecContext(ctx context.Context, op string, tableName string, query string, ...) (sql.Result, error)
  • func (c *Client) GetContext(ctx context.Context, op string, tableName string, dest interface{}, ...) error
  • func (c *Client) GetDB(ctx context.Context) sqlx.QueryerContext
  • func (c *Client) NamedExecContext(ctx context.Context, op string, tableName string, query string, ...) (sql.Result, error)
  • func (c *Client) QueryRowxContext(ctx context.Context, op string, tableName string, query string, ...) *sqlx.Row
  • func (c *Client) QueryxContext(ctx context.Context, op string, tableName string, query string, ...) (*sqlx.Rows, error)
  • func (c *Client) Rollback(ctx context.Context) error
  • func (c *Client) WithTransaction(ctx context.Context, opts *sql.TxOptions) context.Context
• type StringInterfaceMap
  • func (m *StringInterfaceMap) Scan(value interface{}) error
  • func (a StringInterfaceMap) Value() (driver.Value, error)
• type StringStringMap
  • func (m *StringStringMap) Scan(value interface{}) error
  • func (a StringStringMap) Value() (driver.Value, error)
• type TimeDuration
  • func (t *TimeDuration) Scan(value interface{}) error
  • func (t TimeDuration) Value() (driver.Value, error)

Constants

const (
	OpInsert    = "INSERT"
	OpSelectAll = "SELECT_ALL"
	OpSelect    = "SELECT"
	OpUpdate    = "UPDATE"
	OpDelete    = "DELETE"
)

Variables

var (
	ErrDuplicateKey        = errors.New("duplicate key")
	ErrCheckViolation      = errors.New("check constraint violation")
	ErrForeignKeyViolation = errors.New("foreign key violation")
)

Functions

func CheckError

func CheckError(err error) error

Types

type Client

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

func NewClient

func NewClient(logger log.Logger, dbc *db.Client) (*Client, error)

NewClient wraps salt/db client

func (*Client) Close

func (c *Client) Close() error

Close closes the database connection

func (*Client) Commit

func (c *Client) Commit(ctx context.Context) error

func (*Client) ExecContext

func (c *Client) ExecContext(ctx context.Context, op string, tableName string, query string, args ...interface{}) (sql.Result, error)

func (*Client) GetContext

func (c *Client) GetContext(ctx context.Context, op string, tableName string, dest interface{}, query string, args ...interface{}) error

func (*Client) GetDB

func (c *Client) GetDB(ctx context.Context) sqlx.QueryerContext

func (*Client) NamedExecContext

func (c *Client) NamedExecContext(ctx context.Context, op string, tableName string, query string, arg interface{}) (sql.Result, error)

func (*Client) QueryRowxContext

func (c *Client) QueryRowxContext(ctx context.Context, op string, tableName string, query string, args ...interface{}) *sqlx.Row

func (*Client) QueryxContext

func (c *Client) QueryxContext(ctx context.Context, op string, tableName string, query string, args ...interface{}) (*sqlx.Rows, error)

func (*Client) Rollback

func (c *Client) Rollback(ctx context.Context) error

func (*Client) WithTransaction

func (c *Client) WithTransaction(ctx context.Context, opts *sql.TxOptions) context.Context

type StringInterfaceMap

type StringInterfaceMap map[string]interface{}

func (*StringInterfaceMap) Scan

func (m *StringInterfaceMap) Scan(value interface{}) error

func (StringInterfaceMap) Value

func (a StringInterfaceMap) Value() (driver.Value, error)

type StringStringMap

type StringStringMap map[string]string

func (*StringStringMap) Scan

func (m *StringStringMap) Scan(value interface{}) error

func (StringStringMap) Value

func (a StringStringMap) Value() (driver.Value, error)

type TimeDuration

type TimeDuration time.Duration

func (*TimeDuration) Scan

func (t *TimeDuration) Scan(value interface{}) error

func (TimeDuration) Value

func (t TimeDuration) Value() (driver.Value, error)