(req dto.ChangeDBInfo)
| 406 | } |
| 407 | |
| 408 | func (u *MysqlService) ChangeAccess(req dto.ChangeDBInfo) error { |
| 409 | if cmd.CheckIllegal(req.Value) { |
| 410 | return buserr.New("ErrCmdIllegal") |
| 411 | } |
| 412 | cli, version, err := LoadMysqlClientByFrom(req.Database) |
| 413 | if err != nil { |
| 414 | return err |
| 415 | } |
| 416 | defer cli.Close() |
| 417 | var ( |
| 418 | mysqlData model.DatabaseMysql |
| 419 | accessInfo client.AccessChangeInfo |
| 420 | ) |
| 421 | accessInfo.Permission = req.Value |
| 422 | accessInfo.Timeout = 300 |
| 423 | accessInfo.Version = version |
| 424 | |
| 425 | if req.ID != 0 { |
| 426 | mysqlData, err = mysqlRepo.Get(repo.WithByID(req.ID)) |
| 427 | if err != nil { |
| 428 | return err |
| 429 | } |
| 430 | accessInfo.Name = mysqlData.Name |
| 431 | accessInfo.Username = mysqlData.Username |
| 432 | accessInfo.Password = mysqlData.Password |
| 433 | accessInfo.OldPermission = mysqlData.Permission |
| 434 | } else { |
| 435 | accessInfo.Username = "root" |
| 436 | } |
| 437 | if err := cli.ChangeAccess(accessInfo); err != nil { |
| 438 | return err |
| 439 | } |
| 440 | |
| 441 | if mysqlData.ID != 0 { |
| 442 | _ = mysqlRepo.Update(mysqlData.ID, map[string]interface{}{"permission": req.Value}) |
| 443 | } |
| 444 | |
| 445 | return nil |
| 446 | } |
| 447 | |
| 448 | func (u *MysqlService) UpdateVariables(req dto.MysqlVariablesUpdate) error { |
| 449 | app, err := appInstallRepo.LoadBaseInfo(req.Type, req.Database) |
nothing calls this directly
no test coverage detected