drivers

type DB interface {
	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
	BeginTx(ctx context.Context, options *sql.TxOptions) (*sql.Tx, error)
}

type DBWithDriver interface {
	DB
	Driver() driver.Driver
}

type Driver interface {
	Add(ctx context.Context, id string) error
	Remove(ctx context.Context, id string) error
	StartMigration(ctx context.Context, id string) error
	FinishMigration(ctx context.Context, id string) error
	Lock(ctx context.Context) (migrations.Unlocker, error)
}

type DriverConstructor func(db DB, options ...Option) (Driver, error)

type Option func(*driverOpts)

type TXExecer interface {
	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
	Commit() error
	Rollback() error
}