mirror of
https://github.com/Rain-kl/OpenFlare.git
synced 2026-10-12 18:26:36 +08:00
[优化] 移除数据库迁移中的 ApplyCurrentSchema 调用
This commit is contained in:
@@ -18,9 +18,6 @@ func V10() Migration {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func migrateV10(ctx Context, db *gorm.DB, backend string) error {
|
func migrateV10(ctx Context, db *gorm.DB, backend string) error {
|
||||||
if err := ctx.ApplyCurrentSchema(db, backend); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
return ctx.EnsureDefaultGitHubAuthSource(db)
|
return ctx.EnsureDefaultGitHubAuthSource(db)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -18,7 +18,7 @@ func V11() Migration {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func migrateV11(ctx Context, db *gorm.DB, backend string) error {
|
func migrateV11(ctx Context, db *gorm.DB, backend string) error {
|
||||||
return ctx.ApplyCurrentSchema(db, backend)
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func validateV11(ctx Context, db *gorm.DB, backend string) error {
|
func validateV11(ctx Context, db *gorm.DB, backend string) error {
|
||||||
|
|||||||
@@ -18,7 +18,7 @@ func V12() Migration {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func migrateV12(ctx Context, db *gorm.DB, backend string) error {
|
func migrateV12(ctx Context, db *gorm.DB, backend string) error {
|
||||||
return ctx.ApplyCurrentSchema(db, backend)
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func validateV12(ctx Context, db *gorm.DB, backend string) error {
|
func validateV12(ctx Context, db *gorm.DB, backend string) error {
|
||||||
|
|||||||
@@ -18,9 +18,6 @@ func V13() Migration {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func migrateV13(ctx Context, db *gorm.DB, backend string) error {
|
func migrateV13(ctx Context, db *gorm.DB, backend string) error {
|
||||||
if err := ctx.ApplyCurrentSchema(db, backend); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
return ctx.EnsureDefaultWAFRuleGroup(db)
|
return ctx.EnsureDefaultWAFRuleGroup(db)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -18,9 +18,6 @@ func V14() Migration {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func migrateV14(ctx Context, db *gorm.DB, backend string) error {
|
func migrateV14(ctx Context, db *gorm.DB, backend string) error {
|
||||||
if err := ctx.ApplyCurrentSchema(db, backend); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
return ctx.EnsureDefaultWAFRuleGroup(db)
|
return ctx.EnsureDefaultWAFRuleGroup(db)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -30,7 +30,7 @@ func (nodeV15) TableName() string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func migrateV15(ctx Context, db *gorm.DB, backend string) error {
|
func migrateV15(ctx Context, db *gorm.DB, backend string) error {
|
||||||
return ctx.ApplyCurrentSchema(db, backend)
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func validateV15(ctx Context, db *gorm.DB, backend string) error {
|
func validateV15(ctx Context, db *gorm.DB, backend string) error {
|
||||||
|
|||||||
@@ -46,9 +46,6 @@ func (proxyRouteV16) TableName() string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func migrateV16(ctx Context, db *gorm.DB, backend string) error {
|
func migrateV16(ctx Context, db *gorm.DB, backend string) error {
|
||||||
if err := ctx.ApplyCurrentSchema(db, backend); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
if err := db.AutoMigrate(&tunnelV16{}); err != nil {
|
if err := db.AutoMigrate(&tunnelV16{}); err != nil {
|
||||||
return fmt.Errorf("auto migrate tunnelV16: %w", err)
|
return fmt.Errorf("auto migrate tunnelV16: %w", err)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -35,7 +35,7 @@ func (wafRuleGroupV17) TableName() string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func migrateV17(ctx Context, db *gorm.DB, backend string) error {
|
func migrateV17(ctx Context, db *gorm.DB, backend string) error {
|
||||||
return ctx.ApplyCurrentSchema(db, backend)
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func validateV17(ctx Context, db *gorm.DB, backend string) error {
|
func validateV17(ctx Context, db *gorm.DB, backend string) error {
|
||||||
|
|||||||
@@ -31,7 +31,7 @@ func (wafIPGroupV18) TableName() string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func migrateV18(ctx Context, db *gorm.DB, backend string) error {
|
func migrateV18(ctx Context, db *gorm.DB, backend string) error {
|
||||||
return ctx.ApplyCurrentSchema(db, backend)
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func validateV18(ctx Context, db *gorm.DB, backend string) error {
|
func validateV18(ctx Context, db *gorm.DB, backend string) error {
|
||||||
|
|||||||
@@ -64,11 +64,6 @@ func migrateV19(ctx Context, db *gorm.DB, backend string) error {
|
|||||||
slog.Info("dropped tunnel_id column from proxy_routes")
|
slog.Info("dropped tunnel_id column from proxy_routes")
|
||||||
}
|
}
|
||||||
|
|
||||||
slog.Info("v19: starting ApplyCurrentSchema (auto-migrate all tables)")
|
|
||||||
if err := ctx.ApplyCurrentSchema(db, backend); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
slog.Info("v19: ApplyCurrentSchema completed")
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -42,9 +42,6 @@ func migrateV20(ctx Context, db *gorm.DB, backend string) error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if err := ctx.ApplyCurrentSchema(db, backend); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
return validateV20(ctx, db, backend)
|
return validateV20(ctx, db, backend)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -18,9 +18,6 @@ func V8() Migration {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func migrateV8(ctx Context, db *gorm.DB, backend string) error {
|
func migrateV8(ctx Context, db *gorm.DB, backend string) error {
|
||||||
if err := ctx.ApplyCurrentSchema(db, backend); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
if err := ctx.BackfillOriginsFromProxyRoutes(db); err != nil {
|
if err := ctx.BackfillOriginsFromProxyRoutes(db); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user