From c297b173ebd64d41739f4ded1f9c5b577418ca84 Mon Sep 17 00:00:00 2001 From: Tit Petric Date: Fri, 26 Apr 2019 21:29:18 +0200 Subject: [PATCH] upd(all): lock migrations table --- crm/db/migrate.go | 3 +++ messaging/db/migrate.go | 3 +++ system/db/migrate.go | 3 +++ 3 files changed, 9 insertions(+) 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