Documentation
¶
Index ¶
- Constants
- Variables
- type DbVersionInfo
- type ILogger
- type IVersionMag
- type IVersionMagV2
- type VersionMag
- func (mag *VersionMag) AddLogger(logger logFunc)
- func (mag *VersionMag) Label() string
- func (mag *VersionMag) SetLabel(label string)
- func (mag VersionMag) Upgrade(version string) error
- func (mag *VersionMag) UpgradeOne(upVersion string, sqlFile string) error
- func (mag VersionMag) Version() (string, error)
- func (mag *VersionMag) WithLock(lock interfaces.ItfOptimisticLock) *VersionMag
- type VersionMagV2
- func (mag *VersionMagV2) AddLogger(logger logFunc)
- func (mag *VersionMagV2) AllVersionInfo() []DbVersionInfo
- func (mag *VersionMagV2) AppendEmbedFS(fss embed.FS) error
- func (mag *VersionMagV2) AppendSqlContent(version string, content string)
- func (mag *VersionMagV2) AppendVersion(v DbVersionInfo)
- func (mag *VersionMagV2) AppendVersionDir(sqlDir string) error
- func (mag *VersionMagV2) Label() string
- func (mag *VersionMagV2) SetLabel(label string)
- func (mag *VersionMagV2) SetVars(vars map[string]string)
- func (mag *VersionMagV2) Upgrade(version string) error
- func (mag *VersionMagV2) UpgradeOne(vInfo DbVersionInfo) error
- func (mag VersionMagV2) Version() (string, error)
- func (mag *VersionMagV2) WithLock(lock interfaces.ItfOptimisticLock) *VersionMagV2
Constants ¶
View Source
const VERSION_MAG_TABLE = "migrate_version"
Variables ¶
View Source
var CREATE_VERSION_TABLE_SQL = fmt.Sprintf(` CREATE TABLE IF NOT EXISTS %s ( id bigint unsigned NOT NULL AUTO_INCREMENT, created_at timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP, label varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '' COMMENT 'label', version varchar(20) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '' COMMENT '版本号', upgrade_file varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '' COMMENT '升级文件', PRIMARY KEY (id), UNIQUE KEY idx_version (label,version) ) ENGINE = InnoDB AUTO_INCREMENT = 1 DEFAULT CHARSET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT ='升级表' `, VERSION_MAG_TABLE)
Functions ¶
This section is empty.
Types ¶
type DbVersionInfo ¶
type IVersionMag ¶
type IVersionMagV2 ¶
type IVersionMagV2 interface {
AppendVersionDir(sqlDir string) error
AppendVersion(v DbVersionInfo)
AppendSqlContent(version string, content string)
AppendEmbedFS(fs embed.FS) error
AllVersionInfo() []DbVersionInfo
Upgrade(version string) error
UpgradeOne(vInfo DbVersionInfo) error
Version() (string, error)
SetLabel(label string)
Label() string
SetVars(map[string]string)
ILogger
}
type VersionMag ¶
type VersionMag struct {
// contains filtered or unexported fields
}
func NewVersionMag ¶
func NewVersionMag(sqlDir string, db *sql.DB) (*VersionMag, error)
func (*VersionMag) AddLogger ¶
func (mag *VersionMag) AddLogger(logger logFunc)
func (*VersionMag) Label ¶
func (mag *VersionMag) Label() string
func (*VersionMag) SetLabel ¶
func (mag *VersionMag) SetLabel(label string)
func (*VersionMag) UpgradeOne ¶
func (mag *VersionMag) UpgradeOne(upVersion string, sqlFile string) error
升级一次版本
func (*VersionMag) WithLock ¶
func (mag *VersionMag) WithLock(lock interfaces.ItfOptimisticLock) *VersionMag
type VersionMagV2 ¶
type VersionMagV2 struct {
// contains filtered or unexported fields
}
func NewDBVersionMagV2 ¶
func NewDBVersionMagV2(db *sql.DB) (*VersionMagV2, error)
func (*VersionMagV2) AddLogger ¶
func (mag *VersionMagV2) AddLogger(logger logFunc)
func (*VersionMagV2) AllVersionInfo ¶
func (mag *VersionMagV2) AllVersionInfo() []DbVersionInfo
func (*VersionMagV2) AppendEmbedFS ¶
func (mag *VersionMagV2) AppendEmbedFS(fss embed.FS) error
func (*VersionMagV2) AppendSqlContent ¶
func (mag *VersionMagV2) AppendSqlContent(version string, content string)
func (*VersionMagV2) AppendVersion ¶
func (mag *VersionMagV2) AppendVersion(v DbVersionInfo)
func (*VersionMagV2) AppendVersionDir ¶
func (mag *VersionMagV2) AppendVersionDir(sqlDir string) error
func (*VersionMagV2) Label ¶
func (mag *VersionMagV2) Label() string
func (*VersionMagV2) SetLabel ¶
func (mag *VersionMagV2) SetLabel(label string)
func (*VersionMagV2) SetVars ¶
func (mag *VersionMagV2) SetVars(vars map[string]string)
func (*VersionMagV2) UpgradeOne ¶
func (mag *VersionMagV2) UpgradeOne(vInfo DbVersionInfo) error
升级一次版本
func (*VersionMagV2) WithLock ¶
func (mag *VersionMagV2) WithLock(lock interfaces.ItfOptimisticLock) *VersionMagV2
Click to show internal directories.
Click to hide internal directories.