postgres

Documentation

Index

• func NewClient(driverName, dsn string) (*sql.DB, error)
• func SampleMainPgx(yml []byte) error
• func SampleMainStd(yml []byte, driverName string) error
• type Book
• type Postgres
  • func NewPostgres(ctx context.Context, dsn string) (*Postgres, error)
  • func (pg *Postgres) Acquire(ctx context.Context) (*pgxpool.Conn, error)
  • func (pg *Postgres) Begin(ctx context.Context) (pgx.Tx, error)
  • func (pg *Postgres) BeginReadOnly(ctx context.Context) (pgx.Tx, error)
  • func (pg *Postgres) Close()
  • func (pg *Postgres) CreateDatabase(ctx context.Context, dbname string) error
  • func (pg *Postgres) CreateDatabaseIfNotExists(ctx context.Context, dbname string) error
  • func (pg *Postgres) CreateOrReplaceDatabase(ctx context.Context, dbname string) error
  • func (pg *Postgres) DropDatabase(ctx context.Context, dbname string) error
  • func (pg *Postgres) DropDatabaseIfExists(ctx context.Context, dbname string) error
  • func (pg *Postgres) Ping(ctx context.Context) error

Functions

func NewClient

func NewClient(driverName, dsn string) (*sql.DB, error)

func SampleMainPgx

func SampleMainPgx(yml []byte) error

func SampleMainStd

func SampleMainStd(yml []byte, driverName string) error

Types

type Book

type Book struct {
	ID          int32
	Title       string
	Author      *string
	Publisher   *string
	Price       *int32
	ReleaseDate *time.Time
	CreatedAt   time.Time
	UpdatedAt   time.Time
}

type Postgres

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

func NewPostgres

func NewPostgres(ctx context.Context, dsn string) (*Postgres, error)

func (*Postgres) Acquire

func (pg *Postgres) Acquire(ctx context.Context) (*pgxpool.Conn, error)

func (*Postgres) Begin

func (pg *Postgres) Begin(ctx context.Context) (pgx.Tx, error)

func (*Postgres) BeginReadOnly

func (pg *Postgres) BeginReadOnly(ctx context.Context) (pgx.Tx, error)

func (*Postgres) Close

func (pg *Postgres) Close()

func (*Postgres) CreateDatabase

func (pg *Postgres) CreateDatabase(ctx context.Context, dbname string) error

func (*Postgres) CreateDatabaseIfNotExists

func (pg *Postgres) CreateDatabaseIfNotExists(ctx context.Context, dbname string) error

func (*Postgres) CreateOrReplaceDatabase

func (pg *Postgres) CreateOrReplaceDatabase(ctx context.Context, dbname string) error

func (*Postgres) DropDatabase

func (pg *Postgres) DropDatabase(ctx context.Context, dbname string) error

func (*Postgres) DropDatabaseIfExists

func (pg *Postgres) DropDatabaseIfExists(ctx context.Context, dbname string) error

func (*Postgres) Ping

func (pg *Postgres) Ping(ctx context.Context) error