migrator

Documentation

Index

• type DB
• type Migrator
  • func New(db DB, schema Schema) *Migrator
  • func (m *Migrator) Migrate(ctx context.Context) error
• type Schema
• type TableNames

Types

type DB

type DB 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 Migrator

type Migrator struct {
	// contains filtered or unexported fields
}

func New

func New(db DB, schema Schema) *Migrator

func (*Migrator) Migrate

func (m *Migrator) Migrate(ctx context.Context) error

type Schema

type Schema interface {
	Migrations() map[string]string
	CreateSchema(ctx context.Context, db DB) error
	CreateMigrationTable(ctx context.Context, db DB) error
	SelectMaxMigration(ctx context.Context, db DB) *sql.Row
	InsertMigrationRow(ctx context.Context, db DB, version uint32, fileName, sha string) error
	SelectUnlock(ctx context.Context, db DB) error
	SelectLock(ctx context.Context, db DB) error
}

Schema performs queries on the RDBMS at hand. This setup is a mess, and should be cleaned up at some point.

type TableNames

type TableNames struct {
	Schema string
	Prefix string
}