rdb

type Conn interface {
	Begin() (Tx, error)
	Exec(sql string, args ...interface{}) (ExecResult, error)
	Query(sql string, args ...interface{}) (RowsResult, error)
	QueryRow(sql string, args ...interface{}) RowResult
	ToHandle() *Handle
}

type CustomTotalQueryFn = func(conn *Handle, originalSelectBuilder sq.SelectBuilder) (int64, error)

type ExecResult interface {
	RowsAffected() int64
	IsInsert() bool
	IsUpdate() bool
	IsDelete() bool
	IsSelect() bool
	String() string
}

type Handle struct {
	Runner
	TypeConv

	StmtBuilder *StatementBuilder
}

type Migrate interface {
	// Up() looks at the currently active migration version and migrate all the
	// way up.
	Up() error
	MustUp()
	// Down() looks at the currently active migration version and migrate all
	// the way down.
	Down() error
	MustDown()
	// Reset() deletes everything in the database (including migration
	// histories).
	Reset() error
	MustReset()
	// Version() returns the current active migration version and whether the
	// database is at dirty state
	Version() (version uint, dirty bool, err error)
}

type NtobReader interface {
	// returns reference to a scannable argument of native numeric type
	ScannableArg() interface{}
	// parse the scannable argument reference to big.Int
	Parse() (*big.Int, error)
}

type NtobfReader interface {
	// returns reference to a scannable argument of native numeric type
	ScannableArg() interface{}
	// parse the scannable argument reference to big.Float
	Parse() (*big.Float, error)
}

type NtotReader interface {
	// returns reference to a scannable argument of native time type
	ScannableArg() interface{}
	// parse the scannable argument reference to time.Time
	Parse() (*utctime.UTCTime, error)
}

type RDbPaginationBuilder struct {
	*pagination_interface.Pagination
	// contains filtered or unexported fields
}

type RDbPaginationSQLBuilder struct {
	*pagination_interface.Pagination
	// contains filtered or unexported fields
}

type RDbPaginationStmtBuilder struct {
	*pagination_interface.Pagination
	// contains filtered or unexported fields
}

type RowResult interface {
	Scan(dest ...interface{}) error
}

type RowsResult interface {
	Close()
	Err() error
	ExecResult() ExecResult
	Next() bool
	// When no row was found it should return ErrNoRows
	Scan(dest ...interface{}) error
}

type Runner interface {
	Exec(sql string, args ...interface{}) (ExecResult, error)
	Query(sql string, args ...interface{}) (RowsResult, error)
	QueryRow(sql string, args ...interface{}) RowResult
}

type StatementBuilder struct {
	sq.StatementBuilderType
	sq.PlaceholderFormat
}

type Tx interface {
	Exec(sql string, args ...interface{}) (ExecResult, error)
	Query(sql string, args ...interface{}) (RowsResult, error)
	QueryRow(sql string, args ...interface{}) RowResult
	Commit() error
	Rollback() error
	ToHandle() *Handle
}

type TypeConv interface {
	// convert big.Int to native number pointer. Return nil if big.Int is nil
	Bton(*big.Int) interface{}
	// convert big.Float to native number pointer. Return nil if big.Float is nil
	BFton(*big.Float) interface{}
	Iton(int) interface{}
	// native number reader and parser to big.Int
	NtobReader() NtobReader
	// native number reader and parser to big.Float
	NtobfReader() NtobfReader

	// convert time.Time to native time format pointer. Return nil if time
	// is nil
	Tton(*utctime.UTCTime) interface{}
	// native time reader and parser to time.Time
	NtotReader() NtotReader
}