|
|
|
|
@ -35,7 +35,6 @@ type IMysqlService interface {
|
|
|
|
|
SearchWithPage(search dto.MysqlDBSearch) (int64, interface{}, error)
|
|
|
|
|
ListDBOption() ([]dto.MysqlOption, error)
|
|
|
|
|
Create(ctx context.Context, req dto.MysqlDBCreate) (*model.DatabaseMysql, error)
|
|
|
|
|
LoadFromRemote(req dto.MysqlLoadDB) error
|
|
|
|
|
ChangeAccess(info dto.ChangeDBInfo) error
|
|
|
|
|
ChangePassword(info dto.ChangeDBInfo) error
|
|
|
|
|
UpdateVariables(req dto.MysqlVariablesUpdate) error
|
|
|
|
|
@ -44,10 +43,11 @@ type IMysqlService interface {
|
|
|
|
|
DeleteCheck(req dto.MysqlDBDeleteCheck) ([]string, error)
|
|
|
|
|
Delete(ctx context.Context, req dto.MysqlDBDelete) error
|
|
|
|
|
|
|
|
|
|
LoadStatus(req dto.OperationWithNameAndType) (*dto.MysqlStatus, error)
|
|
|
|
|
LoadVariables(req dto.OperationWithNameAndType) (*dto.MysqlVariables, error)
|
|
|
|
|
LoadBaseInfo(req dto.OperationWithNameAndType) (*dto.DBBaseInfo, error)
|
|
|
|
|
LoadRemoteAccess(req dto.OperationWithNameAndType) (bool, error)
|
|
|
|
|
LoadFromRemote(req dto.OperateByID) error
|
|
|
|
|
LoadStatus(req dto.OperateByID) (*dto.MysqlStatus, error)
|
|
|
|
|
LoadVariables(req dto.OperateByID) (*dto.MysqlVariables, error)
|
|
|
|
|
LoadBaseInfo(req dto.OperateByID) (*dto.DBBaseInfo, error)
|
|
|
|
|
LoadRemoteAccess(req dto.OperateByID) (bool, error)
|
|
|
|
|
|
|
|
|
|
LoadDatabaseFile(req dto.OperationWithNameAndType) (string, error)
|
|
|
|
|
}
|
|
|
|
|
@ -58,10 +58,11 @@ func NewIMysqlService() IMysqlService {
|
|
|
|
|
|
|
|
|
|
func (u *MysqlService) SearchWithPage(search dto.MysqlDBSearch) (int64, interface{}, error) {
|
|
|
|
|
total, mysqls, err := mysqlRepo.Page(search.Page, search.PageSize,
|
|
|
|
|
mysqlRepo.WithByMysqlName(search.Database),
|
|
|
|
|
mysqlRepo.WithByDatabase(search.DatabaseID),
|
|
|
|
|
commonRepo.WithLikeName(search.Info),
|
|
|
|
|
commonRepo.WithOrderRuleBy(search.OrderBy, search.Order),
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
var dtoMysqls []dto.MysqlDBInfo
|
|
|
|
|
for _, mysql := range mysqls {
|
|
|
|
|
var item dto.MysqlDBInfo
|
|
|
|
|
@ -89,10 +90,10 @@ func (u *MysqlService) ListDBOption() ([]dto.MysqlOption, error) {
|
|
|
|
|
if err := copier.Copy(&item, &mysql); err != nil {
|
|
|
|
|
return nil, errors.WithMessage(constant.ErrStructTransform, err.Error())
|
|
|
|
|
}
|
|
|
|
|
item.Database = mysql.MysqlName
|
|
|
|
|
for _, database := range databases {
|
|
|
|
|
if database.Name == item.Database {
|
|
|
|
|
if database.ID == item.DatabaseID {
|
|
|
|
|
item.Type = database.Type
|
|
|
|
|
item.Database = database.Name
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
dbs = append(dbs, item)
|
|
|
|
|
@ -105,7 +106,7 @@ func (u *MysqlService) Create(ctx context.Context, req dto.MysqlDBCreate) (*mode
|
|
|
|
|
return nil, buserr.New(constant.ErrCmdIllegal)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
mysql, _ := mysqlRepo.Get(commonRepo.WithByName(req.Name), mysqlRepo.WithByMysqlName(req.Database), databaseRepo.WithByFrom(req.From))
|
|
|
|
|
mysql, _ := mysqlRepo.Get(commonRepo.WithByName(req.Name), mysqlRepo.WithByDatabase(req.DatabaseID))
|
|
|
|
|
if mysql.ID != 0 {
|
|
|
|
|
return nil, constant.ErrRecordExist
|
|
|
|
|
}
|
|
|
|
|
@ -115,15 +116,14 @@ func (u *MysqlService) Create(ctx context.Context, req dto.MysqlDBCreate) (*mode
|
|
|
|
|
return nil, errors.WithMessage(constant.ErrStructTransform, err.Error())
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if req.From == "local" && req.Username == "root" {
|
|
|
|
|
if req.Username == "root" {
|
|
|
|
|
return nil, errors.New("Cannot set root as user name")
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
cli, version, err := LoadMysqlClientByFrom(req.Database)
|
|
|
|
|
cli, version, _, err := LoadMysqlClientByFrom(req.DatabaseID)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
createItem.MysqlName = req.Database
|
|
|
|
|
defer cli.Close()
|
|
|
|
|
if err := cli.Create(client.CreateInfo{
|
|
|
|
|
Name: req.Name,
|
|
|
|
|
@ -144,13 +144,13 @@ func (u *MysqlService) Create(ctx context.Context, req dto.MysqlDBCreate) (*mode
|
|
|
|
|
return &createItem, nil
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (u *MysqlService) LoadFromRemote(req dto.MysqlLoadDB) error {
|
|
|
|
|
client, version, err := LoadMysqlClientByFrom(req.Database)
|
|
|
|
|
func (u *MysqlService) LoadFromRemote(req dto.OperateByID) error {
|
|
|
|
|
client, version, _, err := LoadMysqlClientByFrom(req.ID)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
databases, err := mysqlRepo.List(databaseRepo.WithByFrom(req.From))
|
|
|
|
|
dbs, err := mysqlRepo.List(mysqlRepo.WithByDatabase(req.ID))
|
|
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
@ -160,8 +160,8 @@ func (u *MysqlService) LoadFromRemote(req dto.MysqlLoadDB) error {
|
|
|
|
|
}
|
|
|
|
|
for _, data := range datas {
|
|
|
|
|
hasOld := false
|
|
|
|
|
for _, oldData := range databases {
|
|
|
|
|
if strings.EqualFold(oldData.Name, data.Name) && strings.EqualFold(oldData.MysqlName, data.MysqlName) {
|
|
|
|
|
for _, oldData := range dbs {
|
|
|
|
|
if strings.EqualFold(oldData.Name, data.Name) {
|
|
|
|
|
hasOld = true
|
|
|
|
|
break
|
|
|
|
|
}
|
|
|
|
|
@ -171,6 +171,7 @@ func (u *MysqlService) LoadFromRemote(req dto.MysqlLoadDB) error {
|
|
|
|
|
if err := copier.Copy(&createItem, &data); err != nil {
|
|
|
|
|
return errors.WithMessage(constant.ErrStructTransform, err.Error())
|
|
|
|
|
}
|
|
|
|
|
createItem.DatabaseID = req.ID
|
|
|
|
|
if err := mysqlRepo.Create(context.Background(), &createItem); err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
@ -189,9 +190,12 @@ func (u *MysqlService) DeleteCheck(req dto.MysqlDBDeleteCheck) ([]string, error)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return appInUsed, err
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
database, err := databaseRepo.Get(commonRepo.WithByID(req.DatabaseID))
|
|
|
|
|
if err != nil {
|
|
|
|
|
return appInUsed, err
|
|
|
|
|
}
|
|
|
|
|
if db.From == "local" {
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(req.Type, req.Database)
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(database.Type, database.Name)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return appInUsed, err
|
|
|
|
|
}
|
|
|
|
|
@ -220,7 +224,7 @@ func (u *MysqlService) Delete(ctx context.Context, req dto.MysqlDBDelete) error
|
|
|
|
|
if err != nil && !req.ForceDelete {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
cli, version, err := LoadMysqlClientByFrom(req.Database)
|
|
|
|
|
cli, version, database, err := LoadMysqlClientByFrom(req.DatabaseID)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
@ -235,7 +239,7 @@ func (u *MysqlService) Delete(ctx context.Context, req dto.MysqlDBDelete) error
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
uploadDir := path.Join(global.CONF.System.BaseDir, fmt.Sprintf("1panel/uploads/database/%s/%s/%s", req.Type, req.Database, db.Name))
|
|
|
|
|
uploadDir := path.Join(global.CONF.System.BaseDir, fmt.Sprintf("1panel/uploads/database/%s/%s/%s", req.Type, database, db.Name))
|
|
|
|
|
if _, err := os.Stat(uploadDir); err == nil {
|
|
|
|
|
_ = os.RemoveAll(uploadDir)
|
|
|
|
|
}
|
|
|
|
|
@ -244,13 +248,17 @@ func (u *MysqlService) Delete(ctx context.Context, req dto.MysqlDBDelete) error
|
|
|
|
|
if err != nil && !req.ForceDelete {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
backupDir := path.Join(localDir, fmt.Sprintf("database/%s/%s/%s", req.Type, db.MysqlName, db.Name))
|
|
|
|
|
backupDir := path.Join(localDir, fmt.Sprintf("database/%s/%s-%s/%s", req.Type, db.From, database, db.Name))
|
|
|
|
|
if _, err := os.Stat(backupDir); err == nil {
|
|
|
|
|
_ = os.RemoveAll(backupDir)
|
|
|
|
|
}
|
|
|
|
|
global.LOG.Infof("delete database %s-%s backups successful", req.Database, db.Name)
|
|
|
|
|
backupDir2 := path.Join(localDir, fmt.Sprintf("database/%s/%s/%s", req.Type, database, db.Name))
|
|
|
|
|
if _, err := os.Stat(backupDir2); err == nil {
|
|
|
|
|
_ = os.RemoveAll(backupDir2)
|
|
|
|
|
}
|
|
|
|
|
global.LOG.Infof("delete database %s-%s backups successful", database, db.Name)
|
|
|
|
|
}
|
|
|
|
|
_ = backupRepo.DeleteRecord(ctx, commonRepo.WithByType(req.Type), commonRepo.WithByName(req.Database), backupRepo.WithByDetailName(db.Name))
|
|
|
|
|
_ = backupRepo.DeleteRecord(ctx, commonRepo.WithByType(req.Type), commonRepo.WithByName(database), backupRepo.WithByDetailName(db.Name))
|
|
|
|
|
|
|
|
|
|
_ = mysqlRepo.Delete(ctx, commonRepo.WithByID(db.ID))
|
|
|
|
|
return nil
|
|
|
|
|
@ -260,7 +268,7 @@ func (u *MysqlService) ChangePassword(req dto.ChangeDBInfo) error {
|
|
|
|
|
if cmd.CheckIllegal(req.Value) {
|
|
|
|
|
return buserr.New(constant.ErrCmdIllegal)
|
|
|
|
|
}
|
|
|
|
|
cli, version, err := LoadMysqlClientByFrom(req.Database)
|
|
|
|
|
cli, version, database, err := LoadMysqlClientByFrom(req.DatabaseID)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
@ -291,7 +299,7 @@ func (u *MysqlService) ChangePassword(req dto.ChangeDBInfo) error {
|
|
|
|
|
if req.ID != 0 {
|
|
|
|
|
var appRess []model.AppInstallResource
|
|
|
|
|
if req.From == "local" {
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(req.Type, req.Database)
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(req.Type, database)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
@ -323,7 +331,7 @@ func (u *MysqlService) ChangePassword(req dto.ChangeDBInfo) error {
|
|
|
|
|
return nil
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if err := updateInstallInfoInDB(req.Type, req.Database, "password", false, req.Value); err != nil {
|
|
|
|
|
if err := updateInstallInfoInDB(req.Type, database, "password", false, req.Value); err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
return nil
|
|
|
|
|
@ -333,7 +341,7 @@ func (u *MysqlService) ChangeAccess(req dto.ChangeDBInfo) error {
|
|
|
|
|
if cmd.CheckIllegal(req.Value) {
|
|
|
|
|
return buserr.New(constant.ErrCmdIllegal)
|
|
|
|
|
}
|
|
|
|
|
cli, version, err := LoadMysqlClientByFrom(req.Database)
|
|
|
|
|
cli, version, _, err := LoadMysqlClientByFrom(req.DatabaseID)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
@ -370,11 +378,11 @@ func (u *MysqlService) ChangeAccess(req dto.ChangeDBInfo) error {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (u *MysqlService) UpdateConfByFile(req dto.MysqlConfUpdateByFile) error {
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(req.Type, req.Database)
|
|
|
|
|
database, err := databaseRepo.Get(commonRepo.WithByID(req.DatabaseID))
|
|
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
path := fmt.Sprintf("%s/%s/%s/conf/my.cnf", constant.AppInstallDir, req.Type, app.Name)
|
|
|
|
|
path := fmt.Sprintf("%s/%s/%s/conf/my.cnf", constant.AppInstallDir, database.Type, database.Name)
|
|
|
|
|
file, err := os.OpenFile(path, os.O_WRONLY|os.O_TRUNC, 0640)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
@ -383,20 +391,20 @@ func (u *MysqlService) UpdateConfByFile(req dto.MysqlConfUpdateByFile) error {
|
|
|
|
|
write := bufio.NewWriter(file)
|
|
|
|
|
_, _ = write.WriteString(req.File)
|
|
|
|
|
write.Flush()
|
|
|
|
|
if _, err := compose.Restart(fmt.Sprintf("%s/%s/%s/docker-compose.yml", constant.AppInstallDir, req.Type, app.Name)); err != nil {
|
|
|
|
|
if _, err := compose.Restart(fmt.Sprintf("%s/%s/%s/docker-compose.yml", constant.AppInstallDir, database.Type, database.Name)); err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
return nil
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (u *MysqlService) UpdateVariables(req dto.MysqlVariablesUpdate) error {
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(req.Type, req.Database)
|
|
|
|
|
database, err := databaseRepo.Get(commonRepo.WithByID(req.DatabaseID))
|
|
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
var files []string
|
|
|
|
|
|
|
|
|
|
path := fmt.Sprintf("%s/%s/%s/conf/my.cnf", constant.AppInstallDir, req.Type, app.Name)
|
|
|
|
|
path := fmt.Sprintf("%s/%s/%s/conf/my.cnf", constant.AppInstallDir, database.Type, database.Name)
|
|
|
|
|
lineBytes, err := os.ReadFile(path)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
@ -405,7 +413,7 @@ func (u *MysqlService) UpdateVariables(req dto.MysqlVariablesUpdate) error {
|
|
|
|
|
|
|
|
|
|
group := "[mysqld]"
|
|
|
|
|
for _, info := range req.Variables {
|
|
|
|
|
if !strings.HasPrefix(app.Version, "5.7") && !strings.HasPrefix(app.Version, "5.6") {
|
|
|
|
|
if !strings.HasPrefix(database.Version, "5.7") && !strings.HasPrefix(database.Version, "5.6") {
|
|
|
|
|
if info.Param == "query_cache_size" {
|
|
|
|
|
continue
|
|
|
|
|
}
|
|
|
|
|
@ -427,16 +435,20 @@ func (u *MysqlService) UpdateVariables(req dto.MysqlVariablesUpdate) error {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if _, err := compose.Restart(fmt.Sprintf("%s/%s/%s/docker-compose.yml", constant.AppInstallDir, req.Type, app.Name)); err != nil {
|
|
|
|
|
if _, err := compose.Restart(fmt.Sprintf("%s/%s/%s/docker-compose.yml", constant.AppInstallDir, database.Type, database.Name)); err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return nil
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (u *MysqlService) LoadBaseInfo(req dto.OperationWithNameAndType) (*dto.DBBaseInfo, error) {
|
|
|
|
|
func (u *MysqlService) LoadBaseInfo(req dto.OperateByID) (*dto.DBBaseInfo, error) {
|
|
|
|
|
database, err := databaseRepo.Get(commonRepo.WithByID(req.ID))
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
var data dto.DBBaseInfo
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(req.Type, req.Name)
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(database.Type, database.Name)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
@ -447,8 +459,12 @@ func (u *MysqlService) LoadBaseInfo(req dto.OperationWithNameAndType) (*dto.DBBa
|
|
|
|
|
return &data, nil
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (u *MysqlService) LoadRemoteAccess(req dto.OperationWithNameAndType) (bool, error) {
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(req.Type, req.Name)
|
|
|
|
|
func (u *MysqlService) LoadRemoteAccess(req dto.OperateByID) (bool, error) {
|
|
|
|
|
database, err := databaseRepo.Get(commonRepo.WithByID(req.ID))
|
|
|
|
|
if err != nil {
|
|
|
|
|
return false, err
|
|
|
|
|
}
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(database.Type, database.Name)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return false, err
|
|
|
|
|
}
|
|
|
|
|
@ -465,8 +481,12 @@ func (u *MysqlService) LoadRemoteAccess(req dto.OperationWithNameAndType) (bool,
|
|
|
|
|
return false, nil
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (u *MysqlService) LoadVariables(req dto.OperationWithNameAndType) (*dto.MysqlVariables, error) {
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(req.Type, req.Name)
|
|
|
|
|
func (u *MysqlService) LoadVariables(req dto.OperateByID) (*dto.MysqlVariables, error) {
|
|
|
|
|
database, err := databaseRepo.Get(commonRepo.WithByID(req.ID))
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(database.Type, database.Name)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
@ -483,8 +503,12 @@ func (u *MysqlService) LoadVariables(req dto.OperationWithNameAndType) (*dto.Mys
|
|
|
|
|
return &info, nil
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (u *MysqlService) LoadStatus(req dto.OperationWithNameAndType) (*dto.MysqlStatus, error) {
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(req.Type, req.Name)
|
|
|
|
|
func (u *MysqlService) LoadStatus(req dto.OperateByID) (*dto.MysqlStatus, error) {
|
|
|
|
|
database, err := databaseRepo.Get(commonRepo.WithByID(req.ID))
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(database.Type, database.Name)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
@ -622,7 +646,7 @@ func updateMyCnf(oldFiles []string, group string, param string, value interface{
|
|
|
|
|
return newFiles
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func LoadMysqlClientByFrom(database string) (mysql.MysqlClient, string, error) {
|
|
|
|
|
func LoadMysqlClientByFrom(databaseID uint) (mysql.MysqlClient, string, string, error) {
|
|
|
|
|
var (
|
|
|
|
|
dbInfo client.DBInfo
|
|
|
|
|
version string
|
|
|
|
|
@ -630,12 +654,12 @@ func LoadMysqlClientByFrom(database string) (mysql.MysqlClient, string, error) {
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
dbInfo.Timeout = 300
|
|
|
|
|
databaseItem, err := databaseRepo.Get(commonRepo.WithByName(database))
|
|
|
|
|
databaseItem, err := databaseRepo.Get(commonRepo.WithByID(databaseID))
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, "", err
|
|
|
|
|
return nil, "", databaseItem.Name, err
|
|
|
|
|
}
|
|
|
|
|
dbInfo.From = databaseItem.From
|
|
|
|
|
dbInfo.Database = database
|
|
|
|
|
dbInfo.Database = databaseItem.Name
|
|
|
|
|
if dbInfo.From != "local" {
|
|
|
|
|
dbInfo.Address = databaseItem.Address
|
|
|
|
|
dbInfo.Port = databaseItem.Port
|
|
|
|
|
@ -644,9 +668,9 @@ func LoadMysqlClientByFrom(database string) (mysql.MysqlClient, string, error) {
|
|
|
|
|
version = databaseItem.Version
|
|
|
|
|
|
|
|
|
|
} else {
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(databaseItem.Type, database)
|
|
|
|
|
app, err := appInstallRepo.LoadBaseInfo(databaseItem.Type, databaseItem.Name)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, "", err
|
|
|
|
|
return nil, "", databaseItem.Name, err
|
|
|
|
|
}
|
|
|
|
|
dbInfo.Address = app.ContainerName
|
|
|
|
|
dbInfo.Username = "root"
|
|
|
|
|
@ -656,7 +680,7 @@ func LoadMysqlClientByFrom(database string) (mysql.MysqlClient, string, error) {
|
|
|
|
|
|
|
|
|
|
cli, err := mysql.NewMysqlClient(dbInfo)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, "", err
|
|
|
|
|
return nil, "", databaseItem.Name, err
|
|
|
|
|
}
|
|
|
|
|
return cli, version, nil
|
|
|
|
|
return cli, version, databaseItem.Name, nil
|
|
|
|
|
}
|
|
|
|
|
|
ssongliu
1 year ago
committed by