migrate

Documentation

Index

• Variables
• func Create(ctx context.Context, identifier string, db DBX) error
• type Action
• type DBX
• type Func
  • func (fn Func) Run(ctx context.Context, log *zap.Logger, db tagsql.DB, tx tagsql.Tx) error
• type Migration
  • func (migration *Migration) CurrentVersion(ctx context.Context, log *zap.Logger, db tagsql.DB) (int, error)
  • func (migration *Migration) Run(ctx context.Context, log *zap.Logger) error
  • func (migration *Migration) TargetVersion(version int) *Migration
  • func (migration *Migration) ValidTableName() error
  • func (migration *Migration) ValidateSteps() error
  • func (migration *Migration) ValidateVersions(ctx context.Context, log *zap.Logger) error
• type SQL
  • func (sql SQL) Run(ctx context.Context, log *zap.Logger, db tagsql.DB, tx tagsql.Tx) (err error)
• type Step

Variables

var (
	// ErrValidateVersionQuery is when there is an error querying version table
	ErrValidateVersionQuery = errs.Class("validate db version query error")
	// ErrValidateVersionMismatch is when the migration version does not match the current database version
	ErrValidateVersionMismatch = errs.Class("validate db version mismatch error")
	// ErrValidateMinVersion is when the migration version does not match the current database version
	ErrValidateMinVersion = errs.Class("validate minimum version error")
)

var Error = errs.Class("migrate")

Error is the default migrate errs class

Functions

func Create

func Create(ctx context.Context, identifier string, db DBX) error

Create with a previous schema check

Types

type Action

type Action interface {
	Run(ctx context.Context, log *zap.Logger, db tagsql.DB, tx tagsql.Tx) error
}

Action is something that needs to be done

type DBX

type DBX interface {
	tagsql.DB
	Schema() string
	Rebind(string) string
}

DBX contains additional methods for migrations.

type Func

type Func func(ctx context.Context, log *zap.Logger, db tagsql.DB, tx tagsql.Tx) error

Func is an arbitrary operation

func (Func) Run

func (fn Func) Run(ctx context.Context, log *zap.Logger, db tagsql.DB, tx tagsql.Tx) error

Run runs the migration

type Migration

type Migration struct {
	Table string
	Steps []*Step
}

Migration describes a migration steps

func (*Migration) CurrentVersion

func (migration *Migration) CurrentVersion(ctx context.Context, log *zap.Logger, db tagsql.DB) (int, error)

CurrentVersion finds the latest version for the db

func (*Migration) Run

func (migration *Migration) Run(ctx context.Context, log *zap.Logger) error

Run runs the migration steps

func (*Migration) TargetVersion

func (migration *Migration) TargetVersion(version int) *Migration

TargetVersion returns migration with steps upto specified version

func (*Migration) ValidTableName

func (migration *Migration) ValidTableName() error

ValidTableName checks whether the specified table name is valid

func (*Migration) ValidateSteps

func (migration *Migration) ValidateSteps() error

ValidateSteps checks that the version for each migration step increments in order

func (*Migration) ValidateVersions

func (migration *Migration) ValidateVersions(ctx context.Context, log *zap.Logger) error

ValidateVersions checks that the version of the migration matches the state of the database

type SQL

type SQL []string

SQL statements that are executed on the database

func (SQL) Run

func (sql SQL) Run(ctx context.Context, log *zap.Logger, db tagsql.DB, tx tagsql.Tx) (err error)

Run runs the SQL statements

type Step

type Step struct {
	DB          tagsql.DB // The DB to execute this step on
	Description string
	Version     int // Versions should start at 0
	Action      Action
}

Step describes a single step in migration.