db

type Conn interface {
	Query(sql string, args ...interface{}) (*pgx.Rows, error)
}

type DataRequest struct {
	Start            int64       `json:"start"`
	Limit            int64       `json:"limit"`
	OrderBy          string      `json:"orderBy"`
	OrderByAscending bool        `json:"orderByAscending"`
	Filter           interface{} `json:"filter"`
}

type DataResponse struct {
	Items     *[]interface{} `json:"items"`
	Count     int64          `json:"count"`
	Aggregate interface{}    `json:"aggregate"`
}

type Database interface {
	Execute(handler func(tx Transaction))
}

type DatabaseConfig struct {
	Host     string // host (e.g. localhost) or path to unix domain socket directory (e.g. /private/tmp)
	Port     uint16 // default: 5432
	Database string
	User     string // default: OS user name
	Password string
	// Run-time parameters to set on connection as session default values
	// (e.g. search_path or application_name)
	RuntimeParams map[string]string
}

type Number struct {
	decimal.Dec
	Null bool
}

type Result interface {
	Scan(dest ...interface{}) (err error)

	Values() ([]interface{}, error)
}

type Transaction interface {
	Execute(sql string, args ...interface{}) int64

	Query(query string, handler func(Result), args ...interface{}) int32
}