gmq

type Column struct {
	Name  string
	Value interface{}
}

type Db struct {
	*sql.DB
	// contains filtered or unexported fields
}

type DbTx interface {
	DriverName() string
	Exec(query string, args ...interface{}) (sql.Result, error)
	Prepare(query string) (*sql.Stmt, error)
	Query(query string, args ...interface{}) (*sql.Rows, error)
}

type Filter interface {
	SqlString(alias string, driverName string) string
	Params() []interface{}
	And(Filter) Filter
	Or(Filter) Filter
}

type Option interface {
	IsDefined() bool
}

type OptionFloat64 interface {
	Option
	Get() (float64, error)
}

type OptionInt interface {
	Option
	Get() (int, error)
}

type OptionInt64 interface {
	Option
	Get() (int64, error)
}

type OptionString interface {
	Option
	Get() (string, error)
}

type OptionTime interface {
	Option
	Get() (time.Time, error)
}

type Query interface {
	String() string
	Exec(dbtx DbTx) (sql.Result, error)
	SelectOne(dbtx DbTx, functor QueryRowVisitor) error
	SelectList(dbtx DbTx, functor QueryRowVisitor) error
	SelectCount(dbtx DbTx, functor QueryRowVisitor) error
	Where(f Filter) Query
	OrderBy(by ...string) Query
	Limit(offsets ...int64) Query
	Page(number, size int) Query
	GroupBy(by ...string) Query
}

type QueryRowVisitor func(columns []Column, rb []sql.RawBytes) bool

type TableModel interface {
	Names() (schema, tbl, alias string)
}

type Tx struct {
	*sql.Tx
	// contains filtered or unexported fields
}

type WithinTxFunctor func(tx *Tx) error