db

type ConnPool interface {
	io.Closer
	QueryExec
	Transacter
}

type ExecResult interface {
	RowsAffected() (int64, error)
	LastInsertId() (int64, error)
}

type QueryExec interface {
	Exec(ctx context.Context, sql string, args ...any) (ExecResult, error)
	Query(ctx context.Context, sql string, args ...any) (Rows, error)
	QueryRow(ctx context.Context, sql string, args ...any) Row
	SqlOptions() *driver.SqlOptions
}

type Row interface {
	Scan(dest ...any) error
}

type Rows interface {
	Close()
	Rows() iter.Seq2[int, Scanner]
	Columns() ([]string, error)
	Err() error
}

type Scanner interface {
	Scan(dest ...any) error
}

type Transacter interface {
	Transact(ctx context.Context, handler func(ctx context.Context) error) error
}