postgres

Documentation

Index

• func CreateMetadataQuery(entity string, um map[string]interface{}) (string, []byte, error)
• func HandleError(wrapper, err error) error
• func Total(ctx context.Context, db Database, query string, params interface{}) (uint64, error)
• type Database
  • func NewDatabase(db *sqlx.DB, config postgres.Config, tracer trace.Tracer) Database

Functions

func CreateMetadataQuery

func CreateMetadataQuery(entity string, um map[string]interface{}) (string, []byte, error)

func HandleError

func HandleError(wrapper, err error) error

func Total

func Total(ctx context.Context, db Database, query string, params interface{}) (uint64, error)

Types

type Database

type Database interface {
	// NamedQueryContext executes a named query against the database and returns
	NamedQueryContext(context.Context, string, interface{}) (*sqlx.Rows, error)

	// NamedExecContext executes a named query against the database and returns
	NamedExecContext(context.Context, string, interface{}) (sql.Result, error)

	// QueryRowxContext queries the database and returns an *sqlx.Row.
	QueryRowxContext(context.Context, string, ...interface{}) *sqlx.Row

	// QueryxContext queries the database and returns an *sqlx.Rows and an error.
	QueryxContext(context.Context, string, ...interface{}) (*sqlx.Rows, error)

	// QueryContext queries the database and returns an *sql.Rows and an error.
	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

	// ExecContext executes a query without returning any rows.
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)

	// BeginTxx begins a transaction and returns an *sqlx.Tx.
	BeginTxx(ctx context.Context, opts *sql.TxOptions) (*sqlx.Tx, error)
}

Database provides a database interface.

func NewDatabase

func NewDatabase(db *sqlx.DB, config postgres.Config, tracer trace.Tracer) Database

NewDatabase creates a Clients'Database instance.