db

type Config struct {
	Host      string `koanf:"host"`
	Port      int    `koanf:"port"`
	Name      string `koanf:"name"`
	User      string `koanf:"user"`
	Password  string `koanf:"password"`
	NoMigrate bool   `koanf:"nomigrate"`
	Trace     bool   `koanf:"trace"`
}

type Handler interface {
	RunInTx(fn func(TxHandler) error) error
	Query(stmt string, args ...interface{}) (pgx.Rows, error)
	QueryRow(stmt string, args ...interface{}) pgx.Row
	Exec(stmt string, args ...interface{}) (pgconn.CommandTag, error)
	CopyFrom(tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)
}

type SchemaInfo struct {
	CurrentVersion int32
	LatestVersion  int32
	// contains filtered or unexported fields
}

type TxHandler interface {
	Handler
	Tx() pgx.Tx
}