| | |
|---|
| | | return false |
|---|
| | | } |
|---|
| | | |
|---|
| | | joinSql := fmt.Sprintf("update cluster_node set isDelete=0,drift_state='',node_ip='%s',create_time='%s' where node_id='%s'", serverIp+":"+strconv.Itoa(dbSync.DefaultBindPort), fmtTimeStr, config.Server.AnalyServerId) |
|---|
| | | joinSql := fmt.Sprintf("update cluster_node set isDelete=0,drift_state='slave',node_ip='%s',create_time='%s' where node_id='%s'", serverIp+":"+strconv.Itoa(dbSync.DefaultBindPort), fmtTimeStr, config.Server.AnalyServerId) |
|---|
| | | if err = tx.Exec(joinSql).Error; err != nil { |
|---|
| | | logger.Debug("update isDelete err:", err) |
|---|
| | | return false |
|---|
