repair

Documentation

Index

• Constants
• Variables
• func CreateMigrationTable(ctx context.Context, conn *pgx.Conn) error
• func DeleteVersionSQL(batch *pgconn.Batch, version string)
• func GetMigrationFile(version string, fsys afero.Fs) (string, error)
• func InsertVersionSQL(batch *pgconn.Batch, version, name string, stats []string)
• func Run(ctx context.Context, config pgconn.Config, version, status string, ...) error
• func UpdateMigrationTable(ctx context.Context, conn *pgx.Conn, version, status string, fsys afero.Fs) error
• type MigrationFile
  • func NewMigrationFromFile(path string, fsys afero.Fs) (*MigrationFile, error)
  • func NewMigrationFromReader(sql io.Reader) (*MigrationFile, error)
  • func NewMigrationFromVersion(version string, fsys afero.Fs) (*MigrationFile, error)
  • func (m *MigrationFile) ExecBatch(ctx context.Context, conn *pgx.Conn) error
  • func (m *MigrationFile) ExecBatchWithCache(ctx context.Context, conn *pgx.Conn) error

Constants

const (
	Applied  = "applied"
	Reverted = "reverted"
)

const (
	CREATE_VERSION_SCHEMA    = "CREATE SCHEMA IF NOT EXISTS supabase_migrations"
	CREATE_VERSION_TABLE     = "CREATE TABLE IF NOT EXISTS supabase_migrations.schema_migrations (version text NOT NULL PRIMARY KEY)"
	ADD_STATEMENTS_COLUMN    = "ALTER TABLE supabase_migrations.schema_migrations ADD COLUMN IF NOT EXISTS statements text[]"
	ADD_NAME_COLUMN          = "ALTER TABLE supabase_migrations.schema_migrations ADD COLUMN IF NOT EXISTS name text"
	INSERT_MIGRATION_VERSION = "INSERT INTO supabase_migrations.schema_migrations(version, name, statements) VALUES($1, $2, $3)"
	DELETE_MIGRATION_VERSION = "DELETE FROM supabase_migrations.schema_migrations WHERE version = $1"
)

Variables

var ErrInvalidVersion = errors.New("invalid version number")

Functions

func CreateMigrationTable

func CreateMigrationTable(ctx context.Context, conn *pgx.Conn) error

func DeleteVersionSQL

func DeleteVersionSQL(batch *pgconn.Batch, version string)

func GetMigrationFile

func GetMigrationFile(version string, fsys afero.Fs) (string, error)

func InsertVersionSQL

func InsertVersionSQL(batch *pgconn.Batch, version, name string, stats []string)

func Run

func Run(ctx context.Context, config pgconn.Config, version, status string, fsys afero.Fs, options ...func(*pgx.ConnConfig)) error

func UpdateMigrationTable

func UpdateMigrationTable(ctx context.Context, conn *pgx.Conn, version, status string, fsys afero.Fs) error

Types

type MigrationFile

type MigrationFile struct {
	Lines   []string
	Version string
	Name    string
}

func NewMigrationFromFile

func NewMigrationFromFile(path string, fsys afero.Fs) (*MigrationFile, error)

func NewMigrationFromReader

func NewMigrationFromReader(sql io.Reader) (*MigrationFile, error)

func NewMigrationFromVersion

func NewMigrationFromVersion(version string, fsys afero.Fs) (*MigrationFile, error)

func (*MigrationFile) ExecBatch

func (m *MigrationFile) ExecBatch(ctx context.Context, conn *pgx.Conn) error

func (*MigrationFile) ExecBatchWithCache

func (m *MigrationFile) ExecBatchWithCache(ctx context.Context, conn *pgx.Conn) error