apply

Documentation

Index

• func BatchExecDDL(ctx context.Context, conn *pgx.Conn, sql io.Reader) error
• func MigrateDatabase(ctx context.Context, conn *pgx.Conn, fsys afero.Fs) error
• func MigrateUp(ctx context.Context, conn *pgx.Conn, pending []string, fsys afero.Fs) error
• type MigrationFile
  • func NewMigrationFromFile(path string, fsys afero.Fs) (*MigrationFile, error)
  • func NewMigrationFromReader(sql io.Reader) (*MigrationFile, error)
  • func (m *MigrationFile) ExecBatch(ctx context.Context, conn *pgx.Conn) error
  • func (m *MigrationFile) ExecBatchWithCache(ctx context.Context, conn *pgx.Conn) error

Functions

func BatchExecDDL

func BatchExecDDL(ctx context.Context, conn *pgx.Conn, sql io.Reader) error

func MigrateDatabase

func MigrateDatabase(ctx context.Context, conn *pgx.Conn, fsys afero.Fs) error

func MigrateUp

func MigrateUp(ctx context.Context, conn *pgx.Conn, pending []string, fsys afero.Fs) error

Types

type MigrationFile

type MigrationFile struct {
	Lines []string
	// contains filtered or unexported fields
}

func NewMigrationFromFile

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

func NewMigrationFromReader

func NewMigrationFromReader(sql io.Reader) (*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