postgres

Documentation

Overview

Package postgres defines the PostgresSQL functionalities.

Index

• Constants
• type Postgres
  • func (p *Postgres) CloseConnection(_ context.Context) error
  • func (p *Postgres) Connect(connectionData sqlfw.ConnectionData) (*sqlx.DB, error)
  • func (p *Postgres) GetConnectionData(config interface{}) (*sqlfw.ConnectionData, error)
  • func (p *Postgres) GetMigrationVersion(ctx context.Context) (*sqlfw.GetVersionOutput, error)
  • func (p *Postgres) InitMigration(ctx context.Context, migrationsTablePrefix *string) error
  • func (p *Postgres) OpenConnection(ctx context.Context) error
  • func (p *Postgres) RunMigration(ctx context.Context, migration string) error
  • func (p *Postgres) SetMigrationVersion(ctx context.Context, input sqlfw.SetVersionInput) error
  • func (p *Postgres) TranslateError(_ context.Context, err error, defaultError error) error

Constants

const (
	DialectName = "postgres"
)

Types

type Postgres

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

func (*Postgres) CloseConnection

func (p *Postgres) CloseConnection(_ context.Context) error

func (*Postgres) Connect

func (p *Postgres) Connect(connectionData sqlfw.ConnectionData) (*sqlx.DB, error)

func (*Postgres) GetConnectionData

func (p *Postgres) GetConnectionData(config interface{}) (*sqlfw.ConnectionData, error)

func (*Postgres) GetMigrationVersion

func (p *Postgres) GetMigrationVersion(ctx context.Context) (*sqlfw.GetVersionOutput, error)

func (*Postgres) InitMigration

func (p *Postgres) InitMigration(ctx context.Context, migrationsTablePrefix *string) error

func (*Postgres) OpenConnection

func (p *Postgres) OpenConnection(ctx context.Context) error

func (*Postgres) RunMigration

func (p *Postgres) RunMigration(ctx context.Context, migration string) error

func (*Postgres) SetMigrationVersion

func (p *Postgres) SetMigrationVersion(ctx context.Context, input sqlfw.SetVersionInput) error

func (*Postgres) TranslateError

func (p *Postgres) TranslateError(_ context.Context, err error, defaultError error) error