sdksql

type BeginTx interface {
	BeginTx(ctx context.Context, opts *sql.TxOptions) (tx *sql.Tx, err error)
}

type Conn interface {
	BeginTx
	io.Closer
	PingContext
	TxConn
}

type ExecContext interface {
	ExecContext(ctx context.Context, query string, args ...any) (res sql.Result, err error)
}

type MismatchColumnsError struct{ Col, Dst int }

type PingContext interface {
	PingContext(ctx context.Context) (err error)
}

type PrepareContext interface {
	PrepareContext(ctx context.Context, query string) (stmt *sql.Stmt, err error)
}

type QueryContext interface {
	QueryContext(ctx context.Context, query string, args ...any) (rows *sql.Rows, err error)
}

type QueryRowContext interface {
	QueryRowContext(ctx context.Context, query string, args ...any) (row *sql.Row)
}

type RoundRobinError struct{ Total, Index int }

type TxConn interface {
	ExecContext
	PrepareContext
	QueryContext
	QueryRowContext
}

type WrapExec interface {
	// Scan the result of ExecContext that usually return numbers of rowsAffected
	// and lastInsertID.
	Scan(rowsAffected *int, lastInsertID *int) error
}

type WrapQuery interface {
	// Scan accept do, a func that accept `i int` as index and returning list
	// of pointers.
	//  pointers == nil   // break the loop
	//  len(pointers) < 1 // skip the current loop
	//  len(pointers) > 0 // assign the pointer, MUST be same as the length of columns
	Scan(row func(i int) (pointers []any)) error
}

type WrapQueryRow interface {
	Scan(dest ...any) error
	Err() error
}

type WrapTransaction interface {
	// Do the transaction and ends it with either COMMIT or ROLLBACK
	Do(tx func() error) error
}