pgutil

Documentation

Overview

Package pgutil contains utilities for postgres

Index

• func CheckApplicationName(s string) (r string)
• func ConnstrWithSchema(connstr, schema string) string
• func CreateRandomTestingSchemaName(n int) string
• func CreateSchema(db Execer, schema string) (err error)
• func DropSchema(db Execer, schema string) error
• func IsConstraintError(err error) bool
• func OpenUnique(connstr string, schemaPrefix string) (*dbutil.TempDatabase, error)
• func ParseSchemaFromConnstr(connstr string) (string, error)
• func QueryData(db dbschema.Queryer, schema *dbschema.Schema) (*dbschema.Data, error)
• func QuerySchema(db dbschema.Queryer) (*dbschema.Schema, error)
• func QuerySnapshot(db dbschema.Queryer) (*dbschema.Snapshot, error)
• func QuoteSchema(schema string) string
• func UnquoteIdentifier(quotedIdent string) string
• type Execer

Functions

func CheckApplicationName

func CheckApplicationName(s string) (r string)

CheckApplicationName ensures that the Connection String contains an application name

func ConnstrWithSchema

func ConnstrWithSchema(connstr, schema string) string

ConnstrWithSchema adds schema to a connection string

func CreateRandomTestingSchemaName

func CreateRandomTestingSchemaName(n int) string

CreateRandomTestingSchemaName creates a random schema name string.

func CreateSchema

func CreateSchema(db Execer, schema string) (err error)

CreateSchema creates a schema if it doesn't exist.

func DropSchema

func DropSchema(db Execer, schema string) error

DropSchema drops the named schema

func IsConstraintError

func IsConstraintError(err error) bool

IsConstraintError checks if given error is about constraint violation

func OpenUnique

func OpenUnique(connstr string, schemaPrefix string) (*dbutil.TempDatabase, error)

OpenUnique opens a postgres database with a temporary unique schema, which will be cleaned up when closed. It is expected that this should normally be used by way of "storj.io/storj/private/dbutil/tempdb".OpenUnique() instead of calling it directly.

func ParseSchemaFromConnstr

func ParseSchemaFromConnstr(connstr string) (string, error)

ParseSchemaFromConnstr returns the name of the schema parsed from the connection string if one is provided

func QueryData

func QueryData(db dbschema.Queryer, schema *dbschema.Schema) (*dbschema.Data, error)

QueryData loads all data from tables

func QuerySchema

func QuerySchema(db dbschema.Queryer) (*dbschema.Schema, error)

QuerySchema loads the schema from postgres database.

func QuerySnapshot

func QuerySnapshot(db dbschema.Queryer) (*dbschema.Snapshot, error)

QuerySnapshot loads snapshot from database

func QuoteSchema

func QuoteSchema(schema string) string

QuoteSchema quotes schema name for

func UnquoteIdentifier

func UnquoteIdentifier(quotedIdent string) string

UnquoteIdentifier is the analog of pq.QuoteIdentifier.

Types

type Execer

type Execer interface {
	Exec(query string, args ...interface{}) (sql.Result, error)
}

Execer is for executing sql