Converting to structured logging the file store/sqlstore/upgrade.go (#12628)

* Converting to structured logging the file store/sqlstore/upgrade.go

* changes as per review
Этот коммит содержится в:
Nikhil Ranjan
2019-10-14 12:55:50 +02:00
коммит произвёл Jesús Espino
родитель 6f4f06f8d4
Коммит c5dcd85bc8

Просмотреть файл

@@ -6,7 +6,6 @@ package sqlstore
import ( import (
"database/sql" "database/sql"
"encoding/json" "encoding/json"
"fmt"
"os" "os"
"strings" "strings"
"time" "time"
@@ -106,7 +105,7 @@ func UpgradeDatabase(sqlStore SqlStore, currentModelVersionString string) error
} }
currentSchemaVersion = &currentModelVersion currentSchemaVersion = &currentModelVersion
mlog.Info(fmt.Sprintf("The database schema has been set to version %s", *currentSchemaVersion)) mlog.Info("The database schema version has been set", mlog.String("version", currentSchemaVersion.String()))
return nil return nil
} }
@@ -119,7 +118,7 @@ func UpgradeDatabase(sqlStore SqlStore, currentModelVersionString string) error
if currentSchemaVersion.GTE(nextUnsupportedMajorVersion) { if currentSchemaVersion.GTE(nextUnsupportedMajorVersion) {
return errors.Errorf("Database schema version %s is not supported. This Mattermost server supports only >=%s, <%s. Please upgrade to at least version %s before continuing.", *currentSchemaVersion, currentModelVersion, nextUnsupportedMajorVersion, nextUnsupportedMajorVersion) return errors.Errorf("Database schema version %s is not supported. This Mattermost server supports only >=%s, <%s. Please upgrade to at least version %s before continuing.", *currentSchemaVersion, currentModelVersion, nextUnsupportedMajorVersion, nextUnsupportedMajorVersion)
} else if currentSchemaVersion.GT(currentModelVersion) { } else if currentSchemaVersion.GT(currentModelVersion) {
mlog.Warn(fmt.Sprintf("The database schema with version %s is newer than Mattermost version %s.", currentSchemaVersion, currentModelVersion)) mlog.Warn("The database schema version and model versions do not match", mlog.String("schema_version", currentSchemaVersion.String()), mlog.String("model_version", currentModelVersion.String()))
} }
// Otherwise, apply any necessary migrations. Note that these methods currently invoke // Otherwise, apply any necessary migrations. Note that these methods currently invoke
@@ -176,12 +175,12 @@ func saveSchemaVersion(sqlStore SqlStore, version string) {
os.Exit(EXIT_VERSION_SAVE) os.Exit(EXIT_VERSION_SAVE)
} }
mlog.Warn(fmt.Sprintf("The database schema has been upgraded to version %v", version)) mlog.Warn("The database schema version has been upgraded", mlog.String("version", version))
} }
func shouldPerformUpgrade(sqlStore SqlStore, currentSchemaVersion string, expectedSchemaVersion string) bool { func shouldPerformUpgrade(sqlStore SqlStore, currentSchemaVersion string, expectedSchemaVersion string) bool {
if sqlStore.GetCurrentSchemaVersion() == currentSchemaVersion { if sqlStore.GetCurrentSchemaVersion() == currentSchemaVersion {
mlog.Warn(fmt.Sprintf("Attempting to upgrade the database schema version from %s to %v", currentSchemaVersion, expectedSchemaVersion)) mlog.Warn("Attempting to upgrade the database schema version", mlog.String("current_version", currentSchemaVersion), mlog.String("new_version", expectedSchemaVersion))
return true return true
} }
@@ -205,7 +204,7 @@ func UpgradeDatabaseToVersion32(sqlStore SqlStore) {
} }
func themeMigrationFailed(err error) { func themeMigrationFailed(err error) {
mlog.Critical(fmt.Sprintf("Failed to migrate User.ThemeProps to Preferences table %v", err)) mlog.Critical("Failed to migrate User.ThemeProps to Preferences table", mlog.Err(err))
time.Sleep(time.Second) time.Sleep(time.Second)
os.Exit(EXIT_THEME_MIGRATION) os.Exit(EXIT_THEME_MIGRATION)
} }
@@ -479,7 +478,7 @@ func UpgradeDatabaseToVersion49(sqlStore SqlStore) {
defaultTimezone := timezones.DefaultUserTimezone() defaultTimezone := timezones.DefaultUserTimezone()
defaultTimezoneValue, err := json.Marshal(defaultTimezone) defaultTimezoneValue, err := json.Marshal(defaultTimezone)
if err != nil { if err != nil {
mlog.Critical(fmt.Sprint(err)) mlog.Critical(err.Error())
} }
sqlStore.CreateColumnIfNotExists("Users", "Timezone", "varchar(256)", "varchar(256)", string(defaultTimezoneValue)) sqlStore.CreateColumnIfNotExists("Users", "Timezone", "varchar(256)", "varchar(256)", string(defaultTimezoneValue))
sqlStore.RemoveIndexIfExists("idx_channels_displayname", "Channels") sqlStore.RemoveIndexIfExists("idx_channels_displayname", "Channels")
@@ -673,12 +672,12 @@ func UpgradeDatabaseToVersion511(sqlStore SqlStore) {
// Enforce all teams have an InviteID set // Enforce all teams have an InviteID set
var teams []*model.Team var teams []*model.Team
if _, err := sqlStore.GetReplica().Select(&teams, "SELECT * FROM Teams WHERE InviteId = ''"); err != nil { if _, err := sqlStore.GetReplica().Select(&teams, "SELECT * FROM Teams WHERE InviteId = ''"); err != nil {
mlog.Error("Error fetching Teams without InviteID: " + err.Error()) mlog.Error("Error fetching Teams without InviteID", mlog.Err(err))
} else { } else {
for _, team := range teams { for _, team := range teams {
team.InviteId = model.NewId() team.InviteId = model.NewId()
if _, err := sqlStore.Team().Update(team); err != nil { if _, err := sqlStore.Team().Update(team); err != nil {
mlog.Error("Error updating Team InviteIDs: " + err.Error()) mlog.Error("Error updating Team InviteIDs", mlog.String("team_id", team.Id), mlog.Err(err))
} }
} }
} }