postgres

Documentation

Index

• func Connect(ctx context.Context, dsnURI string) (*pgxpool.Pool, error)
• type PgDatabase
  • func NewPgDatabase(ctx context.Context, logger hclog.Logger, dsn string, sd schema.Dialect) (*PgDatabase, error)
  • func (p PgDatabase) Begin(ctx context.Context) (execution.TXQueryExecer, error)
  • func (p PgDatabase) Close()
  • func (p PgDatabase) CopyFrom(ctx context.Context, resources schema.Resources, shouldCascade bool, ...) error
  • func (p PgDatabase) Delete(ctx context.Context, t *schema.Table, kvFilters []interface{}) error
  • func (p PgDatabase) Dialect() schema.Dialect
  • func (p PgDatabase) Exec(ctx context.Context, query string, args ...interface{}) error
  • func (p PgDatabase) Insert(ctx context.Context, t *schema.Table, resources schema.Resources, ...) error
  • func (p PgDatabase) Query(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)
  • func (p PgDatabase) QueryOne(ctx context.Context, query string, args ...interface{}) pgx.Row
  • func (p PgDatabase) RawCopyFrom(ctx context.Context, r io.Reader, sql string) error
  • func (p PgDatabase) RawCopyTo(ctx context.Context, w io.Writer, sql string) error
  • func (p PgDatabase) RemoveStaleData(ctx context.Context, t *schema.Table, executionStart time.Time, ...) error
• type PgTx
  • func (p PgTx) Begin(ctx context.Context) (execution.TXQueryExecer, error)
  • func (p PgTx) Exec(ctx context.Context, query string, args ...interface{}) error
• type UUID
  • func (u UUID) Get() interface{}
  • func (u UUID) String() string

Functions

func Connect

func Connect(ctx context.Context, dsnURI string) (*pgxpool.Pool, error)

Connect connects to the given DSN and returns a pgxpool

Types

type PgDatabase

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

func NewPgDatabase

func NewPgDatabase(ctx context.Context, logger hclog.Logger, dsn string, sd schema.Dialect) (*PgDatabase, error)

func (PgDatabase) Begin

func (p PgDatabase) Begin(ctx context.Context) (execution.TXQueryExecer, error)

func (PgDatabase) Close

func (p PgDatabase) Close()

func (PgDatabase) CopyFrom

func (p PgDatabase) CopyFrom(ctx context.Context, resources schema.Resources, shouldCascade bool, cascadeDeleteFilters map[string]interface{}) error

CopyFrom copies all resources from []*Resource

func (PgDatabase) Delete

func (p PgDatabase) Delete(ctx context.Context, t *schema.Table, kvFilters []interface{}) error

func (PgDatabase) Dialect

func (p PgDatabase) Dialect() schema.Dialect

func (PgDatabase) Exec

func (p PgDatabase) Exec(ctx context.Context, query string, args ...interface{}) error

Exec allows executions of postgres queries with given args returning error of execution

func (PgDatabase) Insert

func (p PgDatabase) Insert(ctx context.Context, t *schema.Table, resources schema.Resources, shouldCascade bool, cascadeDeleteFilters map[string]interface{}) error

Insert inserts all resources to given table, table and resources are assumed from same table.

func (PgDatabase) Query

func (p PgDatabase) Query(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)

Query allows execution of postgres queries with given args returning data result

func (PgDatabase) QueryOne

func (p PgDatabase) QueryOne(ctx context.Context, query string, args ...interface{}) pgx.Row

QueryOne allows execution of postgres queries with given args returning data result

func (PgDatabase) RawCopyFrom

func (p PgDatabase) RawCopyFrom(ctx context.Context, r io.Reader, sql string) error

func (PgDatabase) RawCopyTo

func (p PgDatabase) RawCopyTo(ctx context.Context, w io.Writer, sql string) error

func (PgDatabase) RemoveStaleData

func (p PgDatabase) RemoveStaleData(ctx context.Context, t *schema.Table, executionStart time.Time, kvFilters []interface{}) error

type PgTx

type PgTx struct {
	pgx.Tx
}

func (PgTx) Begin

func (p PgTx) Begin(ctx context.Context) (execution.TXQueryExecer, error)

func (PgTx) Exec

func (p PgTx) Exec(ctx context.Context, query string, args ...interface{}) error

type UUID

type UUID struct {
	pgtype.UUID
}

func (UUID) Get

func (u UUID) Get() interface{}

func (UUID) String

func (u UUID) String() string