Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat(dbm-services): 更改mysql dbha版本切换检查入参 #1506

Merged
merged 1 commit into from
Oct 23, 2023
+22 −12
Merged

feat(dbm-services): 更改mysql dbha版本切换检查入参 #1506

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
34 changes: 22 additions & 12 deletions dbm-services/mysql/db-tools/dbactuator/pkg/components/mysql/cutover/cutover.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,12 @@ import (
type CutOverParam struct {
Host string `json:"host" validate:"required,ip"`
Cluster *MySQLClusterDetail `json:"cluster"`
IsSafe bool `json:"is_safe"`
// 客户端连接检查
ClientConnCheck bool `json:"client_conn_check"`
// 主从延迟检查
SlaveDelayCheck bool `json:"slave_delay_check"`
// 数据校验结果检查
VerifyChecksum bool `json:"verify_checksum"`
// Master 是否已经dead
IsDeadMaster bool `json:"is_dead_master"`
// 切换完成，是都需要为源Master,获取其他Slave增加复制账户
Expand Down Expand Up @@ -163,9 +168,11 @@ func (m *CutOverToSlaveComp) Example() interface{} {
},
},
},
IsSafe: true,
IsDeadMaster: false,
LockedSwitch: true,
ClientConnCheck: true,
SlaveDelayCheck: true,
VerifyChecksum: true,
IsDeadMaster: false,
LockedSwitch: true,
},
}
return comp
Expand All @@ -183,11 +190,19 @@ func (m *CutOverToSlaveComp) PreCheck() (err error) {
return err
}

// 安全模式下，检查下CheckSum,检查业务连接
if m.Params.IsSafe {
// table checksum 结果校验
if m.Params.VerifyChecksum {
if err = m.cluster.AltSlaveIns.CheckCheckSum(); err != nil {
return err
}
if m.isCutOverPair {
if err = m.cluster.AltSlaveIns.Slave.CheckCheckSum(); err != nil {
return err
}
}
}
// 客户端连接检查
if m.Params.ClientConnCheck {
prcsls, err := m.cluster.AltSlaveIns.dbConn.ShowApplicationProcesslist(m.sysUsers)
if err != nil {
logger.Error("show processlist failed %s", err.Error())
Expand All @@ -196,11 +211,6 @@ func (m *CutOverToSlaveComp) PreCheck() (err error) {
if len(prcsls) > 0 {
return fmt.Errorf("there is a connection for non system users %v", prcsls)
}
if m.isCutOverPair {
if err = m.cluster.AltSlaveIns.Slave.CheckCheckSum(); err != nil {
return err
}
}
}

// 如果源Master已经故障，以下检查跳过
Expand Down Expand Up @@ -299,7 +309,7 @@ func (m *CutOverToSlaveComp) CutOver() (binPos string, err error) {
// record cutover bin pos
if binPos, err = m.cluster.AltSlaveIns.RecordBinPos(); err != nil {
logger.Error("获取切换时候的位点信息失败: %s", err.Error())
return
return "{}", err
}
// proxy switch 待切换slave
logger.Info("proxy backend switch to %s", m.cluster.AltSlaveIns.Addr())
Expand Down
Loading