修复全量数据同步的bug

zhangzengfei

2023-10-21 719ebace06e36089f500485bdde521a10bf1cf6c

 serf/sync.go

@@ -410,10 +410,11 @@
   //fmt.Println("同步全量数据给节点:", targetId)
   sqls, err := DumpTables(ss.sqlDB, ss.syncTables)
   if err != nil {
      fmt.Println("DumpTables error, ", err.Error())
      logx.Errorf("DumpTables error: %s", err.Error())
      return err
   }

   logx.Infof("DumpTables sql:%v", sqls)
   syncSql := strings.Join(sqls, ";")
   if len(syncSql) < sizeLimit {
      err = ss.pubSyncSqlMessage([]byte(syncSql), targetId)
@@ -427,6 +428,10 @@

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

      if len(shard) >0 {
         err = ss.pubSyncSqlMessage([]byte(shard), targetId)
      }
   }

   return err