pqsql

README

pqsql

golang postgres driver with migrations base on https://github.com/lib/pq

Documentation

Index

• func CloseAfter(rows io.Closer, process func() error) error
• func MigrationsUp(ctx context.Context, db *sql.DB, src *Migrations) error
• func Open(ctx context.Context, cfg *Config) (*sql.DB, error)
• type Config
  • func (cfg *Config) TuneConnPool(p interface{ ... })
  • func (cfg *Config) URI() string
• type Migration
• type Migrations

Functions

func CloseAfter

func CloseAfter(rows io.Closer, process func() error) error

CloseAfter

func MigrationsUp

func MigrationsUp(ctx context.Context, db *sql.DB, src *Migrations) error

MigrationsUp

func Open

func Open(ctx context.Context, cfg *Config) (*sql.DB, error)

Open represent connect to database function

Types

type Config

type Config struct {
	Address  string
	Database string
	Username string
	Password string

	MaxOpenConn int
	MaxIdleConn int
	MaxConnTTL  time.Duration
}

Config represent postgres configuration

func (*Config) TuneConnPool

func (cfg *Config) TuneConnPool(p interface {
	SetMaxOpenConns(int)
	SetMaxIdleConns(int)
	SetConnMaxLifetime(time.Duration)
})

TuneConnPool tune configuration for database connector

func (*Config) URI

func (cfg *Config) URI() string

URI return credential string

type Migration

type Migration struct {
	ID   string
	Up   []string
	Down []string
}

Migration represent one migration step

type Migrations

type Migrations struct {
	Table  string
	Source []*Migration
}

Migrations represent migrations source