Use both db name and migration table name for lock hash

bodyguard-ai · May 16, 2017 · 5f2a8b7 · 5f2a8b7
1 parent 2831b4c
commit 5f2a8b7
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/database/mysql/mysql.go b/database/mysql/mysql.go
@@ -156,7 +156,8 @@ func (m *Mysql) Lock() error {
 		return database.ErrLocked
 	}
 
-	aid, err := database.GenerateAdvisoryLockId(m.config.DatabaseName)
+	aid, err := database.GenerateAdvisoryLockId(
+		fmt.Sprintf("%s:%s", m.config.DatabaseName, m.config.MigrationsTable)
 	if err != nil {
 		return err
 	}
@@ -180,7 +181,8 @@ func (m *Mysql) Unlock() error {
 		return nil
 	}
 
-	aid, err := database.GenerateAdvisoryLockId(m.config.DatabaseName)
+	aid, err := database.GenerateAdvisoryLockId(
+		fmt.Sprintf("%s:%s", m.config.DatabaseName, m.config.MigrationsTable)
 	if err != nil {
 		return err
 	}