schema

Mar 25, 2022

Changes in this version

+ var MSSQL = mssqlDialect

Dec 9, 2021

Changes in this version

+ var MySQL = mysqlDialect

+ var SQLite = &sqliteDialect

+ type Connection interface

+ type DB interface

+ Conn func(ctx context.Context) (*sql.Conn, error)

type Dialect

+ CreateMigrationsTable func(ctx context.Context, tx Queryer, tableName string) error

+ GetAppliedMigrations func(ctx context.Context, tx Queryer, tableName string) (applied []*AppliedMigration, err error)

+ InsertAppliedMigration func(ctx context.Context, tx Queryer, tableName string, migration *AppliedMigration) error

+ type Locker interface

+ Lock func(ctx context.Context, tx Queryer, tableName string) error

+ Unlock func(ctx context.Context, tx Queryer, tableName string) error

type Migration

+ func FSMigrations(filesystem fs.FS, glob string) (migrations []*Migration, err error)

+ func (m *Migration) MD5() string

type Option

+ func WithContext(ctx context.Context) Option

type Queryer

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ QueryContext func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ type Transactor interface

+ BeginTx func(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

May 20, 2020

Changes in this version

type Dialect

+ UnlockSQL func(tableName string) string

May 18, 2020

Changes in this version

+ type Logger interface

+ Print func(...interface{})

type Migrator

+ Logger Logger

type Option

+ func WithLogger(logger Logger) Option

Sep 29, 2019

Changes in this version

+ const DefaultTableName

+ var ErrNilDB = errors.New("DB pointer is nil")

+ var Postgres = postgresDialect

+ func MigrationIDFromFilename(filename string) string

+ func SortMigrations(migrations []*Migration)

+ type AppliedMigration struct

+ AppliedAt time.Time

+ Checksum string

+ ExecutionTimeInMillis int

+ type Dialect interface

+ CreateSQL func(tableName string) string

+ InsertSQL func(tableName string) string

+ LockSQL func(tableName string) string

+ QuotedTableName func(schemaName, tableName string) string

+ SelectSQL func(tableName string) string

+ type File interface

+ Name func() string

+ Read func(b []byte) (n int, err error)

+ type Migration struct

+ ID string

+ Script string

+ func MigrationFromFile(file File) (migration *Migration, err error)

+ func MigrationFromFilePath(filename string) (migration *Migration, err error)

+ func MigrationsFromDirectoryPath(dirPath string) (migrations []*Migration, err error)

+ type Migrator struct

+ Dialect Dialect

+ SchemaName string

+ TableName string

+ func NewMigrator(options ...Option) Migrator

+ func (m Migrator) Apply(db *sql.DB, migrations []*Migration) error

+ func (m Migrator) GetAppliedMigrations(db Queryer) (applied map[string]*AppliedMigration, err error)

+ func (m Migrator) QuotedTableName() string

+ type Option func(m Migrator) Migrator

+ func WithDialect(dialect Dialect) Option

+ func WithTableName(names ...string) Option

+ type Queryer interface

+ Query func(sql string, args ...interface{}) (*sql.Rows, error)