Documentation
¶
Overview ¶
Package riverdatabasesql bundles a River driver for Go's built in database/sql.
This is _not_ a fully functional driver, and only supports use through rivermigrate for purposes of interacting with migration frameworks like Goose. Using it with a River client will panic.
Index ¶
- type Driver
- type Executor
- func (e *Executor) Begin(ctx context.Context) (riverdriver.ExecutorTx, error)
- func (e *Executor) Exec(ctx context.Context, sql string) (struct{}, error)
- func (e *Executor) MigrationDeleteByVersionMany(ctx context.Context, versions []int) ([]*riverdriver.Migration, error)
- func (e *Executor) MigrationGetAll(ctx context.Context) ([]*riverdriver.Migration, error)
- func (e *Executor) MigrationInsertMany(ctx context.Context, versions []int) ([]*riverdriver.Migration, error)
- func (e *Executor) TableExists(ctx context.Context, tableName string) (bool, error)
- type ExecutorTx
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Driver ¶
type Driver struct {
// contains filtered or unexported fields
}
Driver is an implementation of riverdriver.Driver for database/sql.
func New ¶
New returns a new database/sql River driver for use with River.
It takes an sql.DB to use for use with River. The pool should already be configured to use the schema specified in the client's Schema field. The pool must not be closed while associated River objects are running.
This is _not_ a fully functional driver, and only supports use through rivermigrate for purposes of interacting with migration frameworks like Goose. Using it with a River client will panic.
func (*Driver) GetExecutor ¶
func (d *Driver) GetExecutor() riverdriver.Executor
func (*Driver) UnwrapExecutor ¶
func (d *Driver) UnwrapExecutor(tx *sql.Tx) riverdriver.Executor
type Executor ¶
type Executor struct {
// contains filtered or unexported fields
}
func (*Executor) Begin ¶
func (e *Executor) Begin(ctx context.Context) (riverdriver.ExecutorTx, error)
func (*Executor) MigrationDeleteByVersionMany ¶
func (*Executor) MigrationGetAll ¶
func (*Executor) MigrationInsertMany ¶
type ExecutorTx ¶
type ExecutorTx struct {
Executor
// contains filtered or unexported fields
}
Source Files
Directories