Remove FLUSH PRIVILEGES
@@ -76,11 +76,6 @@ func (u *Manager) CreateOperatorUser(pass string) error {
return errors.Wrap(err, "grant operator user")
}
- _, err = u.db.Exec("FLUSH PRIVILEGES")
- if err != nil {
- return errors.Wrap(err, "flush privileges")
- }
-
return nil
}
@@ -96,11 +91,6 @@ func (u *Manager) UpdateUserPass(user *SysUser) error {
}
}
- _, err := u.db.Exec("FLUSH PRIVILEGES")
- if err != nil {
- return errors.Wrap(err, "flush privileges")
- }
-
return nil
}
@@ -162,11 +152,6 @@ func (u *Manager) Update160MonitorUserGrant(pass string) (err error) {
return errors.Wrapf(err, "set max connections to user monitor")
}
- _, err = u.db.Exec("FLUSH PRIVILEGES")
- if err != nil {
- return errors.Wrap(err, "flush privileges")
- }
-
return nil
}
@@ -183,11 +168,6 @@ func (u *Manager) Update170XtrabackupUser(pass string) (err error) {
return errors.Wrapf(err, "grant privileges to user xtrabackup")
}
- _, err = u.db.Exec("FLUSH PRIVILEGES")
- if err != nil {
- return errors.Wrap(err, "flush privileges")
- }
-
return nil
}
@@ -204,10 +184,6 @@ func (u *Manager) Update1100SystemUserPrivilege(user *SysUser) (err error) {
}
}
- if _, err := u.db.Exec("FLUSH PRIVILEGES"); err != nil {
- return errors.Wrap(err, "flush privileges")
- }
-
return nil
}
@@ -223,10 +199,5 @@ func (u *Manager) CreateReplicationUser(password string) error {
return errors.Wrap(err, "grant replication user")
}
- _, err = u.db.Exec("FLUSH PRIVILEGES")
- if err != nil {
- return errors.Wrap(err, "flush privileges")
- }
-
return nil
}
