打印数据同步日志

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)
      }
   }