migrations

Documentation

Index

• Variables
• func Migrate(connector database.Connector, fileProvider MigrationFileProvider) error
• type MigrationFileProvider

Variables

var (
	MigrationCreator = func(migrationBodySql string, currentMigration int) string {
		return fmt.Sprintf("begin transaction;\n"+
			"%s\n"+
			"insert into migrations (id) values (%d);\n"+
			"commit;",
			migrationBodySql,
			currentMigration)
	}
	LatestMigrationSelectorSql = "select id from migrations order by id desc limit 1"
	IsInitialMigrationError    = func(err error) bool {
		return strings.HasPrefix(err.Error(), "pq: relation") && strings.HasSuffix(err.Error(), "does not exist")
	}
)

Functions

func Migrate

func Migrate(connector database.Connector, fileProvider MigrationFileProvider) error

Types

type MigrationFileProvider

type MigrationFileProvider interface {
	ReadDir(name string) ([]fs.DirEntry, error)
	ReadFile(name string) ([]byte, error)
}

MigrationFileProvider is an interface used for .sql migration file retrieval. See readme for usage.