manager

Documentation

Index

• Constants
• type DB
• type DBManager
  • func NewDBManager(log zerolog.Logger, d DB, lf lock.LockFactory) *DBManager
  • func (m *DBManager) CheckMigrationRequired(curVersion, wantedVersion uint) (bool, error)
  • func (m *DBManager) CheckVersion(curVersion, wantedVersion uint) error
  • func (m *DBManager) Create(ctx context.Context, stmts []string, wantedVersion uint) error
  • func (m *DBManager) DDL() []string
  • func (m *DBManager) Drop(ctx context.Context) error
  • func (m *DBManager) Export(ctx context.Context, objectKinds []string, w io.Writer) error
  • func (m *DBManager) GetVersion(ctx context.Context) (uint, error)
  • func (m *DBManager) Import(ctx context.Context, r io.Reader) error
  • func (m *DBManager) Lock(ctx context.Context) error
  • func (m *DBManager) Migrate(ctx context.Context) error
  • func (m *DBManager) MigrateToVersion(ctx context.Context, newVersion uint) error
  • func (m *DBManager) Setup(ctx context.Context) error
  • func (m *DBManager) Unlock() error
  • func (m *DBManager) WantedVersion() uint

Constants

const (
	MaxQueryLimit = 100

	DBLockName = "dbupdate"
)

Types

type DB

type DB interface {
	DBType() sql.Type
	DB() *sql.DB
	Version() uint

	Do(ctx context.Context, f func(tx *sql.Tx) error) error

	MigrateFuncs() map[uint]sqlg.MigrateFunc

	DDL() []string
	ObjectsInfo() []sqlg.ObjectInfo

	UnmarshalExportObject(data []byte) (sqlg.Object, error)
	InsertRawObject(tx *sql.Tx, obj sqlg.Object) error
	SelectObject(kind string) *sq.SelectBuilder
	FetchObjects(tx *sql.Tx, kind string, q sq.Builder) ([]sqlg.Object, error)
	ObjectToExportJSON(obj sqlg.Object, e *json.Encoder) error

	Sequences() []sqlg.Sequence
	GetSequence(tx *sql.Tx, sequenceName string) (uint64, error)
	PopulateSequences(tx *sql.Tx) error
}

type DBManager

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

func NewDBManager

func NewDBManager(log zerolog.Logger, d DB, lf lock.LockFactory) *DBManager

func (*DBManager) CheckMigrationRequired

func (m *DBManager) CheckMigrationRequired(curVersion, wantedVersion uint) (bool, error)

func (*DBManager) CheckVersion

func (m *DBManager) CheckVersion(curVersion, wantedVersion uint) error

func (*DBManager) Create

func (m *DBManager) Create(ctx context.Context, stmts []string, wantedVersion uint) error

func (*DBManager) DDL

func (m *DBManager) DDL() []string

func (*DBManager) Drop

func (m *DBManager) Drop(ctx context.Context) error

func (*DBManager) Export

func (m *DBManager) Export(ctx context.Context, objectKinds []string, w io.Writer) error

func (*DBManager) GetVersion

func (m *DBManager) GetVersion(ctx context.Context) (uint, error)

func (*DBManager) Import

func (m *DBManager) Import(ctx context.Context, r io.Reader) error

func (*DBManager) Lock

func (m *DBManager) Lock(ctx context.Context) error

func (*DBManager) Migrate

func (m *DBManager) Migrate(ctx context.Context) error

func (*DBManager) MigrateToVersion

func (m *DBManager) MigrateToVersion(ctx context.Context, newVersion uint) error

func (*DBManager) Setup

func (m *DBManager) Setup(ctx context.Context) error

func (*DBManager) Unlock

func (m *DBManager) Unlock() error

func (*DBManager) WantedVersion

func (m *DBManager) WantedVersion() uint