db

Documentation

Index

• type DB
  • func Open(ctx context.Context, cfg *config.Config) (*DB, error)
  • func (db *DB) Close()
  • func (db *DB) ColumnExists(ctx context.Context, schema, table, column string) (bool, error)
  • func (db *DB) ExecUpgrade(ctx context.Context, sql string, args ...any) error
  • func (db *DB) RunFile(ctx context.Context, path string, preSQL string, vars map[string]string) error

Types

type DB

type DB struct {
	Pool *pgxpool.Pool
	// contains filtered or unexported fields
}

func Open

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

func (*DB) Close

func (db *DB) Close()

func (*DB) ColumnExists

func (db *DB) ColumnExists(ctx context.Context, schema, table, column string) (bool, error)

func (*DB) ExecUpgrade

func (db *DB) ExecUpgrade(ctx context.Context, sql string, args ...any) error

func (*DB) RunFile

func (db *DB) RunFile(ctx context.Context, path string, preSQL string, vars map[string]string) error