sql

type ConnDefinition interface {
	Query(query string, a ...any) (rows SqlRows, err error)
	QueryContext(ctx context.Context, query string, a ...any) (rows SqlRows, err error)
	Exec(query string, a ...any) (result sql.Result, err error)
	ExecContext(ctx context.Context, query string, a ...any) (result sql.Result, err error)
	Close() error
	Stats() sql.DBStats
}

type FormatQuery interface {
	FprintQuery(out io.Writer, name, driver, query string, a ...any) (err error)
}

type FormatQueryFunc func(out io.Writer, name, driver, query string, a ...any) (err error)

type Record interface {
	Nr() int64
	Columns() []string
	Data() []any
	First() bool
	Last() bool
	Init() bool
	Finit() bool
	Err() error
	Value(int, ...any) (any, bool)
	Index(string) int
}

type SQLHandler interface {
	Query(name string, query string, a ...any) (records func(func(Record, int64) bool), err error)
	Exec(name string, query string, a ...any) (any, error)
	Stats(name string) (stats any)
	Conns() []string
	DefineConn(name string, datasource string) (conndef ConnDefinition, err error)
}

type SqlRows interface {
	Close() error
	ColumnTypes() ([]*sql.ColumnType, error)
	Columns() ([]string, error)
	Err() error
	Next() bool
	NextResultSet() bool
	Scan(dest ...any) error
}