From f293d0ef2dea7fab4e06935923df8b1ebb2bfc85 Mon Sep 17 00:00:00 2001 From: Michael Li Date: Sun, 24 Jul 2022 11:29:42 +0800 Subject: [PATCH] change migration table name same table prefix as other table --- internal/migration/migration_embed.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/internal/migration/migration_embed.go b/internal/migration/migration_embed.go index cc157cd9..c9368987 100644 --- a/internal/migration/migration_embed.go +++ b/internal/migration/migration_embed.go @@ -49,18 +49,19 @@ func Run() { return } + migrationsTable := conf.DatabaseSetting.TablePrefix + "schema_migrations" if conf.CfgIf("MySQL") { srcDriver, err = iofs.New(migration.Files, "mysql") - dbDriver, err2 = mysql.WithInstance(db, &mysql.Config{}) + dbDriver, err2 = mysql.WithInstance(db, &mysql.Config{MigrationsTable: migrationsTable}) } else if conf.CfgIf("PostgreSQL") || conf.CfgIf("Postgres") { srcDriver, err = iofs.New(migration.Files, "postgres") - dbDriver, err2 = postgres.WithInstance(db, &postgres.Config{}) + dbDriver, err2 = postgres.WithInstance(db, &postgres.Config{MigrationsTable: migrationsTable}) } else if conf.CfgIf("Sqlite3") { srcDriver, err = iofs.New(migration.Files, "sqlite3") - dbDriver, err2 = sqlite3.WithInstance(db, &sqlite3.Config{}) + dbDriver, err2 = sqlite3.WithInstance(db, &sqlite3.Config{MigrationsTable: migrationsTable}) } else { srcDriver, err = iofs.New(migration.Files, "mysql") - dbDriver, err2 = mysql.WithInstance(db, &mysql.Config{}) + dbDriver, err2 = mysql.WithInstance(db, &mysql.Config{MigrationsTable: migrationsTable}) } if err2 != nil {