fix ExecuteWriteSql

liuxiaolong

2020-05-14 62a20c839009db883a9056a095ebc9cbcee339d5

 sync.go

@@ -152,13 +152,10 @@
      sqls = append(sqls, delSql)
   }

   var dumpSqls *[]string
   dumpSqls, err := agent.GetTableDataFromCluster(syncTables)
   fmt.Println("dumpSqls:", dumpSqls, "err:",err)
   fmt.Println("len(dumpSqls):", len(*dumpSqls), "err:",err)
   if dumpSqls != nil && len(*dumpSqls) > 0 {
      for _, dumpSql := range *dumpSqls {
         sqls = append(sqls, dumpSql)
      }
      sqls = append(sqls, *dumpSqls)
   } else {
      return false
   }
@@ -201,8 +198,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
   }

@@ -220,10 +216,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
      }
   }