setup

Documentation

Index

• Variables
• func ComposeSQLVersion() string
• func UpgradeSQLData(db *dbs.DB) error
• type Config
• type SQLDump
  • func NewSQLDump() *SQLDump
  • func (this *SQLDump) Apply(db *dbs.DB, newResult *SQLDumpResult, showLog bool) (ops []string, err error)
  • func (this *SQLDump) Dump(db *dbs.DB) (result *SQLDumpResult, err error)
• type SQLDumpResult
  • func (this *SQLDumpResult) FindTable(tableName string) *SQLTable
• type SQLExecutor
  • func NewSQLExecutor(dbConfig *dbs.DBConfig) *SQLExecutor
  • func NewSQLExecutorFromCmd() (*SQLExecutor, error)
  • func (this *SQLExecutor) Run(showLog bool) error
• type SQLField
  • func (this *SQLField) EqualDefinition(definition2 string) bool
• type SQLIndex
• type SQLRecord
  • func (this *SQLRecord) ValuesEquals(values maps.Map) bool
• type SQLRecordsTable
• type SQLTable
  • func (this *SQLTable) FindField(fieldName string) *SQLField
  • func (this *SQLTable) FindIndex(indexName string) *SQLIndex
  • func (this *SQLTable) FindRecord(id int64) *SQLRecord
• type Setup
  • func NewSetup(config *Config) *Setup
  • func NewSetupFromCmd() *Setup
  • func (this *Setup) Run() error

Variables

var LatestSQLResult = &SQLDumpResult{}

Functions

func ComposeSQLVersion

func ComposeSQLVersion() string

func UpgradeSQLData

func UpgradeSQLData(db *dbs.DB) error

UpgradeSQLData 升级SQL数据

Types

type Config

type Config struct {
	APINodeProtocol string
	APINodeHost     string
	APINodePort     int
}

type SQLDump

type SQLDump struct {
}

func NewSQLDump

func NewSQLDump() *SQLDump

func (*SQLDump) Apply

func (this *SQLDump) Apply(db *dbs.DB, newResult *SQLDumpResult, showLog bool) (ops []string, err error)

Apply 应用数据

func (*SQLDump) Dump

func (this *SQLDump) Dump(db *dbs.DB) (result *SQLDumpResult, err error)

Dump 导出数据

type SQLDumpResult

type SQLDumpResult struct {
	Tables []*SQLTable `json:"tables"`
}

func (*SQLDumpResult) FindTable

func (this *SQLDumpResult) FindTable(tableName string) *SQLTable

type SQLExecutor

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

SQLExecutor 安装或升级SQL执行器

func NewSQLExecutor

func NewSQLExecutor(dbConfig *dbs.DBConfig) *SQLExecutor

func NewSQLExecutorFromCmd

func NewSQLExecutorFromCmd() (*SQLExecutor, error)

func (*SQLExecutor) Run

func (this *SQLExecutor) Run(showLog bool) error

type SQLField

type SQLField struct {
	Name       string `json:"name"`
	Definition string `json:"definition"`
}

func (*SQLField) EqualDefinition

func (this *SQLField) EqualDefinition(definition2 string) bool

type SQLIndex

type SQLIndex struct {
	Name       string `json:"name"`
	Definition string `json:"definition"`
}

type SQLRecord

type SQLRecord struct {
	Id           int64             `json:"id"`
	Values       map[string]string `json:"values"`
	UniqueFields []string          `json:"uniqueFields"`
	ExceptFields []string          `json:"exceptFields"`
}

func (*SQLRecord) ValuesEquals

func (this *SQLRecord) ValuesEquals(values maps.Map) bool

type SQLRecordsTable

type SQLRecordsTable struct {
	TableName    string
	UniqueFields []string
	ExceptFields []string
}

type SQLTable

type SQLTable struct {
	Name       string       `json:"name"`
	Engine     string       `json:"engine"`
	Charset    string       `json:"charset"`
	Definition string       `json:"definition"`
	Fields     []*SQLField  `json:"fields"`
	Indexes    []*SQLIndex  `json:"indexes"`
	Records    []*SQLRecord `json:"records"`
}

func (*SQLTable) FindField

func (this *SQLTable) FindField(fieldName string) *SQLField

func (*SQLTable) FindIndex

func (this *SQLTable) FindIndex(indexName string) *SQLIndex

func (*SQLTable) FindRecord

func (this *SQLTable) FindRecord(id int64) *SQLRecord

type Setup

type Setup struct {

	// 要返回的数据
	AdminNodeId     string
	AdminNodeSecret string
	// contains filtered or unexported fields
}

func NewSetup

func NewSetup(config *Config) *Setup

func NewSetupFromCmd

func NewSetupFromCmd() *Setup

func (*Setup) Run

func (this *Setup) Run() error