postgres

Documentation

Index

• type DBConn
• type DBConnection
  • func Connect(ctx context.Context, config *config.Database) (*DBConnection, error)
  • func (d *DBConnection) Cleanup() error
  • func (d *DBConnection) Close() error
  • func (d *DBConnection) WithTransaction(f func(conn *DBConnection) error) error

Types

type DBConn

type DBConn interface {
	Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)
	Query(ctx context.Context, sql string, optionsAndArgs ...interface{}) (pgx.Rows, error)
	QueryRow(ctx context.Context, sql string, optionsAndArgs ...interface{}) pgx.Row
}

DBConn implemented by pgx.Conn and pgx.Tx

type DBConnection

type DBConnection struct {
	Ctx  context.Context
	Conn DBConn
	// contains filtered or unexported fields
}

func Connect

func Connect(ctx context.Context, config *config.Database) (*DBConnection, error)

func (*DBConnection) Cleanup

func (d *DBConnection) Cleanup() error

func (*DBConnection) Close

func (d *DBConnection) Close() error

func (*DBConnection) WithTransaction

func (d *DBConnection) WithTransaction(f func(conn *DBConnection) error) error