mirror of
https://github.com/casdoor/casdoor.git
synced 2025-05-23 02:35:49 +08:00
b285144a64
* feat: support tool for mysql master-slave sync * feat: support mysql master-master sync * feat: improve log * feat: improve code * fix: fix bug when len(res) ==0 * fix: fix bug when len(res) ==0 * feat: support master-slave sync * feat: add deleteSlaveUser for TestStopMasterSlaveSync * feat: add deleteSlaveUser for TestStopMasterSlaveSync
85 lines
3.0 KiB
Go
85 lines
3.0 KiB
Go
// Copyright 2023 The Casdoor Authors. All Rights Reserved.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package sync_v2
|
|
|
|
import "log"
|
|
|
|
// slaveStatus shows slave status
|
|
func slaveStatus(slavedb *Database) {
|
|
res := slavedb.exec("show slave status")
|
|
if len(res) == 0 {
|
|
log.Printf("no slave status for slave [%v:%v]\n", slavedb.host, slavedb.port)
|
|
return
|
|
}
|
|
log.Println("*****check slave status*****")
|
|
log.Println("slave:", slavedb.host, ":", slavedb.port)
|
|
masterServerId := res[0]["Master_Server_Id"]
|
|
log.Println("master server id:", masterServerId)
|
|
lastError := res[0]["Last_Error"]
|
|
log.Println("last error:", lastError) // this should be empty
|
|
lastIoError := res[0]["Last_IO_Error"]
|
|
log.Println("last io error:", lastIoError) // this should be empty
|
|
slaveIoState := res[0]["Slave_IO_State"]
|
|
log.Println("slave io state:", slaveIoState)
|
|
slaveIoRunning := res[0]["Slave_IO_Running"]
|
|
log.Println("slave io running:", slaveIoRunning) // this should be Yes
|
|
slaveSqlRunning := res[0]["Slave_SQL_Running"]
|
|
log.Println("slave sql running:", slaveSqlRunning) // this should be Yes
|
|
slaveSqlRunningState := res[0]["Slave_SQL_Running_State"]
|
|
log.Println("slave sql running state:", slaveSqlRunningState)
|
|
slaveSecondsBehindMaster := res[0]["Seconds_Behind_Master"]
|
|
log.Println("seconds behind master:", slaveSecondsBehindMaster) // this should be 0, if not, it means the slave is behind the master
|
|
log.Println("slave status:", res)
|
|
log.Println("****************************")
|
|
}
|
|
|
|
// stopSlave stops slave
|
|
func stopSlave(slavedb *Database) {
|
|
defer func() {
|
|
if err := recover(); err != nil {
|
|
log.Fatalln(err)
|
|
}
|
|
}()
|
|
slavedb.exec("stop slave")
|
|
slaveStatus(slavedb)
|
|
}
|
|
|
|
// startSlave starts slave
|
|
func startSlave(masterdb *Database, slavedb *Database) {
|
|
res := make([]map[string]string, 0)
|
|
defer func() {
|
|
if err := recover(); err != nil {
|
|
log.Fatalln(err)
|
|
}
|
|
}()
|
|
stopSlave(slavedb)
|
|
// get the info about master
|
|
res = masterdb.exec("show master status")
|
|
if len(res) == 0 {
|
|
log.Println("no master status")
|
|
return
|
|
}
|
|
pos := res[0]["Position"]
|
|
file := res[0]["File"]
|
|
log.Println("file:", file, ", position:", pos, ", master status:", res)
|
|
res = slavedb.exec("stop slave")
|
|
res = slavedb.exec(
|
|
"change master to master_host='%v', master_port=%v, master_user='%v', master_password='%v', master_log_file='%v', master_log_pos=%v;",
|
|
masterdb.host, masterdb.port, masterdb.slaveUser, masterdb.slavePassword, file, pos,
|
|
)
|
|
res = slavedb.exec("start slave")
|
|
slaveStatus(slavedb)
|
|
}
|