diff --git a/crm/db/migrate.go b/crm/db/migrate.go index b8aa86a0f..3c8258589 100644 --- a/crm/db/migrate.go +++ b/crm/db/migrate.go @@ -97,6 +97,9 @@ func Migrate(db *factory.DB) error { return err } + db.Exec("LOCK TABLE migrations WRITE;") + defer db.Exec("UNLOCK TABLES") + for _, filename := range files { if err := migrate(filename, true); err != nil { return err diff --git a/messaging/db/migrate.go b/messaging/db/migrate.go index 0af99d11e..1f146cd15 100644 --- a/messaging/db/migrate.go +++ b/messaging/db/migrate.go @@ -97,6 +97,9 @@ func Migrate(db *factory.DB) error { return err } + db.Exec("LOCK TABLE migrations WRITE;") + defer db.Exec("UNLOCK TABLES") + for _, filename := range files { if err := migrate(filename, true); err != nil { return err diff --git a/system/db/migrate.go b/system/db/migrate.go index bac21abae..f362bec37 100644 --- a/system/db/migrate.go +++ b/system/db/migrate.go @@ -97,6 +97,9 @@ func Migrate(db *factory.DB) error { return err } + db.Exec("LOCK TABLE migrations WRITE;") + defer db.Exec("UNLOCK TABLES") + for _, filename := range files { if err := migrate(filename, true); err != nil { return err