Skip to content

Commit ea526b7

Browse files
committed
Refactor mysqldump user backup handling and improve error logging
1 parent bcbc195 commit ea526b7

File tree

1 file changed

+11
-11
lines changed

1 file changed

+11
-11
lines changed

cluster/srv_job.go

+11-11
Original file line numberDiff line numberDiff line change
@@ -1731,15 +1731,6 @@ func (server *ServerMonitor) JobBackupMysqldump(filename string) error {
17311731
gtidRegex = regexp.MustCompile(`GTID_PURGED\s*=(\/\*!.+\*\/)?\s*'(.+)'`)
17321732
}
17331733

1734-
if cluster.Conf.BackupSplitMysqlUser {
1735-
server.LastBackupMeta.Logical.SplitUser = true
1736-
err := server.JobBackupMysqldumpUser(filename)
1737-
if err != nil {
1738-
cluster.LogModulePrintf(cluster.Conf.Verbose, config.ConstLogModTask, config.LvlErr, "Error mysqldump backup request: %s", err.Error())
1739-
return err
1740-
}
1741-
}
1742-
17431734
var bfile, bgtid string
17441735
var bpos uint64
17451736

@@ -1876,11 +1867,11 @@ func (server *ServerMonitor) JobBackupMysqldump(filename string) error {
18761867
return err
18771868
}
18781869

1879-
func (server *ServerMonitor) JobBackupMysqldumpUser(filename string) error {
1870+
func (server *ServerMonitor) JobBackupMysqldumpUser() error {
18801871
cluster := server.ClusterGroup
18811872
var err error
18821873

1883-
dir := filepath.Dir(filename)
1874+
dir := server.GetMyBackupDirectory()
18841875
userpath := filepath.Join(dir, "mysql.users.sql.gz")
18851876

18861877
dumpargs := append(cluster.GetDumpCredentials(server), server.GetSSLClientParam("client-dump")...)
@@ -2172,6 +2163,15 @@ func (server *ServerMonitor) JobBackupLogical() error {
21722163
// Removing previous valid backup state and start
21732164
server.DelBackupLogicalCookie()
21742165

2166+
if cluster.Conf.BackupSplitMysqlUser {
2167+
server.LastBackupMeta.Logical.SplitUser = true
2168+
err := server.JobBackupMysqldumpUser()
2169+
if err != nil {
2170+
cluster.LogModulePrintf(cluster.Conf.Verbose, config.ConstLogModTask, config.LvlErr, "Error mysqldump backup request: %s", err.Error())
2171+
return err
2172+
}
2173+
}
2174+
21752175
//Skip other type if using backup script
21762176
if cluster.Conf.BackupSaveScript != "" {
21772177
task := "script"

0 commit comments

Comments
 (0)