|
|
@@ -3,6 +3,7 @@ package core
|
|
|
import (
|
|
|
"fmt"
|
|
|
"go_server/base/config"
|
|
|
+ bizApp "go_server/model/biz_modules/app"
|
|
|
"go_server/model/system"
|
|
|
"gorm.io/gorm"
|
|
|
)
|
|
|
@@ -27,7 +28,13 @@ var allTables = []MigrateTable{
|
|
|
&system.SysSignConfig{},
|
|
|
}
|
|
|
|
|
|
+// bizTables 业务库需要迁移的表
|
|
|
+var bizTables = []MigrateTable{
|
|
|
+ &bizApp.CfAccount{},
|
|
|
+}
|
|
|
+
|
|
|
func Migrates() {
|
|
|
+ // 系统表迁移(主库)
|
|
|
db := MainDb()
|
|
|
CurrentDatabase := db.Migrator().CurrentDatabase()
|
|
|
Log.Info(fmt.Sprintf("当前数据库[%s]", CurrentDatabase))
|
|
|
@@ -36,6 +43,14 @@ func Migrates() {
|
|
|
migrationTable(db, mTables) // 同步数据库结构
|
|
|
sysDataInit(db) // 数据初始化
|
|
|
sysSignInfoInit(db) // 系统交互密钥初始化
|
|
|
+
|
|
|
+ // 业务表迁移(biz 库)
|
|
|
+ bizDbs, _, _ := BizDbs()
|
|
|
+ for alias, bizDb := range bizDbs {
|
|
|
+ Log.Info(fmt.Sprintf("开始迁移业务库[%s]", alias))
|
|
|
+ migrationTable(bizDb, bizTables)
|
|
|
+ }
|
|
|
+
|
|
|
Log.Info(fmt.Sprintf("数据库迁移完成"))
|
|
|
}
|
|
|
|