打印数据同步日志

zhangqian

2023-10-21 a7e5430cf06a82f7c17b6565bd9f1ce581187adb

打印数据同步日志

 serf/sync.go

@@ -371,7 +371,7 @@
}

func (ss *SyncServer) handleClusterMessage(msg []byte) {
    //fmt.Println("clusterMessage:", string(msg))
    logx.Infof("clusterMessage:", string(msg))
    sql := string(msg)

    if len(sql) <= 0 {
@@ -419,13 +419,13 @@
        err = ss.pubSyncSqlMessage([]byte(syncSql), targetId)
    } else {
        shard := ""
        for _, sql := range sqls{
            if len(shard) + len(sql) > sizeLimit {
        for _, sql := range sqls {
            if len(shard)+len(sql) > sizeLimit {
                err = ss.pubSyncSqlMessage([]byte(shard), targetId)
                shard = ""
            }

            shard = fmt.Sprintf("%s%s;",shard,sql)
            shard = fmt.Sprintf("%s%s;", shard, sql)
        }
    }