liuxiaolong
2020-05-14 f415b40162623cef084caf6c18ed3e595a5c6373
sync.go
@@ -153,10 +153,11 @@
   }
   dumpSqls, err := agent.GetTableDataFromCluster(syncTables)
   fmt.Println("len(dumpSqls):", len(*dumpSqls), "err:",err)
   if dumpSqls != nil && len(*dumpSqls) > 0 {
      fmt.Println("len(dumpSqls):", len(*dumpSqls), "err:", err)
      sqls = append(sqls, *dumpSqls)
   } else {
      fmt.Println("dumpSqls is nil, err:", err)
      return false
   }
@@ -198,8 +199,7 @@
func UpdateClusterName(clusterName, clusterID string) bool {
   sql := string("update cluster set cluster_name='" + clusterName + "' where cluster_id='" + clusterID + "'")
   _, err := sdb.ExecuteWriteSql([]string{sql}, false)
   if err != nil {
   if !sdb.DbHandle.Execute(sql) {
      return false
   }
@@ -217,10 +217,9 @@
      agent.Shutdown()
      agent = nil
      sqls := []string{"delete from cluster_node", "delete from cluster"}
      sqls := "delete from cluster_node;delete from cluster;"
      _, err = sdb.ExecuteWriteSql(sqls, false)
      if err != nil {
      if !sdb.DbHandle.Execute(sqls) {
         return false
      }
   }