backends

Documentation

Index

• func CreateMigrationTable(db *sqlx.DB, query string) (string, error)
• func HasMigrationTable(db *sqlx.DB, query string) (bool, error)
• func InsertRecord(tx *sqlx.Tx, query string, args ...interface{}) error
• func QueryPrevious(db *sqlx.DB, query string) (map[string]string, error)
• func RepairHashes(tx *sqlx.Tx, query string, hashes map[string]string) error
• type Backend
• type MigrationRecord
• type MySQL
  • func (m *MySQL) CreateMigrationTable() (string, error)
  • func (m *MySQL) HasMigrationTable() (bool, error)
  • func (m *MySQL) InsertRecord(tx *sqlx.Tx, name string, hash string, comment string) error
  • func (m *MySQL) QueryPrevious() (map[string]string, error)
  • func (m *MySQL) RepairHashes(tx *sqlx.Tx, hashes map[string]string) error
  • func (m *MySQL) Setup(db *sqlx.DB, table string, tableSchema string)
• type Postgres
  • func (p *Postgres) CreateMigrationTable() (string, error)
  • func (p *Postgres) HasMigrationTable() (bool, error)
  • func (p *Postgres) InsertRecord(tx *sqlx.Tx, name string, hash string, comment string) error
  • func (p *Postgres) QueryPrevious() (map[string]string, error)
  • func (p *Postgres) RepairHashes(tx *sqlx.Tx, hashes map[string]string) error
  • func (p *Postgres) Setup(db *sqlx.DB, table string, tableSchema string)
• type SQLite
  • func (s *SQLite) CreateMigrationTable() (string, error)
  • func (s *SQLite) HasMigrationTable() (bool, error)
  • func (s *SQLite) InsertRecord(tx *sqlx.Tx, name string, hash string, comment string) error
  • func (s *SQLite) QueryPrevious() (map[string]string, error)
  • func (s *SQLite) RepairHashes(tx *sqlx.Tx, hashes map[string]string) error
  • func (s *SQLite) Setup(db *sqlx.DB, table string, tableSchema string)

Functions

func CreateMigrationTable

func CreateMigrationTable(db *sqlx.DB, query string) (string, error)

func HasMigrationTable

func HasMigrationTable(db *sqlx.DB, query string) (bool, error)

func InsertRecord

func InsertRecord(tx *sqlx.Tx, query string, args ...interface{}) error

func QueryPrevious

func QueryPrevious(db *sqlx.DB, query string) (map[string]string, error)

QueryPrevious runs the query from the Backend.QueryPrevious and returns the results.

func RepairHashes

func RepairHashes(tx *sqlx.Tx, query string, hashes map[string]string) error

Types

type Backend

type Backend interface {
	// Setup does the initial configuration of the backend.
	Setup(db *sqlx.DB, table string, tableSchema string)
	// InsertRecord migration record into the DB.
	InsertRecord(tx *sqlx.Tx, name string, hash string, comment string) error
	// HasMigrationTable returns true if the migration table exists.
	HasMigrationTable() (bool, error)
	// QueryPrevious queries and sets the records of all previous migrations.
	QueryPrevious() (map[string]string, error)
	// CreateMigrationTable makes the migrations table, and return the query used to
	// do it.
	CreateMigrationTable() (string, error)
	RepairHashes(tx *sqlx.Tx, hashes map[string]string) error
}

type MigrationRecord

type MigrationRecord struct {
	ID      int       `db:"id"`
	Name    string    `db:"name"`
	Hash    string    `db:"hash"`
	Date    time.Time `db:"date"`
	Comment string    `db:"comment"`
}

type MySQL

type MySQL struct {
	// contains filtered or unexported fields
}

func (*MySQL) CreateMigrationTable

func (m *MySQL) CreateMigrationTable() (string, error)

CreateMigrationTable makes the migrations table, and return the query used to do it.

func (*MySQL) HasMigrationTable

func (m *MySQL) HasMigrationTable() (bool, error)

HasMigrationTable returns true if the migration table exists.

func (*MySQL) InsertRecord

func (m *MySQL) InsertRecord(tx *sqlx.Tx, name string, hash string, comment string) error

InsertRecord migration record into the DB.

func (*MySQL) QueryPrevious

func (m *MySQL) QueryPrevious() (map[string]string, error)

QueryPrevious queries and sets the records of all previous migrations.

func (*MySQL) RepairHashes

func (m *MySQL) RepairHashes(tx *sqlx.Tx, hashes map[string]string) error

func (*MySQL) Setup

func (m *MySQL) Setup(db *sqlx.DB, table string, tableSchema string)

Setup does the initial configuration of the backend.

type Postgres

type Postgres struct {
	// contains filtered or unexported fields
}

func (*Postgres) CreateMigrationTable

func (p *Postgres) CreateMigrationTable() (string, error)

CreateMigrationTable makes the migrations table, and return the query used to do it.

func (*Postgres) HasMigrationTable

func (p *Postgres) HasMigrationTable() (bool, error)

HasMigrationTable returns true if the migration table exists.

func (*Postgres) InsertRecord

func (p *Postgres) InsertRecord(tx *sqlx.Tx, name string, hash string, comment string) error

InsertRecord migration record into the DB.

func (*Postgres) QueryPrevious

func (p *Postgres) QueryPrevious() (map[string]string, error)

QueryPrevious queries and sets the records of all previous migrations.

func (*Postgres) RepairHashes

func (p *Postgres) RepairHashes(tx *sqlx.Tx, hashes map[string]string) error

func (*Postgres) Setup

func (p *Postgres) Setup(db *sqlx.DB, table string, tableSchema string)

Setup does the initial configuration of the backend.

type SQLite

type SQLite struct {
	// contains filtered or unexported fields
}

func (*SQLite) CreateMigrationTable

func (s *SQLite) CreateMigrationTable() (string, error)

CreateMigrationTable makes the migrations table, and return the query used to do it.

func (*SQLite) HasMigrationTable

func (s *SQLite) HasMigrationTable() (bool, error)

HasMigrationTable returns true if the migration table exists.

func (*SQLite) InsertRecord

func (s *SQLite) InsertRecord(tx *sqlx.Tx, name string, hash string, comment string) error

InsertRecord migration record into the DB.

func (*SQLite) QueryPrevious

func (s *SQLite) QueryPrevious() (map[string]string, error)

QueryPrevious queries and sets the records of all previous migrations.

func (*SQLite) RepairHashes

func (s *SQLite) RepairHashes(tx *sqlx.Tx, hashes map[string]string) error

func (*SQLite) Setup

func (s *SQLite) Setup(db *sqlx.DB, table string, tableSchema string)

Setup does the initial configuration of the backend.