squeel

type Connection interface {
	// Inheritance, great ...
	Queryer

	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
	Close() error
	Conn(ctx context.Context) (*sql.Conn, error)
	PingContext(ctx context.Context) error
}

type Middleware func(
	statement *Statement,
)

type Pipeline interface {
	Use(middleware ...Middleware)
	Queryer
}

type Queryer interface {
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
}

type SQL_OPERATION int64

type Statement struct {
	Query string
	Args  []any

	Rows   *sql.Rows
	Row    *sql.Row
	Result sql.Result
	// contains filtered or unexported fields
}

type Transaction interface {
	Queryer
	Commit() error
	Rollback() error
}