db

Documentation

Index

• Constants
• type Database
  • func GetDatabase() *Database
  • func NewDatabase(config *config.Database) *Database
  • func (db *Database) GetLevelDB(name string) *leveldb.DB
  • func (db *Database) GetSQLite(name string) *SQLite
  • func (db *Database) RevertMigrations() error
  • func (db *Database) RunMigrations() error
• type SQLMigration
  • func NewSQLMigration(name string, upQuery string, downQuery string) SQLMigration
• type SQLite
  • func (s *SQLite) AddMigration(migration ...SQLMigration)
  • func (s *SQLite) Migrations() []SQLMigration
  • func (s *SQLite) RevertMigrations() error
  • func (s *SQLite) RunMigrations() error

Constants

const CreateMigrationTable string = `
	CREATE TABLE IF NOT EXISTS migration (
		name TEXT NOT NULL PRIMARY KEY,
		created_at INTEGER NOT NULL
	);
`

const DeleteMigrationEntry string = `
	DELETE FROM migration WHERE name = ?
`

const FindMigrationEntry string = `
	SELECT name FROM migration WHERE name = ?
`

const NewMigrationEntry string = `
	INSERT INTO migration (name, created_at) VALUES (?, ?)
`

Types

type Database

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

func GetDatabase

func GetDatabase() *Database

func NewDatabase

func NewDatabase(config *config.Database) *Database

func (*Database) GetLevelDB

func (db *Database) GetLevelDB(name string) *leveldb.DB

func (*Database) GetSQLite

func (db *Database) GetSQLite(name string) *SQLite

func (*Database) RevertMigrations

func (db *Database) RevertMigrations() error

func (*Database) RunMigrations

func (db *Database) RunMigrations() error

type SQLMigration

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

func NewSQLMigration

func NewSQLMigration(name string, upQuery string, downQuery string) SQLMigration

type SQLite

type SQLite struct {
	Db *sql.DB
	// contains filtered or unexported fields
}

SQLite struct definition

func (*SQLite) AddMigration

func (s *SQLite) AddMigration(migration ...SQLMigration)

AddMigration adds SQLMigration to migrations, can pass array of migrations

func (*SQLite) Migrations

func (s *SQLite) Migrations() []SQLMigration

Migrations return migrations array

func (*SQLite) RevertMigrations

func (s *SQLite) RevertMigrations() error

RevertMigrations revert all migrations in reverse order, from the last one to first

func (*SQLite) RunMigrations

func (s *SQLite) RunMigrations() error

RunMigrations run migrations - from first one to last