migrator

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

type HistoryModel struct {
	ID        uint64    `gorm:"primarykey"`
	CreatedAt time.Time `json:"createdAt" gorm:"created_at;type:datetime;not null;default CURRENT_TIMESTAMP"`
	UpdatedAt time.Time `json:"updatedAt" gorm:"updated_at;type:datetime;not null;default CURRENT_TIMESTAMP; on update CURRENT_TIMESTAMP"`

	ServiceName  string `json:"serviceName"  gorm:"service_name;type:varchar(32);not null;comment:微服务名"`
	Filename     string `json:"filename"     gorm:"filename;type:varchar(191);not null;comment:脚本类型"`
	Checksum     string `json:"checksum"     gorm:"checksum;type:char(128);not null;comment:rawtext 的 md5 值"`
	InstalledBy  string `json:"installedBy"  gorm:"installed_by;type:varchar(32);not null;comment:执行人"`
	InstalledOn  string `json:"installedOn"  gorm:"install_on;type:varchar(32);not null;comment:执行平台"`
	LanguageType string `json:"languageType" gorm:"language_type;type:varchar(16);not null;comment:SQL, Go, Java"`
	Reversed     string `json:"reversed"     gorm:"reversed;type:longtext;not null;comment:反转的 DDL"`
}

type Migrator struct {
	Parameters

	LocalScripts *Scripts
	// contains filtered or unexported fields
}

type Module []*Script

type Parameters interface {
	// DSN gets MySQL DSN
	DSN() string

	// SandboxDSN gets sandbox DSN
	SandboxDSN() string

	// database name
	Database() string

	// MigrationDir gets migration scripts direction from repo, like .dice/migrations or 4.1/sqls
	MigrationDir() string

	// Modules is the modules for installing.
	// if is nil, to install all modules in the MigrationDir()
	Modules() []string

	// Workdir gets pipeline node workdir
	Workdir() string

	// DebugSQL gets weather to debug SQL executing
	DebugSQL() bool

	NeedErdaMySQLLint() bool

	Rules() []rules.Ruler
}

type Schema struct {
	TableDefinitions map[string]*TableDefinition
}

type Script struct {
	// path from repo root, filepath.Base(script.Name) for base filename
	Name      string
	Rawtext   []byte
	Reversing []string
	Nodes     []ast.StmtNode
	Pending   bool
	Record    *HistoryModel
	Workdir   string
	// contains filtered or unexported fields
}

type Scripts struct {
	Workdir       string
	Dirname       string
	ServicesNames []string
	Services      map[string]Module
	// contains filtered or unexported fields
}

type TableDefinition struct {
	CreateStmt *ast.CreateTableStmt
}